Documentation ¶
Overview ¶
Code generated by MockGen. DO NOT EDIT. Source: antrea.io/antrea/pkg/ipfix (interfaces: IPFIXExportingProcess,IPFIXRegistry,IPFIXCollectingProcess,IPFIXAggregationProcess)
Generated by this command:
mockgen -copyright_file hack/boilerplate/license_header.raw.txt -destination pkg/ipfix/testing/mock_ipfix.go -package testing antrea.io/antrea/pkg/ipfix IPFIXExportingProcess,IPFIXRegistry,IPFIXCollectingProcess,IPFIXAggregationProcess
Package testing is a generated GoMock package.
Index ¶
- type MockIPFIXAggregationProcess
- func (m *MockIPFIXAggregationProcess) AreCorrelatedFieldsFilled(arg0 intermediate.AggregationFlowRecord) bool
- func (m *MockIPFIXAggregationProcess) AreExternalFieldsFilled(arg0 intermediate.AggregationFlowRecord) bool
- func (m *MockIPFIXAggregationProcess) EXPECT() *MockIPFIXAggregationProcessMockRecorder
- func (m *MockIPFIXAggregationProcess) ForAllExpiredFlowRecordsDo(arg0 intermediate.FlowKeyRecordMapCallBack) error
- func (m *MockIPFIXAggregationProcess) GetExpiryFromExpirePriorityQueue() time.Duration
- func (m *MockIPFIXAggregationProcess) GetNumFlows() int64
- func (m *MockIPFIXAggregationProcess) GetRecords(arg0 *intermediate.FlowKey) []map[string]any
- func (m *MockIPFIXAggregationProcess) IsAggregatedRecordIPv4(arg0 intermediate.AggregationFlowRecord) bool
- func (m *MockIPFIXAggregationProcess) ResetStatAndThroughputElementsInRecord(arg0 entities.Record) error
- func (m *MockIPFIXAggregationProcess) SetCorrelatedFieldsFilled(arg0 *intermediate.AggregationFlowRecord, arg1 bool)
- func (m *MockIPFIXAggregationProcess) SetExternalFieldsFilled(arg0 *intermediate.AggregationFlowRecord, arg1 bool)
- func (m *MockIPFIXAggregationProcess) Start()
- func (m *MockIPFIXAggregationProcess) Stop()
- type MockIPFIXAggregationProcessMockRecorder
- func (mr *MockIPFIXAggregationProcessMockRecorder) AreCorrelatedFieldsFilled(arg0 any) *gomock.Call
- func (mr *MockIPFIXAggregationProcessMockRecorder) AreExternalFieldsFilled(arg0 any) *gomock.Call
- func (mr *MockIPFIXAggregationProcessMockRecorder) ForAllExpiredFlowRecordsDo(arg0 any) *gomock.Call
- func (mr *MockIPFIXAggregationProcessMockRecorder) GetExpiryFromExpirePriorityQueue() *gomock.Call
- func (mr *MockIPFIXAggregationProcessMockRecorder) GetNumFlows() *gomock.Call
- func (mr *MockIPFIXAggregationProcessMockRecorder) GetRecords(arg0 any) *gomock.Call
- func (mr *MockIPFIXAggregationProcessMockRecorder) IsAggregatedRecordIPv4(arg0 any) *gomock.Call
- func (mr *MockIPFIXAggregationProcessMockRecorder) ResetStatAndThroughputElementsInRecord(arg0 any) *gomock.Call
- func (mr *MockIPFIXAggregationProcessMockRecorder) SetCorrelatedFieldsFilled(arg0, arg1 any) *gomock.Call
- func (mr *MockIPFIXAggregationProcessMockRecorder) SetExternalFieldsFilled(arg0, arg1 any) *gomock.Call
- func (mr *MockIPFIXAggregationProcessMockRecorder) Start() *gomock.Call
- func (mr *MockIPFIXAggregationProcessMockRecorder) Stop() *gomock.Call
- type MockIPFIXCollectingProcess
- func (m *MockIPFIXCollectingProcess) EXPECT() *MockIPFIXCollectingProcessMockRecorder
- func (m *MockIPFIXCollectingProcess) GetMsgChan() chan *entities.Message
- func (m *MockIPFIXCollectingProcess) GetNumConnToCollector() int64
- func (m *MockIPFIXCollectingProcess) GetNumRecordsReceived() int64
- func (m *MockIPFIXCollectingProcess) Start()
- func (m *MockIPFIXCollectingProcess) Stop()
- type MockIPFIXCollectingProcessMockRecorder
- func (mr *MockIPFIXCollectingProcessMockRecorder) GetMsgChan() *gomock.Call
- func (mr *MockIPFIXCollectingProcessMockRecorder) GetNumConnToCollector() *gomock.Call
- func (mr *MockIPFIXCollectingProcessMockRecorder) GetNumRecordsReceived() *gomock.Call
- func (mr *MockIPFIXCollectingProcessMockRecorder) Start() *gomock.Call
- func (mr *MockIPFIXCollectingProcessMockRecorder) Stop() *gomock.Call
- type MockIPFIXExportingProcess
- type MockIPFIXExportingProcessMockRecorder
- type MockIPFIXRegistry
- type MockIPFIXRegistryMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockIPFIXAggregationProcess ¶
type MockIPFIXAggregationProcess struct {
// contains filtered or unexported fields
}
MockIPFIXAggregationProcess is a mock of IPFIXAggregationProcess interface.
func NewMockIPFIXAggregationProcess ¶
func NewMockIPFIXAggregationProcess(ctrl *gomock.Controller) *MockIPFIXAggregationProcess
NewMockIPFIXAggregationProcess creates a new mock instance.
func (*MockIPFIXAggregationProcess) AreCorrelatedFieldsFilled ¶ added in v1.2.0
func (m *MockIPFIXAggregationProcess) AreCorrelatedFieldsFilled(arg0 intermediate.AggregationFlowRecord) bool
AreCorrelatedFieldsFilled mocks base method.
func (*MockIPFIXAggregationProcess) AreExternalFieldsFilled ¶ added in v1.2.0
func (m *MockIPFIXAggregationProcess) AreExternalFieldsFilled(arg0 intermediate.AggregationFlowRecord) bool
AreExternalFieldsFilled mocks base method.
func (*MockIPFIXAggregationProcess) EXPECT ¶
func (m *MockIPFIXAggregationProcess) EXPECT() *MockIPFIXAggregationProcessMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIPFIXAggregationProcess) ForAllExpiredFlowRecordsDo ¶
func (m *MockIPFIXAggregationProcess) ForAllExpiredFlowRecordsDo(arg0 intermediate.FlowKeyRecordMapCallBack) error
ForAllExpiredFlowRecordsDo mocks base method.
func (*MockIPFIXAggregationProcess) GetExpiryFromExpirePriorityQueue ¶
func (m *MockIPFIXAggregationProcess) GetExpiryFromExpirePriorityQueue() time.Duration
GetExpiryFromExpirePriorityQueue mocks base method.
func (*MockIPFIXAggregationProcess) GetNumFlows ¶ added in v1.4.0
func (m *MockIPFIXAggregationProcess) GetNumFlows() int64
GetNumFlows mocks base method.
func (*MockIPFIXAggregationProcess) GetRecords ¶ added in v1.5.0
func (m *MockIPFIXAggregationProcess) GetRecords(arg0 *intermediate.FlowKey) []map[string]any
GetRecords mocks base method.
func (*MockIPFIXAggregationProcess) IsAggregatedRecordIPv4 ¶ added in v1.2.0
func (m *MockIPFIXAggregationProcess) IsAggregatedRecordIPv4(arg0 intermediate.AggregationFlowRecord) bool
IsAggregatedRecordIPv4 mocks base method.
func (*MockIPFIXAggregationProcess) ResetStatAndThroughputElementsInRecord ¶ added in v1.6.0
func (m *MockIPFIXAggregationProcess) ResetStatAndThroughputElementsInRecord(arg0 entities.Record) error
ResetStatAndThroughputElementsInRecord mocks base method.
func (*MockIPFIXAggregationProcess) SetCorrelatedFieldsFilled ¶ added in v1.2.0
func (m *MockIPFIXAggregationProcess) SetCorrelatedFieldsFilled(arg0 *intermediate.AggregationFlowRecord, arg1 bool)
SetCorrelatedFieldsFilled mocks base method.
func (*MockIPFIXAggregationProcess) SetExternalFieldsFilled ¶ added in v1.2.0
func (m *MockIPFIXAggregationProcess) SetExternalFieldsFilled(arg0 *intermediate.AggregationFlowRecord, arg1 bool)
SetExternalFieldsFilled mocks base method.
func (*MockIPFIXAggregationProcess) Start ¶
func (m *MockIPFIXAggregationProcess) Start()
Start mocks base method.
func (*MockIPFIXAggregationProcess) Stop ¶
func (m *MockIPFIXAggregationProcess) Stop()
Stop mocks base method.
type MockIPFIXAggregationProcessMockRecorder ¶
type MockIPFIXAggregationProcessMockRecorder struct {
// contains filtered or unexported fields
}
MockIPFIXAggregationProcessMockRecorder is the mock recorder for MockIPFIXAggregationProcess.
func (*MockIPFIXAggregationProcessMockRecorder) AreCorrelatedFieldsFilled ¶ added in v1.2.0
func (mr *MockIPFIXAggregationProcessMockRecorder) AreCorrelatedFieldsFilled(arg0 any) *gomock.Call
AreCorrelatedFieldsFilled indicates an expected call of AreCorrelatedFieldsFilled.
func (*MockIPFIXAggregationProcessMockRecorder) AreExternalFieldsFilled ¶ added in v1.2.0
func (mr *MockIPFIXAggregationProcessMockRecorder) AreExternalFieldsFilled(arg0 any) *gomock.Call
AreExternalFieldsFilled indicates an expected call of AreExternalFieldsFilled.
func (*MockIPFIXAggregationProcessMockRecorder) ForAllExpiredFlowRecordsDo ¶
func (mr *MockIPFIXAggregationProcessMockRecorder) ForAllExpiredFlowRecordsDo(arg0 any) *gomock.Call
ForAllExpiredFlowRecordsDo indicates an expected call of ForAllExpiredFlowRecordsDo.
func (*MockIPFIXAggregationProcessMockRecorder) GetExpiryFromExpirePriorityQueue ¶
func (mr *MockIPFIXAggregationProcessMockRecorder) GetExpiryFromExpirePriorityQueue() *gomock.Call
GetExpiryFromExpirePriorityQueue indicates an expected call of GetExpiryFromExpirePriorityQueue.
func (*MockIPFIXAggregationProcessMockRecorder) GetNumFlows ¶ added in v1.4.0
func (mr *MockIPFIXAggregationProcessMockRecorder) GetNumFlows() *gomock.Call
GetNumFlows indicates an expected call of GetNumFlows.
func (*MockIPFIXAggregationProcessMockRecorder) GetRecords ¶ added in v1.5.0
func (mr *MockIPFIXAggregationProcessMockRecorder) GetRecords(arg0 any) *gomock.Call
GetRecords indicates an expected call of GetRecords.
func (*MockIPFIXAggregationProcessMockRecorder) IsAggregatedRecordIPv4 ¶ added in v1.2.0
func (mr *MockIPFIXAggregationProcessMockRecorder) IsAggregatedRecordIPv4(arg0 any) *gomock.Call
IsAggregatedRecordIPv4 indicates an expected call of IsAggregatedRecordIPv4.
func (*MockIPFIXAggregationProcessMockRecorder) ResetStatAndThroughputElementsInRecord ¶ added in v1.6.0
func (mr *MockIPFIXAggregationProcessMockRecorder) ResetStatAndThroughputElementsInRecord(arg0 any) *gomock.Call
ResetStatAndThroughputElementsInRecord indicates an expected call of ResetStatAndThroughputElementsInRecord.
func (*MockIPFIXAggregationProcessMockRecorder) SetCorrelatedFieldsFilled ¶ added in v1.2.0
func (mr *MockIPFIXAggregationProcessMockRecorder) SetCorrelatedFieldsFilled(arg0, arg1 any) *gomock.Call
SetCorrelatedFieldsFilled indicates an expected call of SetCorrelatedFieldsFilled.
func (*MockIPFIXAggregationProcessMockRecorder) SetExternalFieldsFilled ¶ added in v1.2.0
func (mr *MockIPFIXAggregationProcessMockRecorder) SetExternalFieldsFilled(arg0, arg1 any) *gomock.Call
SetExternalFieldsFilled indicates an expected call of SetExternalFieldsFilled.
func (*MockIPFIXAggregationProcessMockRecorder) Start ¶
func (mr *MockIPFIXAggregationProcessMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockIPFIXAggregationProcessMockRecorder) Stop ¶
func (mr *MockIPFIXAggregationProcessMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
type MockIPFIXCollectingProcess ¶
type MockIPFIXCollectingProcess struct {
// contains filtered or unexported fields
}
MockIPFIXCollectingProcess is a mock of IPFIXCollectingProcess interface.
func NewMockIPFIXCollectingProcess ¶
func NewMockIPFIXCollectingProcess(ctrl *gomock.Controller) *MockIPFIXCollectingProcess
NewMockIPFIXCollectingProcess creates a new mock instance.
func (*MockIPFIXCollectingProcess) EXPECT ¶
func (m *MockIPFIXCollectingProcess) EXPECT() *MockIPFIXCollectingProcessMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIPFIXCollectingProcess) GetMsgChan ¶
func (m *MockIPFIXCollectingProcess) GetMsgChan() chan *entities.Message
GetMsgChan mocks base method.
func (*MockIPFIXCollectingProcess) GetNumConnToCollector ¶ added in v1.4.0
func (m *MockIPFIXCollectingProcess) GetNumConnToCollector() int64
GetNumConnToCollector mocks base method.
func (*MockIPFIXCollectingProcess) GetNumRecordsReceived ¶ added in v1.4.0
func (m *MockIPFIXCollectingProcess) GetNumRecordsReceived() int64
GetNumRecordsReceived mocks base method.
func (*MockIPFIXCollectingProcess) Start ¶
func (m *MockIPFIXCollectingProcess) Start()
Start mocks base method.
func (*MockIPFIXCollectingProcess) Stop ¶
func (m *MockIPFIXCollectingProcess) Stop()
Stop mocks base method.
type MockIPFIXCollectingProcessMockRecorder ¶
type MockIPFIXCollectingProcessMockRecorder struct {
// contains filtered or unexported fields
}
MockIPFIXCollectingProcessMockRecorder is the mock recorder for MockIPFIXCollectingProcess.
func (*MockIPFIXCollectingProcessMockRecorder) GetMsgChan ¶
func (mr *MockIPFIXCollectingProcessMockRecorder) GetMsgChan() *gomock.Call
GetMsgChan indicates an expected call of GetMsgChan.
func (*MockIPFIXCollectingProcessMockRecorder) GetNumConnToCollector ¶ added in v1.4.0
func (mr *MockIPFIXCollectingProcessMockRecorder) GetNumConnToCollector() *gomock.Call
GetNumConnToCollector indicates an expected call of GetNumConnToCollector.
func (*MockIPFIXCollectingProcessMockRecorder) GetNumRecordsReceived ¶ added in v1.4.0
func (mr *MockIPFIXCollectingProcessMockRecorder) GetNumRecordsReceived() *gomock.Call
GetNumRecordsReceived indicates an expected call of GetNumRecordsReceived.
func (*MockIPFIXCollectingProcessMockRecorder) Start ¶
func (mr *MockIPFIXCollectingProcessMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockIPFIXCollectingProcessMockRecorder) Stop ¶
func (mr *MockIPFIXCollectingProcessMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
type MockIPFIXExportingProcess ¶
type MockIPFIXExportingProcess struct {
// contains filtered or unexported fields
}
MockIPFIXExportingProcess is a mock of IPFIXExportingProcess interface.
func NewMockIPFIXExportingProcess ¶
func NewMockIPFIXExportingProcess(ctrl *gomock.Controller) *MockIPFIXExportingProcess
NewMockIPFIXExportingProcess creates a new mock instance.
func (*MockIPFIXExportingProcess) CloseConnToCollector ¶
func (m *MockIPFIXExportingProcess) CloseConnToCollector()
CloseConnToCollector mocks base method.
func (*MockIPFIXExportingProcess) EXPECT ¶
func (m *MockIPFIXExportingProcess) EXPECT() *MockIPFIXExportingProcessMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIPFIXExportingProcess) NewTemplateID ¶
func (m *MockIPFIXExportingProcess) NewTemplateID() uint16
NewTemplateID mocks base method.
type MockIPFIXExportingProcessMockRecorder ¶
type MockIPFIXExportingProcessMockRecorder struct {
// contains filtered or unexported fields
}
MockIPFIXExportingProcessMockRecorder is the mock recorder for MockIPFIXExportingProcess.
func (*MockIPFIXExportingProcessMockRecorder) CloseConnToCollector ¶
func (mr *MockIPFIXExportingProcessMockRecorder) CloseConnToCollector() *gomock.Call
CloseConnToCollector indicates an expected call of CloseConnToCollector.
func (*MockIPFIXExportingProcessMockRecorder) NewTemplateID ¶
func (mr *MockIPFIXExportingProcessMockRecorder) NewTemplateID() *gomock.Call
NewTemplateID indicates an expected call of NewTemplateID.
type MockIPFIXRegistry ¶
type MockIPFIXRegistry struct {
// contains filtered or unexported fields
}
MockIPFIXRegistry is a mock of IPFIXRegistry interface.
func NewMockIPFIXRegistry ¶
func NewMockIPFIXRegistry(ctrl *gomock.Controller) *MockIPFIXRegistry
NewMockIPFIXRegistry creates a new mock instance.
func (*MockIPFIXRegistry) EXPECT ¶
func (m *MockIPFIXRegistry) EXPECT() *MockIPFIXRegistryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIPFIXRegistry) GetInfoElement ¶
func (m *MockIPFIXRegistry) GetInfoElement(arg0 string, arg1 uint32) (*entities.InfoElement, error)
GetInfoElement mocks base method.
func (*MockIPFIXRegistry) LoadRegistry ¶
func (m *MockIPFIXRegistry) LoadRegistry()
LoadRegistry mocks base method.
type MockIPFIXRegistryMockRecorder ¶
type MockIPFIXRegistryMockRecorder struct {
// contains filtered or unexported fields
}
MockIPFIXRegistryMockRecorder is the mock recorder for MockIPFIXRegistry.
func (*MockIPFIXRegistryMockRecorder) GetInfoElement ¶
func (mr *MockIPFIXRegistryMockRecorder) GetInfoElement(arg0, arg1 any) *gomock.Call
GetInfoElement indicates an expected call of GetInfoElement.
func (*MockIPFIXRegistryMockRecorder) LoadRegistry ¶
func (mr *MockIPFIXRegistryMockRecorder) LoadRegistry() *gomock.Call
LoadRegistry indicates an expected call of LoadRegistry.