mocks

package
v0.1.3-alpha Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 21, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockBroker 

type MockBroker struct {
	mock.Mock
}

MockBroker is an autogenerated mock type for the Broker type

func NewMockBroker 

func NewMockBroker(t mockConstructorTestingTNewMockBroker) *MockBroker

NewMockBroker creates a new instance of MockBroker. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockBroker) AddSubscriber 

func (_m *MockBroker) AddSubscriber(_a0 pubsub.Subscriber)

AddSubscriber provides a mock function with given fields: _a0

func (*MockBroker) Broadcast 

func (_m *MockBroker) Broadcast(_a0 *optimusv1.LogEvent)

Broadcast provides a mock function with given fields: _a0

func (*MockBroker) EXPECT 

func (_m *MockBroker) EXPECT() *MockBroker_Expecter

type MockBroker_AddSubscriber_Call 

type MockBroker_AddSubscriber_Call struct {
	*mock.Call
}

MockBroker_AddSubscriber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddSubscriber'

func (*MockBroker_AddSubscriber_Call) Return 

func (_c *MockBroker_AddSubscriber_Call) Return() *MockBroker_AddSubscriber_Call

func (*MockBroker_AddSubscriber_Call) Run 

func (_c *MockBroker_AddSubscriber_Call) Run(run func(_a0 pubsub.Subscriber)) *MockBroker_AddSubscriber_Call

func (*MockBroker_AddSubscriber_Call) RunAndReturn 

func (_c *MockBroker_AddSubscriber_Call) RunAndReturn(run func(pubsub.Subscriber)) *MockBroker_AddSubscriber_Call

type MockBroker_Broadcast_Call 

type MockBroker_Broadcast_Call struct {
	*mock.Call
}

MockBroker_Broadcast_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Broadcast'

func (*MockBroker_Broadcast_Call) Return 

func (_c *MockBroker_Broadcast_Call) Return() *MockBroker_Broadcast_Call

func (*MockBroker_Broadcast_Call) Run 

func (_c *MockBroker_Broadcast_Call) Run(run func(_a0 *optimusv1.LogEvent)) *MockBroker_Broadcast_Call

func (*MockBroker_Broadcast_Call) RunAndReturn 

func (_c *MockBroker_Broadcast_Call) RunAndReturn(run func(*optimusv1.LogEvent)) *MockBroker_Broadcast_Call

type MockBroker_Expecter 

type MockBroker_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockBroker_Expecter) AddSubscriber 

func (_e *MockBroker_Expecter) AddSubscriber(_a0 interface{}) *MockBroker_AddSubscriber_Call

AddSubscriber is a helper method to define mock.On call

  • _a0 pubsub.Subscriber

func (*MockBroker_Expecter) Broadcast 

func (_e *MockBroker_Expecter) Broadcast(_a0 interface{}) *MockBroker_Broadcast_Call

Broadcast is a helper method to define mock.On call

  • _a0 *optimusv1.LogEvent

type MockDestinationProcessor 

type MockDestinationProcessor struct {
	mock.Mock
}

MockDestinationProcessor is an autogenerated mock type for the DestinationProcessor type

func NewMockDestinationProcessor 

func NewMockDestinationProcessor(t mockConstructorTestingTNewMockDestinationProcessor) *MockDestinationProcessor

NewMockDestinationProcessor creates a new instance of MockDestinationProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockDestinationProcessor) Close 

func (_m *MockDestinationProcessor) Close() error

Close provides a mock function with given fields:

func (*MockDestinationProcessor) Deliver 

func (_m *MockDestinationProcessor) Deliver(_a0 context.Context, _a1 *optimusv1.LogEvent) error

Deliver provides a mock function with given fields: _a0, _a1

func (*MockDestinationProcessor) EXPECT 

func (_m *MockDestinationProcessor) EXPECT() *MockDestinationProcessor_Expecter

func (*MockDestinationProcessor) Setup 

func (_m *MockDestinationProcessor) Setup() error

Setup provides a mock function with given fields:

type MockDestinationProcessor_Close_Call 

type MockDestinationProcessor_Close_Call struct {
	*mock.Call
}

MockDestinationProcessor_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*MockDestinationProcessor_Close_Call) Return 

func (_c *MockDestinationProcessor_Close_Call) Return(_a0 error) *MockDestinationProcessor_Close_Call

func (*MockDestinationProcessor_Close_Call) Run 

func (_c *MockDestinationProcessor_Close_Call) Run(run func()) *MockDestinationProcessor_Close_Call

func (*MockDestinationProcessor_Close_Call) RunAndReturn 

func (_c *MockDestinationProcessor_Close_Call) RunAndReturn(run func() error) *MockDestinationProcessor_Close_Call

type MockDestinationProcessor_Deliver_Call 

type MockDestinationProcessor_Deliver_Call struct {
	*mock.Call
}

MockDestinationProcessor_Deliver_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Deliver'

func (*MockDestinationProcessor_Deliver_Call) Return 

func (_c *MockDestinationProcessor_Deliver_Call) Return(_a0 error) *MockDestinationProcessor_Deliver_Call

func (*MockDestinationProcessor_Deliver_Call) Run 

func (_c *MockDestinationProcessor_Deliver_Call) Run(run func(_a0 context.Context, _a1 *optimusv1.LogEvent)) *MockDestinationProcessor_Deliver_Call

func (*MockDestinationProcessor_Deliver_Call) RunAndReturn 

func (_c *MockDestinationProcessor_Deliver_Call) RunAndReturn(run func(context.Context, *optimusv1.LogEvent) error) *MockDestinationProcessor_Deliver_Call

type MockDestinationProcessor_Expecter 

type MockDestinationProcessor_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockDestinationProcessor_Expecter) Close 

func (_e *MockDestinationProcessor_Expecter) Close() *MockDestinationProcessor_Close_Call

Close is a helper method to define mock.On call

func (*MockDestinationProcessor_Expecter) Deliver 

func (_e *MockDestinationProcessor_Expecter) Deliver(_a0 interface{}, _a1 interface{}) *MockDestinationProcessor_Deliver_Call

Deliver is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *optimusv1.LogEvent

func (*MockDestinationProcessor_Expecter) Setup 

func (_e *MockDestinationProcessor_Expecter) Setup() *MockDestinationProcessor_Setup_Call

Setup is a helper method to define mock.On call

type MockDestinationProcessor_Setup_Call 

type MockDestinationProcessor_Setup_Call struct {
	*mock.Call
}

MockDestinationProcessor_Setup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Setup'

func (*MockDestinationProcessor_Setup_Call) Return 

func (_c *MockDestinationProcessor_Setup_Call) Return(_a0 error) *MockDestinationProcessor_Setup_Call

func (*MockDestinationProcessor_Setup_Call) Run 

func (_c *MockDestinationProcessor_Setup_Call) Run(run func()) *MockDestinationProcessor_Setup_Call

func (*MockDestinationProcessor_Setup_Call) RunAndReturn 

func (_c *MockDestinationProcessor_Setup_Call) RunAndReturn(run func() error) *MockDestinationProcessor_Setup_Call

type MockFilterProcessor 

type MockFilterProcessor struct {
	mock.Mock
}

MockFilterProcessor is an autogenerated mock type for the FilterProcessor type

func NewMockFilterProcessor 

func NewMockFilterProcessor(t mockConstructorTestingTNewMockFilterProcessor) *MockFilterProcessor

NewMockFilterProcessor creates a new instance of MockFilterProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockFilterProcessor) EXPECT 

func (_m *MockFilterProcessor) EXPECT() *MockFilterProcessor_Expecter

func (*MockFilterProcessor) Process 

func (_m *MockFilterProcessor) Process(_a0 context.Context, _a1 *optimusv1.LogEvent) (*optimusv1.LogEvent, error)

Process provides a mock function with given fields: _a0, _a1

func (*MockFilterProcessor) Setup 

func (_m *MockFilterProcessor) Setup() error

Setup provides a mock function with given fields:

type MockFilterProcessor_Expecter 

type MockFilterProcessor_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockFilterProcessor_Expecter) Process 

func (_e *MockFilterProcessor_Expecter) Process(_a0 interface{}, _a1 interface{}) *MockFilterProcessor_Process_Call

Process is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *optimusv1.LogEvent

func (*MockFilterProcessor_Expecter) Setup 

func (_e *MockFilterProcessor_Expecter) Setup() *MockFilterProcessor_Setup_Call

Setup is a helper method to define mock.On call

type MockFilterProcessor_Process_Call 

type MockFilterProcessor_Process_Call struct {
	*mock.Call
}

MockFilterProcessor_Process_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Process'

func (*MockFilterProcessor_Process_Call) Return 

func (_c *MockFilterProcessor_Process_Call) Return(_a0 *optimusv1.LogEvent, _a1 error) *MockFilterProcessor_Process_Call

func (*MockFilterProcessor_Process_Call) Run 

func (_c *MockFilterProcessor_Process_Call) Run(run func(_a0 context.Context, _a1 *optimusv1.LogEvent)) *MockFilterProcessor_Process_Call

func (*MockFilterProcessor_Process_Call) RunAndReturn 

func (_c *MockFilterProcessor_Process_Call) RunAndReturn(run func(context.Context, *optimusv1.LogEvent) (*optimusv1.LogEvent, error)) *MockFilterProcessor_Process_Call

type MockFilterProcessor_Setup_Call 

type MockFilterProcessor_Setup_Call struct {
	*mock.Call
}

MockFilterProcessor_Setup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Setup'

func (*MockFilterProcessor_Setup_Call) Return 

func (_c *MockFilterProcessor_Setup_Call) Return(_a0 error) *MockFilterProcessor_Setup_Call

func (*MockFilterProcessor_Setup_Call) Run 

func (_c *MockFilterProcessor_Setup_Call) Run(run func()) *MockFilterProcessor_Setup_Call

func (*MockFilterProcessor_Setup_Call) RunAndReturn 

func (_c *MockFilterProcessor_Setup_Call) RunAndReturn(run func() error) *MockFilterProcessor_Setup_Call

type MockInputProcessor 

type MockInputProcessor struct {
	mock.Mock
}

MockInputProcessor is an autogenerated mock type for the InputProcessor type

func NewMockInputProcessor 

func NewMockInputProcessor(t mockConstructorTestingTNewMockInputProcessor) *MockInputProcessor

NewMockInputProcessor creates a new instance of MockInputProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockInputProcessor) EXPECT 

func (_m *MockInputProcessor) EXPECT() *MockInputProcessor_Expecter

func (*MockInputProcessor) Initialize 

func (_m *MockInputProcessor) Initialize(id string, broker pubsub.Broker) error

Initialize provides a mock function with given fields: id, broker

func (*MockInputProcessor) Process 

func (_m *MockInputProcessor) Process(_a0 context.Context) error

Process provides a mock function with given fields: _a0

type MockInputProcessor_Expecter 

type MockInputProcessor_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockInputProcessor_Expecter) Initialize 

func (_e *MockInputProcessor_Expecter) Initialize(id interface{}, broker interface{}) *MockInputProcessor_Initialize_Call

Initialize is a helper method to define mock.On call

  • id string
  • broker pubsub.Broker

func (*MockInputProcessor_Expecter) Process 

func (_e *MockInputProcessor_Expecter) Process(_a0 interface{}) *MockInputProcessor_Process_Call

Process is a helper method to define mock.On call

  • _a0 context.Context

type MockInputProcessor_Initialize_Call 

type MockInputProcessor_Initialize_Call struct {
	*mock.Call
}

MockInputProcessor_Initialize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Initialize'

func (*MockInputProcessor_Initialize_Call) Return 

func (_c *MockInputProcessor_Initialize_Call) Return(_a0 error) *MockInputProcessor_Initialize_Call

func (*MockInputProcessor_Initialize_Call) Run 

func (_c *MockInputProcessor_Initialize_Call) Run(run func(id string, broker pubsub.Broker)) *MockInputProcessor_Initialize_Call

func (*MockInputProcessor_Initialize_Call) RunAndReturn 

func (_c *MockInputProcessor_Initialize_Call) RunAndReturn(run func(string, pubsub.Broker) error) *MockInputProcessor_Initialize_Call

type MockInputProcessor_Process_Call 

type MockInputProcessor_Process_Call struct {
	*mock.Call
}

MockInputProcessor_Process_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Process'

func (*MockInputProcessor_Process_Call) Return 

func (_c *MockInputProcessor_Process_Call) Return(_a0 error) *MockInputProcessor_Process_Call

func (*MockInputProcessor_Process_Call) Run 

func (_c *MockInputProcessor_Process_Call) Run(run func(_a0 context.Context)) *MockInputProcessor_Process_Call

func (*MockInputProcessor_Process_Call) RunAndReturn 

func (_c *MockInputProcessor_Process_Call) RunAndReturn(run func(context.Context) error) *MockInputProcessor_Process_Call

type MockSubscriber 

type MockSubscriber struct {
	mock.Mock
}

MockSubscriber is an autogenerated mock type for the Subscriber type

func NewMockSubscriber 

func NewMockSubscriber(t mockConstructorTestingTNewMockSubscriber) *MockSubscriber

NewMockSubscriber creates a new instance of MockSubscriber. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockSubscriber) Destruct 

func (_m *MockSubscriber) Destruct()

Destruct provides a mock function with given fields:

func (*MockSubscriber) EXPECT 

func (_m *MockSubscriber) EXPECT() *MockSubscriber_Expecter

func (*MockSubscriber) GetID 

func (_m *MockSubscriber) GetID() string

GetID provides a mock function with given fields:

func (*MockSubscriber) Signal 

func (_m *MockSubscriber) Signal(_a0 *optimusv1.LogEvent)

Signal provides a mock function with given fields: _a0

type MockSubscriber_Destruct_Call 

type MockSubscriber_Destruct_Call struct {
	*mock.Call
}

MockSubscriber_Destruct_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Destruct'

func (*MockSubscriber_Destruct_Call) Return 

func (_c *MockSubscriber_Destruct_Call) Return() *MockSubscriber_Destruct_Call

func (*MockSubscriber_Destruct_Call) Run 

func (_c *MockSubscriber_Destruct_Call) Run(run func()) *MockSubscriber_Destruct_Call

func (*MockSubscriber_Destruct_Call) RunAndReturn 

func (_c *MockSubscriber_Destruct_Call) RunAndReturn(run func()) *MockSubscriber_Destruct_Call

type MockSubscriber_Expecter 

type MockSubscriber_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockSubscriber_Expecter) Destruct 

func (_e *MockSubscriber_Expecter) Destruct() *MockSubscriber_Destruct_Call

Destruct is a helper method to define mock.On call

func (*MockSubscriber_Expecter) GetID 

func (_e *MockSubscriber_Expecter) GetID() *MockSubscriber_GetID_Call

GetID is a helper method to define mock.On call

func (*MockSubscriber_Expecter) Signal 

func (_e *MockSubscriber_Expecter) Signal(_a0 interface{}) *MockSubscriber_Signal_Call

Signal is a helper method to define mock.On call

  • _a0 *optimusv1.LogEvent

type MockSubscriber_GetID_Call 

type MockSubscriber_GetID_Call struct {
	*mock.Call
}

MockSubscriber_GetID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetID'

func (*MockSubscriber_GetID_Call) Return 

func (_c *MockSubscriber_GetID_Call) Return(_a0 string) *MockSubscriber_GetID_Call

func (*MockSubscriber_GetID_Call) Run 

func (_c *MockSubscriber_GetID_Call) Run(run func()) *MockSubscriber_GetID_Call

func (*MockSubscriber_GetID_Call) RunAndReturn 

func (_c *MockSubscriber_GetID_Call) RunAndReturn(run func() string) *MockSubscriber_GetID_Call

type MockSubscriber_Signal_Call 

type MockSubscriber_Signal_Call struct {
	*mock.Call
}

MockSubscriber_Signal_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Signal'

func (*MockSubscriber_Signal_Call) Return 

func (_c *MockSubscriber_Signal_Call) Return() *MockSubscriber_Signal_Call

func (*MockSubscriber_Signal_Call) Run 

func (_c *MockSubscriber_Signal_Call) Run(run func(_a0 *optimusv1.LogEvent)) *MockSubscriber_Signal_Call

func (*MockSubscriber_Signal_Call) RunAndReturn 

func (_c *MockSubscriber_Signal_Call) RunAndReturn(run func(*optimusv1.LogEvent)) *MockSubscriber_Signal_Call

type MockTransformerImpl 

type MockTransformerImpl struct {
	mock.Mock
}

MockTransformerImpl is an autogenerated mock type for the TransformerImpl type

func NewMockTransformerImpl 

func NewMockTransformerImpl(t mockConstructorTestingTNewMockTransformerImpl) *MockTransformerImpl

NewMockTransformerImpl creates a new instance of MockTransformerImpl. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockTransformerImpl) EXPECT 

func (_m *MockTransformerImpl) EXPECT() *MockTransformerImpl_Expecter

func (*MockTransformerImpl) Initialize 

func (_m *MockTransformerImpl) Initialize() error

Initialize provides a mock function with given fields:

func (*MockTransformerImpl) Transform 

func (_m *MockTransformerImpl) Transform(ctx context.Context, data *structpb.Struct) (*structpb.Struct, error)

Transform provides a mock function with given fields: ctx, data

type MockTransformerImpl_Expecter 

type MockTransformerImpl_Expecter struct {
	// contains filtered or unexported fields
}

func (*MockTransformerImpl_Expecter) Initialize 

func (_e *MockTransformerImpl_Expecter) Initialize() *MockTransformerImpl_Initialize_Call

Initialize is a helper method to define mock.On call

func (*MockTransformerImpl_Expecter) Transform 

func (_e *MockTransformerImpl_Expecter) Transform(ctx interface{}, data interface{}) *MockTransformerImpl_Transform_Call

Transform is a helper method to define mock.On call

  • ctx context.Context
  • data *structpb.Struct

type MockTransformerImpl_Initialize_Call 

type MockTransformerImpl_Initialize_Call struct {
	*mock.Call
}

MockTransformerImpl_Initialize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Initialize'

func (*MockTransformerImpl_Initialize_Call) Return 

func (_c *MockTransformerImpl_Initialize_Call) Return(_a0 error) *MockTransformerImpl_Initialize_Call

func (*MockTransformerImpl_Initialize_Call) Run 

func (_c *MockTransformerImpl_Initialize_Call) Run(run func()) *MockTransformerImpl_Initialize_Call

func (*MockTransformerImpl_Initialize_Call) RunAndReturn 

func (_c *MockTransformerImpl_Initialize_Call) RunAndReturn(run func() error) *MockTransformerImpl_Initialize_Call

type MockTransformerImpl_Transform_Call 

type MockTransformerImpl_Transform_Call struct {
	*mock.Call
}

MockTransformerImpl_Transform_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Transform'

func (*MockTransformerImpl_Transform_Call) Return 

func (_c *MockTransformerImpl_Transform_Call) Return(_a0 *structpb.Struct, _a1 error) *MockTransformerImpl_Transform_Call

func (*MockTransformerImpl_Transform_Call) Run 

func (_c *MockTransformerImpl_Transform_Call) Run(run func(ctx context.Context, data *structpb.Struct)) *MockTransformerImpl_Transform_Call

func (*MockTransformerImpl_Transform_Call) RunAndReturn 

func (_c *MockTransformerImpl_Transform_Call) RunAndReturn(run func(context.Context, *structpb.Struct) (*structpb.Struct, error)) *MockTransformerImpl_Transform_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.