mocks

Documentation

Index

• type GenericBulkProcessor
  • func (_m *GenericBulkProcessor) Add(request *bulk.GenericBulkableAddRequest)
  • func (_m *GenericBulkProcessor) Close() error
  • func (_m *GenericBulkProcessor) Flush() error
  • func (_m *GenericBulkProcessor) Start(ctx context.Context) error
  • func (_m *GenericBulkProcessor) Stop() error
• type GenericBulkableRequest
  • func (_m *GenericBulkableRequest) Source() ([]string, error)
  • func (_m *GenericBulkableRequest) String() string

Types

type GenericBulkProcessor

type GenericBulkProcessor struct {
	mock.Mock
}

GenericBulkProcessor is an autogenerated mock type for the GenericBulkProcessor type

func (*GenericBulkProcessor) Add

func (_m *GenericBulkProcessor) Add(request *bulk.GenericBulkableAddRequest)

Add provides a mock function with given fields: request

func (*GenericBulkProcessor) Close

func (_m *GenericBulkProcessor) Close() error

Close provides a mock function with given fields:

func (*GenericBulkProcessor) Flush

func (_m *GenericBulkProcessor) Flush() error

Flush provides a mock function with given fields:

func (*GenericBulkProcessor) Start

func (_m *GenericBulkProcessor) Start(ctx context.Context) error

Start provides a mock function with given fields: ctx

func (*GenericBulkProcessor) Stop

func (_m *GenericBulkProcessor) Stop() error

Stop provides a mock function with given fields:

type GenericBulkableRequest

type GenericBulkableRequest struct {
	mock.Mock
}

GenericBulkableRequest is an autogenerated mock type for the GenericBulkableRequest type

func (*GenericBulkableRequest) Source

func (_m *GenericBulkableRequest) Source() ([]string, error)

Source provides a mock function with given fields:

func (*GenericBulkableRequest) String

func (_m *GenericBulkableRequest) String() string

String provides a mock function with given fields: