aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMike Crute <mike@crute.us>2022-05-21 23:10:37 -0700
committerMike Crute <mike@crute.us>2022-05-21 23:10:37 -0700
commitce36372cf812ae0d5e41584b865d99bdc22756ad (patch)
treeaac6270bd930152257943cb5d50fc732e14cac0e
parenta071dd1aa4ca80014633c206a31f1a137a249055 (diff)
downloadgolib-ce36372cf812ae0d5e41584b865d99bdc22756ad.tar.bz2
golib-ce36372cf812ae0d5e41584b865d99bdc22756ad.tar.xz
golib-ce36372cf812ae0d5e41584b865d99bdc22756ad.zip
echo: pass context to netbox client
-rw-r--r--echo/middleware/ip_filter.go4
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
86func (f *NetboxIPFilter) Init() error { 86func (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 {