mocks

package
v0.1.8 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AlloraClientInterface 

type AlloraClientInterface struct {
	mock.Mock
}

AlloraClientInterface is an autogenerated mock type for the AlloraClientInterface type

func NewAlloraClientInterface 

func NewAlloraClientInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *AlloraClientInterface

NewAlloraClientInterface creates a new instance of AlloraClientInterface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*AlloraClientInterface) EXPECT 

func (_m *AlloraClientInterface) EXPECT() *AlloraClientInterface_Expecter

func (*AlloraClientInterface) GetBlockByHeight 

func (_m *AlloraClientInterface) GetBlockByHeight(ctx context.Context, height int64) (*coretypes.ResultBlock, error)

GetBlockByHeight provides a mock function with given fields: ctx, height

func (*AlloraClientInterface) GetBlockResults 

func (_m *AlloraClientInterface) GetBlockResults(ctx context.Context, height int64) (*coretypes.ResultBlockResults, error)

GetBlockResults provides a mock function with given fields: ctx, height

func (*AlloraClientInterface) GetHeader 

func (_m *AlloraClientInterface) GetHeader(ctx context.Context, height int64) (*coretypes.ResultHeader, error)

GetHeader provides a mock function with given fields: ctx, height

func (*AlloraClientInterface) GetLatestBlockHeight 

func (_m *AlloraClientInterface) GetLatestBlockHeight(ctx context.Context) (int64, error)

GetLatestBlockHeight provides a mock function with given fields: ctx

type AlloraClientInterface_Expecter 

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

func (*AlloraClientInterface_Expecter) GetBlockByHeight 

func (_e *AlloraClientInterface_Expecter) GetBlockByHeight(ctx interface{}, height interface{}) *AlloraClientInterface_GetBlockByHeight_Call

GetBlockByHeight is a helper method to define mock.On call

  • ctx context.Context
  • height int64

func (*AlloraClientInterface_Expecter) GetBlockResults 

func (_e *AlloraClientInterface_Expecter) GetBlockResults(ctx interface{}, height interface{}) *AlloraClientInterface_GetBlockResults_Call

GetBlockResults is a helper method to define mock.On call

  • ctx context.Context
  • height int64

func (*AlloraClientInterface_Expecter) GetHeader 

func (_e *AlloraClientInterface_Expecter) GetHeader(ctx interface{}, height interface{}) *AlloraClientInterface_GetHeader_Call

GetHeader is a helper method to define mock.On call

  • ctx context.Context
  • height int64

func (*AlloraClientInterface_Expecter) GetLatestBlockHeight 

func (_e *AlloraClientInterface_Expecter) GetLatestBlockHeight(ctx interface{}) *AlloraClientInterface_GetLatestBlockHeight_Call

GetLatestBlockHeight is a helper method to define mock.On call

  • ctx context.Context

type AlloraClientInterface_GetBlockByHeight_Call 

type AlloraClientInterface_GetBlockByHeight_Call struct {
	*mock.Call
}

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

func (*AlloraClientInterface_GetBlockByHeight_Call) Return 

func (_c *AlloraClientInterface_GetBlockByHeight_Call) Return(_a0 *coretypes.ResultBlock, _a1 error) *AlloraClientInterface_GetBlockByHeight_Call

func (*AlloraClientInterface_GetBlockByHeight_Call) Run 

func (_c *AlloraClientInterface_GetBlockByHeight_Call) Run(run func(ctx context.Context, height int64)) *AlloraClientInterface_GetBlockByHeight_Call

func (*AlloraClientInterface_GetBlockByHeight_Call) RunAndReturn 

func (_c *AlloraClientInterface_GetBlockByHeight_Call) RunAndReturn(run func(context.Context, int64) (*coretypes.ResultBlock, error)) *AlloraClientInterface_GetBlockByHeight_Call

type AlloraClientInterface_GetBlockResults_Call 

type AlloraClientInterface_GetBlockResults_Call struct {
	*mock.Call
}

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

func (*AlloraClientInterface_GetBlockResults_Call) Return 

func (_c *AlloraClientInterface_GetBlockResults_Call) Return(_a0 *coretypes.ResultBlockResults, _a1 error) *AlloraClientInterface_GetBlockResults_Call

func (*AlloraClientInterface_GetBlockResults_Call) Run 

func (_c *AlloraClientInterface_GetBlockResults_Call) Run(run func(ctx context.Context, height int64)) *AlloraClientInterface_GetBlockResults_Call

func (*AlloraClientInterface_GetBlockResults_Call) RunAndReturn 

func (_c *AlloraClientInterface_GetBlockResults_Call) RunAndReturn(run func(context.Context, int64) (*coretypes.ResultBlockResults, error)) *AlloraClientInterface_GetBlockResults_Call

type AlloraClientInterface_GetHeader_Call 

type AlloraClientInterface_GetHeader_Call struct {
	*mock.Call
}

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

func (*AlloraClientInterface_GetHeader_Call) Return 

func (_c *AlloraClientInterface_GetHeader_Call) Return(_a0 *coretypes.ResultHeader, _a1 error) *AlloraClientInterface_GetHeader_Call

func (*AlloraClientInterface_GetHeader_Call) Run 

func (_c *AlloraClientInterface_GetHeader_Call) Run(run func(ctx context.Context, height int64)) *AlloraClientInterface_GetHeader_Call

func (*AlloraClientInterface_GetHeader_Call) RunAndReturn 

func (_c *AlloraClientInterface_GetHeader_Call) RunAndReturn(run func(context.Context, int64) (*coretypes.ResultHeader, error)) *AlloraClientInterface_GetHeader_Call

type AlloraClientInterface_GetLatestBlockHeight_Call 

type AlloraClientInterface_GetLatestBlockHeight_Call struct {
	*mock.Call
}

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

func (*AlloraClientInterface_GetLatestBlockHeight_Call) Return 

func (_c *AlloraClientInterface_GetLatestBlockHeight_Call) Return(_a0 int64, _a1 error) *AlloraClientInterface_GetLatestBlockHeight_Call

func (*AlloraClientInterface_GetLatestBlockHeight_Call) Run 

func (_c *AlloraClientInterface_GetLatestBlockHeight_Call) Run(run func(ctx context.Context)) *AlloraClientInterface_GetLatestBlockHeight_Call

func (*AlloraClientInterface_GetLatestBlockHeight_Call) RunAndReturn 

func (_c *AlloraClientInterface_GetLatestBlockHeight_Call) RunAndReturn(run func(context.Context) (int64, error)) *AlloraClientInterface_GetLatestBlockHeight_Call

type CodecInterface 

type CodecInterface struct {
	mock.Mock
}

CodecInterface is an autogenerated mock type for the CodecInterface type

func NewCodecInterface 

func NewCodecInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *CodecInterface

NewCodecInterface creates a new instance of CodecInterface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*CodecInterface) EXPECT 

func (_m *CodecInterface) EXPECT() *CodecInterface_Expecter

func (*CodecInterface) IsTypedEvent added in v0.1.4 

func (_m *CodecInterface) IsTypedEvent(event *types.Event) bool

IsTypedEvent provides a mock function with given fields: event

func (*CodecInterface) MarshalProtoJSON 

func (_m *CodecInterface) MarshalProtoJSON(event proto.Message) (json.RawMessage, error)

MarshalProtoJSON provides a mock function with given fields: event

func (*CodecInterface) ParseEvent 

func (_m *CodecInterface) ParseEvent(event *types.Event) (proto.Message, error)

ParseEvent provides a mock function with given fields: event

func (*CodecInterface) ParseTx 

func (_m *CodecInterface) ParseTx(txBytes []byte) (*tx.Tx, error)

ParseTx provides a mock function with given fields: txBytes

func (*CodecInterface) ParseTxMessage 

func (_m *CodecInterface) ParseTxMessage(message *codectypes.Any) (proto.Message, error)

ParseTxMessage provides a mock function with given fields: message

func (*CodecInterface) ParseTxMessages 

func (_m *CodecInterface) ParseTxMessages(txMessages []*codectypes.Any) ([]proto.Message, error)

ParseTxMessages provides a mock function with given fields: txMessages

func (*CodecInterface) ParseUntypedEvent added in v0.1.4 

func (_m *CodecInterface) ParseUntypedEvent(event *types.Event) (json.RawMessage, error)

ParseUntypedEvent provides a mock function with given fields: event

type CodecInterface_Expecter 

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

func (*CodecInterface_Expecter) IsTypedEvent added in v0.1.4 

func (_e *CodecInterface_Expecter) IsTypedEvent(event interface{}) *CodecInterface_IsTypedEvent_Call

IsTypedEvent is a helper method to define mock.On call

  • event *types.Event

func (*CodecInterface_Expecter) MarshalProtoJSON 

func (_e *CodecInterface_Expecter) MarshalProtoJSON(event interface{}) *CodecInterface_MarshalProtoJSON_Call

MarshalProtoJSON is a helper method to define mock.On call

  • event proto.Message

func (*CodecInterface_Expecter) ParseEvent 

func (_e *CodecInterface_Expecter) ParseEvent(event interface{}) *CodecInterface_ParseEvent_Call

ParseEvent is a helper method to define mock.On call

  • event *types.Event

func (*CodecInterface_Expecter) ParseTx 

func (_e *CodecInterface_Expecter) ParseTx(txBytes interface{}) *CodecInterface_ParseTx_Call

ParseTx is a helper method to define mock.On call

  • txBytes []byte

func (*CodecInterface_Expecter) ParseTxMessage 

func (_e *CodecInterface_Expecter) ParseTxMessage(message interface{}) *CodecInterface_ParseTxMessage_Call

ParseTxMessage is a helper method to define mock.On call

  • message *codectypes.Any

func (*CodecInterface_Expecter) ParseTxMessages 

func (_e *CodecInterface_Expecter) ParseTxMessages(txMessages interface{}) *CodecInterface_ParseTxMessages_Call

ParseTxMessages is a helper method to define mock.On call

  • txMessages []*codectypes.Any

func (*CodecInterface_Expecter) ParseUntypedEvent added in v0.1.4 

func (_e *CodecInterface_Expecter) ParseUntypedEvent(event interface{}) *CodecInterface_ParseUntypedEvent_Call

ParseUntypedEvent is a helper method to define mock.On call

  • event *types.Event

type CodecInterface_IsTypedEvent_Call added in v0.1.4 

type CodecInterface_IsTypedEvent_Call struct {
	*mock.Call
}

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

func (*CodecInterface_IsTypedEvent_Call) Return added in v0.1.4 

func (_c *CodecInterface_IsTypedEvent_Call) Return(_a0 bool) *CodecInterface_IsTypedEvent_Call

func (*CodecInterface_IsTypedEvent_Call) Run added in v0.1.4 

func (_c *CodecInterface_IsTypedEvent_Call) Run(run func(event *types.Event)) *CodecInterface_IsTypedEvent_Call

func (*CodecInterface_IsTypedEvent_Call) RunAndReturn added in v0.1.4 

func (_c *CodecInterface_IsTypedEvent_Call) RunAndReturn(run func(*types.Event) bool) *CodecInterface_IsTypedEvent_Call

type CodecInterface_MarshalProtoJSON_Call 

type CodecInterface_MarshalProtoJSON_Call struct {
	*mock.Call
}

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

func (*CodecInterface_MarshalProtoJSON_Call) Return 

func (_c *CodecInterface_MarshalProtoJSON_Call) Return(_a0 json.RawMessage, _a1 error) *CodecInterface_MarshalProtoJSON_Call

func (*CodecInterface_MarshalProtoJSON_Call) Run 

func (_c *CodecInterface_MarshalProtoJSON_Call) Run(run func(event proto.Message)) *CodecInterface_MarshalProtoJSON_Call

func (*CodecInterface_MarshalProtoJSON_Call) RunAndReturn 

func (_c *CodecInterface_MarshalProtoJSON_Call) RunAndReturn(run func(proto.Message) (json.RawMessage, error)) *CodecInterface_MarshalProtoJSON_Call

type CodecInterface_ParseEvent_Call 

type CodecInterface_ParseEvent_Call struct {
	*mock.Call
}

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

func (*CodecInterface_ParseEvent_Call) Return 

func (_c *CodecInterface_ParseEvent_Call) Return(_a0 proto.Message, _a1 error) *CodecInterface_ParseEvent_Call

func (*CodecInterface_ParseEvent_Call) Run 

func (_c *CodecInterface_ParseEvent_Call) Run(run func(event *types.Event)) *CodecInterface_ParseEvent_Call

func (*CodecInterface_ParseEvent_Call) RunAndReturn 

func (_c *CodecInterface_ParseEvent_Call) RunAndReturn(run func(*types.Event) (proto.Message, error)) *CodecInterface_ParseEvent_Call

type CodecInterface_ParseTxMessage_Call 

type CodecInterface_ParseTxMessage_Call struct {
	*mock.Call
}

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

func (*CodecInterface_ParseTxMessage_Call) Return 

func (_c *CodecInterface_ParseTxMessage_Call) Return(_a0 proto.Message, _a1 error) *CodecInterface_ParseTxMessage_Call

func (*CodecInterface_ParseTxMessage_Call) Run 

func (_c *CodecInterface_ParseTxMessage_Call) Run(run func(message *codectypes.Any)) *CodecInterface_ParseTxMessage_Call

func (*CodecInterface_ParseTxMessage_Call) RunAndReturn 

func (_c *CodecInterface_ParseTxMessage_Call) RunAndReturn(run func(*codectypes.Any) (proto.Message, error)) *CodecInterface_ParseTxMessage_Call

type CodecInterface_ParseTxMessages_Call 

type CodecInterface_ParseTxMessages_Call struct {
	*mock.Call
}

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

func (*CodecInterface_ParseTxMessages_Call) Return 

func (_c *CodecInterface_ParseTxMessages_Call) Return(_a0 []proto.Message, _a1 error) *CodecInterface_ParseTxMessages_Call

func (*CodecInterface_ParseTxMessages_Call) Run 

func (_c *CodecInterface_ParseTxMessages_Call) Run(run func(txMessages []*codectypes.Any)) *CodecInterface_ParseTxMessages_Call

func (*CodecInterface_ParseTxMessages_Call) RunAndReturn 

func (_c *CodecInterface_ParseTxMessages_Call) RunAndReturn(run func([]*codectypes.Any) ([]proto.Message, error)) *CodecInterface_ParseTxMessages_Call

type CodecInterface_ParseTx_Call 

type CodecInterface_ParseTx_Call struct {
	*mock.Call
}

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

func (*CodecInterface_ParseTx_Call) Return 

func (_c *CodecInterface_ParseTx_Call) Return(_a0 *tx.Tx, _a1 error) *CodecInterface_ParseTx_Call

func (*CodecInterface_ParseTx_Call) Run 

func (_c *CodecInterface_ParseTx_Call) Run(run func(txBytes []byte)) *CodecInterface_ParseTx_Call

func (*CodecInterface_ParseTx_Call) RunAndReturn 

func (_c *CodecInterface_ParseTx_Call) RunAndReturn(run func([]byte) (*tx.Tx, error)) *CodecInterface_ParseTx_Call

type CodecInterface_ParseUntypedEvent_Call added in v0.1.4 

type CodecInterface_ParseUntypedEvent_Call struct {
	*mock.Call
}

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

func (*CodecInterface_ParseUntypedEvent_Call) Return added in v0.1.4 

func (_c *CodecInterface_ParseUntypedEvent_Call) Return(_a0 json.RawMessage, _a1 error) *CodecInterface_ParseUntypedEvent_Call

func (*CodecInterface_ParseUntypedEvent_Call) Run added in v0.1.4 

func (_c *CodecInterface_ParseUntypedEvent_Call) Run(run func(event *types.Event)) *CodecInterface_ParseUntypedEvent_Call

func (*CodecInterface_ParseUntypedEvent_Call) RunAndReturn added in v0.1.4 

func (_c *CodecInterface_ParseUntypedEvent_Call) RunAndReturn(run func(*types.Event) (json.RawMessage, error)) *CodecInterface_ParseUntypedEvent_Call

type EventsProducer 

type EventsProducer struct {
	mock.Mock
}

EventsProducer is an autogenerated mock type for the EventsProducer type

func NewEventsProducer 

func NewEventsProducer(t interface {
	mock.TestingT
	Cleanup(func())
}) *EventsProducer

NewEventsProducer creates a new instance of EventsProducer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*EventsProducer) EXPECT 

func (_m *EventsProducer) EXPECT() *EventsProducer_Expecter

func (*EventsProducer) Execute 

func (_m *EventsProducer) Execute(ctx context.Context) error

Execute provides a mock function with given fields: ctx

type EventsProducer_Execute_Call 

type EventsProducer_Execute_Call struct {
	*mock.Call
}

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

func (*EventsProducer_Execute_Call) Return 

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

func (*EventsProducer_Execute_Call) Run 

func (_c *EventsProducer_Execute_Call) Run(run func(ctx context.Context)) *EventsProducer_Execute_Call

func (*EventsProducer_Execute_Call) RunAndReturn 

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

type EventsProducer_Expecter 

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

func (*EventsProducer_Expecter) Execute 

func (_e *EventsProducer_Expecter) Execute(ctx interface{}) *EventsProducer_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context

type FilterInterface 

type FilterInterface[T interface{}] struct {
	mock.Mock
}

FilterInterface is an autogenerated mock type for the FilterInterface type

func NewFilterInterface 

func NewFilterInterface[T interface{}](t interface {
	mock.TestingT
	Cleanup(func())
}) *FilterInterface[T]

NewFilterInterface creates a new instance of FilterInterface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*FilterInterface[T]) EXPECT 

func (_m *FilterInterface[T]) EXPECT() *FilterInterface_Expecter[T]

func (*FilterInterface[T]) ShouldProcess 

func (_m *FilterInterface[T]) ShouldProcess(typeValue *T) bool

ShouldProcess provides a mock function with given fields: typeValue

type FilterInterface_Expecter 

type FilterInterface_Expecter[T interface{}] struct {
	// contains filtered or unexported fields
}

func (*FilterInterface_Expecter[T]) ShouldProcess 

func (_e *FilterInterface_Expecter[T]) ShouldProcess(typeValue interface{}) *FilterInterface_ShouldProcess_Call[T]

ShouldProcess is a helper method to define mock.On call

  • typeValue *T

type FilterInterface_ShouldProcess_Call 

type FilterInterface_ShouldProcess_Call[T interface{}] struct {
	*mock.Call
}

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

func (*FilterInterface_ShouldProcess_Call[T]) Return 

func (_c *FilterInterface_ShouldProcess_Call[T]) Return(_a0 bool) *FilterInterface_ShouldProcess_Call[T]

func (*FilterInterface_ShouldProcess_Call[T]) Run 

func (_c *FilterInterface_ShouldProcess_Call[T]) Run(run func(typeValue *T)) *FilterInterface_ShouldProcess_Call[T]

func (*FilterInterface_ShouldProcess_Call[T]) RunAndReturn 

func (_c *FilterInterface_ShouldProcess_Call[T]) RunAndReturn(run func(*T) bool) *FilterInterface_ShouldProcess_Call[T]

type ProcessedBlockRepositoryInterface 

type ProcessedBlockRepositoryInterface struct {
	mock.Mock
}

ProcessedBlockRepositoryInterface is an autogenerated mock type for the ProcessedBlockRepositoryInterface type

func NewProcessedBlockRepositoryInterface 

func NewProcessedBlockRepositoryInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *ProcessedBlockRepositoryInterface

NewProcessedBlockRepositoryInterface creates a new instance of ProcessedBlockRepositoryInterface. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ProcessedBlockRepositoryInterface) EXPECT 

func (_m *ProcessedBlockRepositoryInterface) EXPECT() *ProcessedBlockRepositoryInterface_Expecter

func (*ProcessedBlockRepositoryInterface) GetLastProcessedBlock 

func (_m *ProcessedBlockRepositoryInterface) GetLastProcessedBlock(ctx context.Context) (domain.ProcessedBlock, error)

GetLastProcessedBlock provides a mock function with given fields: ctx

func (*ProcessedBlockRepositoryInterface) GetLastProcessedBlockEvent 

func (_m *ProcessedBlockRepositoryInterface) GetLastProcessedBlockEvent(ctx context.Context) (domain.ProcessedBlockEvent, error)

GetLastProcessedBlockEvent provides a mock function with given fields: ctx

func (*ProcessedBlockRepositoryInterface) SaveProcessedBlock 

func (_m *ProcessedBlockRepositoryInterface) SaveProcessedBlock(ctx context.Context, block domain.ProcessedBlock) error

SaveProcessedBlock provides a mock function with given fields: ctx, block

func (*ProcessedBlockRepositoryInterface) SaveProcessedBlockEvent 

func (_m *ProcessedBlockRepositoryInterface) SaveProcessedBlockEvent(ctx context.Context, blockEvent domain.ProcessedBlockEvent) error

SaveProcessedBlockEvent provides a mock function with given fields: ctx, blockEvent

type ProcessedBlockRepositoryInterface_Expecter 

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

func (*ProcessedBlockRepositoryInterface_Expecter) GetLastProcessedBlock 

func (_e *ProcessedBlockRepositoryInterface_Expecter) GetLastProcessedBlock(ctx interface{}) *ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call

GetLastProcessedBlock is a helper method to define mock.On call

  • ctx context.Context

func (*ProcessedBlockRepositoryInterface_Expecter) GetLastProcessedBlockEvent 

func (_e *ProcessedBlockRepositoryInterface_Expecter) GetLastProcessedBlockEvent(ctx interface{}) *ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call

GetLastProcessedBlockEvent is a helper method to define mock.On call

  • ctx context.Context

func (*ProcessedBlockRepositoryInterface_Expecter) SaveProcessedBlock 

func (_e *ProcessedBlockRepositoryInterface_Expecter) SaveProcessedBlock(ctx interface{}, block interface{}) *ProcessedBlockRepositoryInterface_SaveProcessedBlock_Call

SaveProcessedBlock is a helper method to define mock.On call

  • ctx context.Context
  • block domain.ProcessedBlock

func (*ProcessedBlockRepositoryInterface_Expecter) SaveProcessedBlockEvent 

func (_e *ProcessedBlockRepositoryInterface_Expecter) SaveProcessedBlockEvent(ctx interface{}, blockEvent interface{}) *ProcessedBlockRepositoryInterface_SaveProcessedBlockEvent_Call

SaveProcessedBlockEvent is a helper method to define mock.On call

  • ctx context.Context
  • blockEvent domain.ProcessedBlockEvent

type ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call 

type ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call struct {
	*mock.Call
}

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

func (*ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call) Return 

func (_c *ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call) Return(_a0 domain.ProcessedBlockEvent, _a1 error) *ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call

func (*ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call) Run 

func (_c *ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call) Run(run func(ctx context.Context)) *ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call

func (*ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call) RunAndReturn 

func (_c *ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call) RunAndReturn(run func(context.Context) (domain.ProcessedBlockEvent, error)) *ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call

type ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call 

type ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call struct {
	*mock.Call
}

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

func (*ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call) Return 

func (_c *ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call) Return(_a0 domain.ProcessedBlock, _a1 error) *ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call

func (*ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call) Run 

func (_c *ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call) Run(run func(ctx context.Context)) *ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call

func (*ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call) RunAndReturn 

func (_c *ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call) RunAndReturn(run func(context.Context) (domain.ProcessedBlock, error)) *ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call

type ProcessedBlockRepositoryInterface_SaveProcessedBlockEvent_Call 

type ProcessedBlockRepositoryInterface_SaveProcessedBlockEvent_Call struct {
	*mock.Call
}

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

func (*ProcessedBlockRepositoryInterface_SaveProcessedBlockEvent_Call) Return 

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

func (*ProcessedBlockRepositoryInterface_SaveProcessedBlockEvent_Call) Run 

func (_c *ProcessedBlockRepositoryInterface_SaveProcessedBlockEvent_Call) Run(run func(ctx context.Context, blockEvent domain.ProcessedBlockEvent)) *ProcessedBlockRepositoryInterface_SaveProcessedBlockEvent_Call

func (*ProcessedBlockRepositoryInterface_SaveProcessedBlockEvent_Call) RunAndReturn 

func (_c *ProcessedBlockRepositoryInterface_SaveProcessedBlockEvent_Call) RunAndReturn(run func(context.Context, domain.ProcessedBlockEvent) error) *ProcessedBlockRepositoryInterface_SaveProcessedBlockEvent_Call

type ProcessedBlockRepositoryInterface_SaveProcessedBlock_Call 

type ProcessedBlockRepositoryInterface_SaveProcessedBlock_Call struct {
	*mock.Call
}

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

func (*ProcessedBlockRepositoryInterface_SaveProcessedBlock_Call) Return 

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

func (*ProcessedBlockRepositoryInterface_SaveProcessedBlock_Call) Run 

func (_c *ProcessedBlockRepositoryInterface_SaveProcessedBlock_Call) Run(run func(ctx context.Context, block domain.ProcessedBlock)) *ProcessedBlockRepositoryInterface_SaveProcessedBlock_Call

func (*ProcessedBlockRepositoryInterface_SaveProcessedBlock_Call) RunAndReturn 

func (_c *ProcessedBlockRepositoryInterface_SaveProcessedBlock_Call) RunAndReturn(run func(context.Context, domain.ProcessedBlock) error) *ProcessedBlockRepositoryInterface_SaveProcessedBlock_Call

type ProcessorService 

type ProcessorService struct {
	mock.Mock
}

ProcessorService is an autogenerated mock type for the ProcessorService type

func NewProcessorService 

func NewProcessorService(t interface {
	mock.TestingT
	Cleanup(func())
}) *ProcessorService

NewProcessorService creates a new instance of ProcessorService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ProcessorService) EXPECT 

func (_m *ProcessorService) EXPECT() *ProcessorService_Expecter

func (*ProcessorService) ProcessBlock 

func (_m *ProcessorService) ProcessBlock(ctx context.Context, block *coretypes.ResultBlock) error

ProcessBlock provides a mock function with given fields: ctx, block

func (*ProcessorService) ProcessBlockResults 

func (_m *ProcessorService) ProcessBlockResults(ctx context.Context, blockResults *coretypes.ResultBlockResults, header *types.Header) error

ProcessBlockResults provides a mock function with given fields: ctx, blockResults, header

type ProcessorService_Expecter 

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

func (*ProcessorService_Expecter) ProcessBlock 

func (_e *ProcessorService_Expecter) ProcessBlock(ctx interface{}, block interface{}) *ProcessorService_ProcessBlock_Call

ProcessBlock is a helper method to define mock.On call

  • ctx context.Context
  • block *coretypes.ResultBlock

func (*ProcessorService_Expecter) ProcessBlockResults 

func (_e *ProcessorService_Expecter) ProcessBlockResults(ctx interface{}, blockResults interface{}, header interface{}) *ProcessorService_ProcessBlockResults_Call

ProcessBlockResults is a helper method to define mock.On call

  • ctx context.Context
  • blockResults *coretypes.ResultBlockResults
  • header *types.Header

type ProcessorService_ProcessBlockResults_Call 

type ProcessorService_ProcessBlockResults_Call struct {
	*mock.Call
}

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

func (*ProcessorService_ProcessBlockResults_Call) Return 

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

func (*ProcessorService_ProcessBlockResults_Call) Run 

func (_c *ProcessorService_ProcessBlockResults_Call) Run(run func(ctx context.Context, blockResults *coretypes.ResultBlockResults, header *types.Header)) *ProcessorService_ProcessBlockResults_Call

func (*ProcessorService_ProcessBlockResults_Call) RunAndReturn 

func (_c *ProcessorService_ProcessBlockResults_Call) RunAndReturn(run func(context.Context, *coretypes.ResultBlockResults, *types.Header) error) *ProcessorService_ProcessBlockResults_Call

type ProcessorService_ProcessBlock_Call 

type ProcessorService_ProcessBlock_Call struct {
	*mock.Call
}

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

func (*ProcessorService_ProcessBlock_Call) Return 

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

func (*ProcessorService_ProcessBlock_Call) Run 

func (_c *ProcessorService_ProcessBlock_Call) Run(run func(ctx context.Context, block *coretypes.ResultBlock)) *ProcessorService_ProcessBlock_Call

func (*ProcessorService_ProcessBlock_Call) RunAndReturn 

func (_c *ProcessorService_ProcessBlock_Call) RunAndReturn(run func(context.Context, *coretypes.ResultBlock) error) *ProcessorService_ProcessBlock_Call

type StreamingClient 

type StreamingClient struct {
	mock.Mock
}

StreamingClient is an autogenerated mock type for the StreamingClient type

func NewStreamingClient 

func NewStreamingClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *StreamingClient

NewStreamingClient creates a new instance of StreamingClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*StreamingClient) Close 

func (_m *StreamingClient) Close() error

Close provides a mock function with given fields:

func (*StreamingClient) EXPECT 

func (_m *StreamingClient) EXPECT() *StreamingClient_Expecter

func (*StreamingClient) Flush 

func (_m *StreamingClient) Flush(ctx context.Context) error

Flush provides a mock function with given fields: ctx

func (*StreamingClient) PublishAsync 

func (_m *StreamingClient) PublishAsync(ctx context.Context, msgType string, message []byte, blockHeight int64) error

PublishAsync provides a mock function with given fields: ctx, msgType, message, blockHeight

type StreamingClient_Close_Call 

type StreamingClient_Close_Call struct {
	*mock.Call
}

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

func (*StreamingClient_Close_Call) Return 

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

func (*StreamingClient_Close_Call) Run 

func (_c *StreamingClient_Close_Call) Run(run func()) *StreamingClient_Close_Call

func (*StreamingClient_Close_Call) RunAndReturn 

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

type StreamingClient_Expecter 

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

func (*StreamingClient_Expecter) Close 

func (_e *StreamingClient_Expecter) Close() *StreamingClient_Close_Call

Close is a helper method to define mock.On call

func (*StreamingClient_Expecter) Flush 

func (_e *StreamingClient_Expecter) Flush(ctx interface{}) *StreamingClient_Flush_Call

Flush is a helper method to define mock.On call

  • ctx context.Context

func (*StreamingClient_Expecter) PublishAsync 

func (_e *StreamingClient_Expecter) PublishAsync(ctx interface{}, msgType interface{}, message interface{}, blockHeight interface{}) *StreamingClient_PublishAsync_Call

PublishAsync is a helper method to define mock.On call

  • ctx context.Context
  • msgType string
  • message []byte
  • blockHeight int64

type StreamingClient_Flush_Call 

type StreamingClient_Flush_Call struct {
	*mock.Call
}

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

func (*StreamingClient_Flush_Call) Return 

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

func (*StreamingClient_Flush_Call) Run 

func (_c *StreamingClient_Flush_Call) Run(run func(ctx context.Context)) *StreamingClient_Flush_Call

func (*StreamingClient_Flush_Call) RunAndReturn 

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

type StreamingClient_PublishAsync_Call 

type StreamingClient_PublishAsync_Call struct {
	*mock.Call
}

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

func (*StreamingClient_PublishAsync_Call) Return 

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

func (*StreamingClient_PublishAsync_Call) Run 

func (_c *StreamingClient_PublishAsync_Call) Run(run func(ctx context.Context, msgType string, message []byte, blockHeight int64)) *StreamingClient_PublishAsync_Call

func (*StreamingClient_PublishAsync_Call) RunAndReturn 

func (_c *StreamingClient_PublishAsync_Call) RunAndReturn(run func(context.Context, string, []byte, int64) error) *StreamingClient_PublishAsync_Call

type TopicRouter 

type TopicRouter struct {
	mock.Mock
}

TopicRouter is an autogenerated mock type for the TopicRouter type

func NewTopicRouter 

func NewTopicRouter(t interface {
	mock.TestingT
	Cleanup(func())
}) *TopicRouter

NewTopicRouter creates a new instance of TopicRouter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*TopicRouter) EXPECT 

func (_m *TopicRouter) EXPECT() *TopicRouter_Expecter

func (*TopicRouter) GetTopic 

func (_m *TopicRouter) GetTopic(msgType string) (string, error)

GetTopic provides a mock function with given fields: msgType

type TopicRouter_Expecter 

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

func (*TopicRouter_Expecter) GetTopic 

func (_e *TopicRouter_Expecter) GetTopic(msgType interface{}) *TopicRouter_GetTopic_Call

GetTopic is a helper method to define mock.On call

  • msgType string

type TopicRouter_GetTopic_Call 

type TopicRouter_GetTopic_Call struct {
	*mock.Call
}

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

func (*TopicRouter_GetTopic_Call) Return 

func (_c *TopicRouter_GetTopic_Call) Return(_a0 string, _a1 error) *TopicRouter_GetTopic_Call

func (*TopicRouter_GetTopic_Call) Run 

func (_c *TopicRouter_GetTopic_Call) Run(run func(msgType string)) *TopicRouter_GetTopic_Call

func (*TopicRouter_GetTopic_Call) RunAndReturn 

func (_c *TopicRouter_GetTopic_Call) RunAndReturn(run func(string) (string, error)) *TopicRouter_GetTopic_Call

type TransactionsProducer 

type TransactionsProducer struct {
	mock.Mock
}

TransactionsProducer is an autogenerated mock type for the TransactionsProducer type

func NewTransactionsProducer 

func NewTransactionsProducer(t interface {
	mock.TestingT
	Cleanup(func())
}) *TransactionsProducer

NewTransactionsProducer creates a new instance of TransactionsProducer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*TransactionsProducer) EXPECT 

func (_m *TransactionsProducer) EXPECT() *TransactionsProducer_Expecter

func (*TransactionsProducer) Execute 

func (_m *TransactionsProducer) Execute(ctx context.Context) error

Execute provides a mock function with given fields: ctx

type TransactionsProducer_Execute_Call 

type TransactionsProducer_Execute_Call struct {
	*mock.Call
}

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

func (*TransactionsProducer_Execute_Call) Return 

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

func (*TransactionsProducer_Execute_Call) Run 

func (_c *TransactionsProducer_Execute_Call) Run(run func(ctx context.Context)) *TransactionsProducer_Execute_Call

func (*TransactionsProducer_Execute_Call) RunAndReturn 

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

type TransactionsProducer_Expecter 

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

func (*TransactionsProducer_Expecter) Execute 

func (_e *TransactionsProducer_Expecter) Execute(ctx interface{}) *TransactionsProducer_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context

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.