diff options
author | Mike Crute <mike@crute.us> | 2022-05-21 23:10:37 -0700 |
---|---|---|
committer | Mike Crute <mike@crute.us> | 2022-05-21 23:10:37 -0700 |
commit | ce36372cf812ae0d5e41584b865d99bdc22756ad (patch) | |
tree | aac6270bd930152257943cb5d50fc732e14cac0e | |
parent | a071dd1aa4ca80014633c206a31f1a137a249055 (diff) | |
download | golib-ce36372cf812ae0d5e41584b865d99bdc22756ad.tar.bz2 golib-ce36372cf812ae0d5e41584b865d99bdc22756ad.tar.xz golib-ce36372cf812ae0d5e41584b865d99bdc22756ad.zip |
echo: pass context to netbox client
-rw-r--r-- | echo/middleware/ip_filter.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/echo/middleware/ip_filter.go b/echo/middleware/ip_filter.go index fe601d2..034542e 100644 --- a/echo/middleware/ip_filter.go +++ b/echo/middleware/ip_filter.go | |||
@@ -84,7 +84,7 @@ type NetboxIPFilter struct { | |||
84 | } | 84 | } |
85 | 85 | ||
86 | func (f *NetboxIPFilter) Init() error { | 86 | func (f *NetboxIPFilter) Init() error { |
87 | nets, err := f.NetboxClient.GetPrefixesWithTag(f.Tag) | 87 | nets, err := f.NetboxClient.GetPrefixesWithTag(context.Background(), f.Tag) |
88 | if err != nil { | 88 | if err != nil { |
89 | return err | 89 | return err |
90 | } | 90 | } |
@@ -119,7 +119,7 @@ func (f *NetboxIPFilter) RunRefresh(c context.Context, wg *sync.WaitGroup) error | |||
119 | for { | 119 | for { |
120 | select { | 120 | select { |
121 | case <-t.C: | 121 | case <-t.C: |
122 | if nets, err := f.NetboxClient.GetPrefixesWithTag(f.Tag); err != nil { | 122 | if nets, err := f.NetboxClient.GetPrefixesWithTag(c, f.Tag); err != nil { |
123 | f.Logger.Errorf("Error refreshing netbox prefixes for IP filter: %w", err) | 123 | f.Logger.Errorf("Error refreshing netbox prefixes for IP filter: %w", err) |
124 | netboxFilterFailures.Inc() | 124 | netboxFilterFailures.Inc() |
125 | } else { | 125 | } else { |