diff --git a/go.mod b/go.mod index 140357545c3..f88268120bf 100644 --- a/go.mod +++ b/go.mod @@ -52,7 +52,7 @@ require ( github.com/stretchr/testify v1.9.0 github.com/ti-mo/conntrack v0.5.1 github.com/vishvananda/netlink v1.3.0 - github.com/vmware/go-ipfix v0.9.0 + github.com/vmware/go-ipfix v0.10.0 go.uber.org/mock v0.4.0 golang.org/x/crypto v0.26.0 golang.org/x/mod v0.20.0 diff --git a/go.sum b/go.sum index 7f65cdd6dce..4af11307196 100644 --- a/go.sum +++ b/go.sum @@ -766,8 +766,8 @@ github.com/vishvananda/netlink v1.3.0/go.mod h1:i6NetklAujEcC6fK0JPjT8qSwWyO0HLn github.com/vishvananda/netns v0.0.0-20200728191858-db3c7e526aae/go.mod h1:DD4vA1DwXk04H54A1oHXtwZmA0grkVMdPxx/VGLCah0= github.com/vishvananda/netns v0.0.4 h1:Oeaw1EM2JMxD51g9uhtC0D7erkIjgmj8+JZc26m1YX8= github.com/vishvananda/netns v0.0.4/go.mod h1:SpkAiCQRtJ6TvvxPnOSyH3BMl6unz3xZlaprSwhNNJM= -github.com/vmware/go-ipfix v0.9.0 h1:4/N5eFliqULEaCUQV0lafOpN/1bItPE9OTAPGhrIXus= -github.com/vmware/go-ipfix v0.9.0/go.mod h1:MYEdL6Uel2ufOZyVCKvIAaw9hwnewK8aPr7rnwRbxMY= +github.com/vmware/go-ipfix v0.10.0 h1:MYd4bAiaP8fD1M8jYP5/ojwUBPvLqasodS3YwnI3ZpQ= +github.com/vmware/go-ipfix v0.10.0/go.mod h1:a39eX0v1P8y8EGPU0y77hf8JHJHjuaXxdizXMPZw1VY= github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2 h1:eY9dn8+vbi4tKz5Qo6v2eYzo7kUS51QINcR5jNpbZS8= github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2/go.mod h1:UETIi67q53MR2AWcXfiuqkDkRtnGDLqkBTpCHuJHxtU= github.com/xlab/treeprint v1.2.0 h1:HzHnuAF1plUN2zGlAFHbSQP2qJ0ZAD3XF5XD7OesXRQ= diff --git a/pkg/ipfix/ipfix_collector.go b/pkg/ipfix/ipfix_collector.go index 659ce466a6f..26be98e4ca0 100644 --- a/pkg/ipfix/ipfix_collector.go +++ b/pkg/ipfix/ipfix_collector.go @@ -22,7 +22,7 @@ import ( type IPFIXCollectingProcess interface { Start() Stop() - GetMsgChan() chan *ipfixentities.Message + GetMsgChan() <-chan *ipfixentities.Message GetNumRecordsReceived() int64 GetNumConnToCollector() int64 } diff --git a/pkg/ipfix/testing/mock_ipfix.go b/pkg/ipfix/testing/mock_ipfix.go index 455a28cb1f2..7bf265b84a9 100644 --- a/pkg/ipfix/testing/mock_ipfix.go +++ b/pkg/ipfix/testing/mock_ipfix.go @@ -171,10 +171,10 @@ func (m *MockIPFIXCollectingProcess) EXPECT() *MockIPFIXCollectingProcessMockRec } // GetMsgChan mocks base method. -func (m *MockIPFIXCollectingProcess) GetMsgChan() chan *entities.Message { +func (m *MockIPFIXCollectingProcess) GetMsgChan() <-chan *entities.Message { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "GetMsgChan") - ret0, _ := ret[0].(chan *entities.Message) + ret0, _ := ret[0].(<-chan *entities.Message) return ret0 }