mocks

package
v0.1.10 Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2024 License: Apache-2.0 Imports: 11 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

func (*AlloraClientInterface) Query added in v0.1.10 

func (_m *AlloraClientInterface) Query(ctx context.Context, path string, data bytes.HexBytes) (*coretypes.ResultABCIQuery, error)

Query provides a mock function with given fields: ctx, path, data

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

func (*AlloraClientInterface_Expecter) Query added in v0.1.10 

func (_e *AlloraClientInterface_Expecter) Query(ctx interface{}, path interface{}, data interface{}) *AlloraClientInterface_Query_Call

Query is a helper method to define mock.On call

  • ctx context.Context
  • path string
  • data bytes.HexBytes

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 AlloraClientInterface_Query_Call added in v0.1.10 

type AlloraClientInterface_Query_Call struct {
	*mock.Call
}

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

func (*AlloraClientInterface_Query_Call) Return added in v0.1.10 

func (_c *AlloraClientInterface_Query_Call) Return(_a0 *coretypes.ResultABCIQuery, _a1 error) *AlloraClientInterface_Query_Call

func (*AlloraClientInterface_Query_Call) Run added in v0.1.10 

func (_c *AlloraClientInterface_Query_Call) Run(run func(ctx context.Context, path string, data bytes.HexBytes)) *AlloraClientInterface_Query_Call

func (*AlloraClientInterface_Query_Call) RunAndReturn added in v0.1.10 

func (_c *AlloraClientInterface_Query_Call) RunAndReturn(run func(context.Context, string, bytes.HexBytes) (*coretypes.ResultABCIQuery, error)) *AlloraClientInterface_Query_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 any] struct {
	mock.Mock
}

FilterInterface is an autogenerated mock type for the FilterInterface type

func NewFilterInterface 

func NewFilterInterface[T any](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 any] 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 any] 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 QueryProcessor added in v0.1.10 

type QueryProcessor struct {
	mock.Mock
}

QueryProcessor is an autogenerated mock type for the QueryProcessor type

func NewQueryProcessor added in v0.1.10 

func NewQueryProcessor(t interface {
	mock.TestingT
	Cleanup(func())
}) *QueryProcessor

NewQueryProcessor creates a new instance of QueryProcessor. 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 (*QueryProcessor) EXPECT added in v0.1.10 

func (_m *QueryProcessor) EXPECT() *QueryProcessor_Expecter

func (*QueryProcessor) GetMaxTopicID added in v0.1.10 

func (_m *QueryProcessor) GetMaxTopicID(ctx context.Context) (uint64, error)

GetMaxTopicID provides a mock function with given fields: ctx

func (*QueryProcessor) ProcessEmissionInfo added in v0.1.10 

func (_m *QueryProcessor) ProcessEmissionInfo(ctx context.Context) error

ProcessEmissionInfo provides a mock function with given fields: ctx

func (*QueryProcessor) ProcessInflation added in v0.1.10 

func (_m *QueryProcessor) ProcessInflation(ctx context.Context) error

ProcessInflation provides a mock function with given fields: ctx

func (*QueryProcessor) ProcessNaiveInfererNetworkRegret added in v0.1.10 

func (_m *QueryProcessor) ProcessNaiveInfererNetworkRegret(ctx context.Context, topicID uint64) error

ProcessNaiveInfererNetworkRegret provides a mock function with given fields: ctx, topicID

func (*QueryProcessor) ProcessNetworkInferences added in v0.1.10 

func (_m *QueryProcessor) ProcessNetworkInferences(ctx context.Context, topicID uint64) error

ProcessNetworkInferences provides a mock function with given fields: ctx, topicID

type QueryProcessor_Expecter added in v0.1.10 

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

func (*QueryProcessor_Expecter) GetMaxTopicID added in v0.1.10 

func (_e *QueryProcessor_Expecter) GetMaxTopicID(ctx interface{}) *QueryProcessor_GetMaxTopicID_Call

GetMaxTopicID is a helper method to define mock.On call

  • ctx context.Context

func (*QueryProcessor_Expecter) ProcessEmissionInfo added in v0.1.10 

func (_e *QueryProcessor_Expecter) ProcessEmissionInfo(ctx interface{}) *QueryProcessor_ProcessEmissionInfo_Call

ProcessEmissionInfo is a helper method to define mock.On call

  • ctx context.Context

func (*QueryProcessor_Expecter) ProcessInflation added in v0.1.10 

func (_e *QueryProcessor_Expecter) ProcessInflation(ctx interface{}) *QueryProcessor_ProcessInflation_Call

ProcessInflation is a helper method to define mock.On call

  • ctx context.Context

func (*QueryProcessor_Expecter) ProcessNaiveInfererNetworkRegret added in v0.1.10 

func (_e *QueryProcessor_Expecter) ProcessNaiveInfererNetworkRegret(ctx interface{}, topicID interface{}) *QueryProcessor_ProcessNaiveInfererNetworkRegret_Call

ProcessNaiveInfererNetworkRegret is a helper method to define mock.On call

  • ctx context.Context
  • topicID uint64

func (*QueryProcessor_Expecter) ProcessNetworkInferences added in v0.1.10 

func (_e *QueryProcessor_Expecter) ProcessNetworkInferences(ctx interface{}, topicID interface{}) *QueryProcessor_ProcessNetworkInferences_Call

ProcessNetworkInferences is a helper method to define mock.On call

  • ctx context.Context
  • topicID uint64

type QueryProcessor_GetMaxTopicID_Call added in v0.1.10 

type QueryProcessor_GetMaxTopicID_Call struct {
	*mock.Call
}

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

func (*QueryProcessor_GetMaxTopicID_Call) Return added in v0.1.10 

func (_c *QueryProcessor_GetMaxTopicID_Call) Return(_a0 uint64, _a1 error) *QueryProcessor_GetMaxTopicID_Call

func (*QueryProcessor_GetMaxTopicID_Call) Run added in v0.1.10 

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

func (*QueryProcessor_GetMaxTopicID_Call) RunAndReturn added in v0.1.10 

func (_c *QueryProcessor_GetMaxTopicID_Call) RunAndReturn(run func(context.Context) (uint64, error)) *QueryProcessor_GetMaxTopicID_Call

type QueryProcessor_ProcessEmissionInfo_Call added in v0.1.10 

type QueryProcessor_ProcessEmissionInfo_Call struct {
	*mock.Call
}

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

func (*QueryProcessor_ProcessEmissionInfo_Call) Return added in v0.1.10 

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

func (*QueryProcessor_ProcessEmissionInfo_Call) Run added in v0.1.10 

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

func (*QueryProcessor_ProcessEmissionInfo_Call) RunAndReturn added in v0.1.10 

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

type QueryProcessor_ProcessInflation_Call added in v0.1.10 

type QueryProcessor_ProcessInflation_Call struct {
	*mock.Call
}

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

func (*QueryProcessor_ProcessInflation_Call) Return added in v0.1.10 

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

func (*QueryProcessor_ProcessInflation_Call) Run added in v0.1.10 

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

func (*QueryProcessor_ProcessInflation_Call) RunAndReturn added in v0.1.10 

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

type QueryProcessor_ProcessNaiveInfererNetworkRegret_Call added in v0.1.10 

type QueryProcessor_ProcessNaiveInfererNetworkRegret_Call struct {
	*mock.Call
}

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

func (*QueryProcessor_ProcessNaiveInfererNetworkRegret_Call) Return added in v0.1.10 

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

func (*QueryProcessor_ProcessNaiveInfererNetworkRegret_Call) Run added in v0.1.10 

func (_c *QueryProcessor_ProcessNaiveInfererNetworkRegret_Call) Run(run func(ctx context.Context, topicID uint64)) *QueryProcessor_ProcessNaiveInfererNetworkRegret_Call

func (*QueryProcessor_ProcessNaiveInfererNetworkRegret_Call) RunAndReturn added in v0.1.10 

func (_c *QueryProcessor_ProcessNaiveInfererNetworkRegret_Call) RunAndReturn(run func(context.Context, uint64) error) *QueryProcessor_ProcessNaiveInfererNetworkRegret_Call

type QueryProcessor_ProcessNetworkInferences_Call added in v0.1.10 

type QueryProcessor_ProcessNetworkInferences_Call struct {
	*mock.Call
}

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

func (*QueryProcessor_ProcessNetworkInferences_Call) Return added in v0.1.10 

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

func (*QueryProcessor_ProcessNetworkInferences_Call) Run added in v0.1.10 

func (_c *QueryProcessor_ProcessNetworkInferences_Call) Run(run func(ctx context.Context, topicID uint64)) *QueryProcessor_ProcessNetworkInferences_Call

func (*QueryProcessor_ProcessNetworkInferences_Call) RunAndReturn added in v0.1.10 

func (_c *QueryProcessor_ProcessNetworkInferences_Call) RunAndReturn(run func(context.Context, uint64) error) *QueryProcessor_ProcessNetworkInferences_Call

type QueryProducer added in v0.1.10 

type QueryProducer struct {
	mock.Mock
}

QueryProducer is an autogenerated mock type for the QueryProducer type

func NewQueryProducer added in v0.1.10 

func NewQueryProducer(t interface {
	mock.TestingT
	Cleanup(func())
}) *QueryProducer

NewQueryProducer creates a new instance of QueryProducer. 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 (*QueryProducer) EXPECT added in v0.1.10 

func (_m *QueryProducer) EXPECT() *QueryProducer_Expecter

func (*QueryProducer) Execute added in v0.1.10 

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

Execute provides a mock function with given fields: ctx

type QueryProducer_Execute_Call added in v0.1.10 

type QueryProducer_Execute_Call struct {
	*mock.Call
}

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

func (*QueryProducer_Execute_Call) Return added in v0.1.10 

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

func (*QueryProducer_Execute_Call) Run added in v0.1.10 

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

func (*QueryProducer_Execute_Call) RunAndReturn added in v0.1.10 

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

type QueryProducer_Expecter added in v0.1.10 

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

func (*QueryProducer_Expecter) Execute added in v0.1.10 

func (_e *QueryProducer_Expecter) Execute(ctx interface{}) *QueryProducer_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context

type QueryResultRepositoryInterface added in v0.1.10 

type QueryResultRepositoryInterface struct {
	mock.Mock
}

QueryResultRepositoryInterface is an autogenerated mock type for the QueryResultRepositoryInterface type

func NewQueryResultRepositoryInterface added in v0.1.10 

func NewQueryResultRepositoryInterface(t interface {
	mock.TestingT
	Cleanup(func())
}) *QueryResultRepositoryInterface

NewQueryResultRepositoryInterface creates a new instance of QueryResultRepositoryInterface. 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 (*QueryResultRepositoryInterface) EXPECT added in v0.1.10 

func (_m *QueryResultRepositoryInterface) EXPECT() *QueryResultRepositoryInterface_Expecter

func (*QueryResultRepositoryInterface) SaveQueryResult added in v0.1.10 

func (_m *QueryResultRepositoryInterface) SaveQueryResult(ctx context.Context, key string, queryType string, metadata json.RawMessage, value json.RawMessage) error

SaveQueryResult provides a mock function with given fields: ctx, key, queryType, metadata, value

type QueryResultRepositoryInterface_Expecter added in v0.1.10 

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

func (*QueryResultRepositoryInterface_Expecter) SaveQueryResult added in v0.1.10 

func (_e *QueryResultRepositoryInterface_Expecter) SaveQueryResult(ctx interface{}, key interface{}, queryType interface{}, metadata interface{}, value interface{}) *QueryResultRepositoryInterface_SaveQueryResult_Call

SaveQueryResult is a helper method to define mock.On call

  • ctx context.Context
  • key string
  • queryType string
  • metadata json.RawMessage
  • value json.RawMessage

type QueryResultRepositoryInterface_SaveQueryResult_Call added in v0.1.10 

type QueryResultRepositoryInterface_SaveQueryResult_Call struct {
	*mock.Call
}

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

func (*QueryResultRepositoryInterface_SaveQueryResult_Call) Return added in v0.1.10 

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

func (*QueryResultRepositoryInterface_SaveQueryResult_Call) Run added in v0.1.10 

func (_c *QueryResultRepositoryInterface_SaveQueryResult_Call) Run(run func(ctx context.Context, key string, queryType string, metadata json.RawMessage, value json.RawMessage)) *QueryResultRepositoryInterface_SaveQueryResult_Call

func (*QueryResultRepositoryInterface_SaveQueryResult_Call) RunAndReturn added in v0.1.10 

func (_c *QueryResultRepositoryInterface_SaveQueryResult_Call) RunAndReturn(run func(context.Context, string, string, json.RawMessage, json.RawMessage) error) *QueryResultRepositoryInterface_SaveQueryResult_Call

type QueryService added in v0.1.10 

type QueryService struct {
	mock.Mock
}

QueryService is an autogenerated mock type for the QueryService type

func NewQueryService added in v0.1.10 

func NewQueryService(t interface {
	mock.TestingT
	Cleanup(func())
}) *QueryService

NewQueryService creates a new instance of QueryService. 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 (*QueryService) EXPECT added in v0.1.10 

func (_m *QueryService) EXPECT() *QueryService_Expecter

func (*QueryService) GetEmissionInfo added in v0.1.10 

func (_m *QueryService) GetEmissionInfo(ctx context.Context) (*domain.QueryResult, error)

GetEmissionInfo provides a mock function with given fields: ctx

func (*QueryService) GetInflation added in v0.1.10 

func (_m *QueryService) GetInflation(ctx context.Context) (*domain.QueryResult, error)

GetInflation provides a mock function with given fields: ctx

func (*QueryService) GetLatestNetworkInferences added in v0.1.10 

func (_m *QueryService) GetLatestNetworkInferences(ctx context.Context, topicID uint64) (*domain.QueryResult, error)

GetLatestNetworkInferences provides a mock function with given fields: ctx, topicID

func (*QueryService) GetNaiveInfererNetworkRegret added in v0.1.10 

func (_m *QueryService) GetNaiveInfererNetworkRegret(ctx context.Context, topicID uint64) (*domain.QueryResult, error)

GetNaiveInfererNetworkRegret provides a mock function with given fields: ctx, topicID

func (*QueryService) GetNextTopicID added in v0.1.10 

func (_m *QueryService) GetNextTopicID(ctx context.Context) (uint64, error)

GetNextTopicID provides a mock function with given fields: ctx

type QueryService_Expecter added in v0.1.10 

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

func (*QueryService_Expecter) GetEmissionInfo added in v0.1.10 

func (_e *QueryService_Expecter) GetEmissionInfo(ctx interface{}) *QueryService_GetEmissionInfo_Call

GetEmissionInfo is a helper method to define mock.On call

  • ctx context.Context

func (*QueryService_Expecter) GetInflation added in v0.1.10 

func (_e *QueryService_Expecter) GetInflation(ctx interface{}) *QueryService_GetInflation_Call

GetInflation is a helper method to define mock.On call

  • ctx context.Context

func (*QueryService_Expecter) GetLatestNetworkInferences added in v0.1.10 

func (_e *QueryService_Expecter) GetLatestNetworkInferences(ctx interface{}, topicID interface{}) *QueryService_GetLatestNetworkInferences_Call

GetLatestNetworkInferences is a helper method to define mock.On call

  • ctx context.Context
  • topicID uint64

func (*QueryService_Expecter) GetNaiveInfererNetworkRegret added in v0.1.10 

func (_e *QueryService_Expecter) GetNaiveInfererNetworkRegret(ctx interface{}, topicID interface{}) *QueryService_GetNaiveInfererNetworkRegret_Call

GetNaiveInfererNetworkRegret is a helper method to define mock.On call

  • ctx context.Context
  • topicID uint64

func (*QueryService_Expecter) GetNextTopicID added in v0.1.10 

func (_e *QueryService_Expecter) GetNextTopicID(ctx interface{}) *QueryService_GetNextTopicID_Call

GetNextTopicID is a helper method to define mock.On call

  • ctx context.Context

type QueryService_GetEmissionInfo_Call added in v0.1.10 

type QueryService_GetEmissionInfo_Call struct {
	*mock.Call
}

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

func (*QueryService_GetEmissionInfo_Call) Return added in v0.1.10 

func (_c *QueryService_GetEmissionInfo_Call) Return(_a0 *domain.QueryResult, _a1 error) *QueryService_GetEmissionInfo_Call

func (*QueryService_GetEmissionInfo_Call) Run added in v0.1.10 

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

func (*QueryService_GetEmissionInfo_Call) RunAndReturn added in v0.1.10 

func (_c *QueryService_GetEmissionInfo_Call) RunAndReturn(run func(context.Context) (*domain.QueryResult, error)) *QueryService_GetEmissionInfo_Call

type QueryService_GetInflation_Call added in v0.1.10 

type QueryService_GetInflation_Call struct {
	*mock.Call
}

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

func (*QueryService_GetInflation_Call) Return added in v0.1.10 

func (_c *QueryService_GetInflation_Call) Return(_a0 *domain.QueryResult, _a1 error) *QueryService_GetInflation_Call

func (*QueryService_GetInflation_Call) Run added in v0.1.10 

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

func (*QueryService_GetInflation_Call) RunAndReturn added in v0.1.10 

func (_c *QueryService_GetInflation_Call) RunAndReturn(run func(context.Context) (*domain.QueryResult, error)) *QueryService_GetInflation_Call

type QueryService_GetLatestNetworkInferences_Call added in v0.1.10 

type QueryService_GetLatestNetworkInferences_Call struct {
	*mock.Call
}

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

func (*QueryService_GetLatestNetworkInferences_Call) Return added in v0.1.10 

func (_c *QueryService_GetLatestNetworkInferences_Call) Return(_a0 *domain.QueryResult, _a1 error) *QueryService_GetLatestNetworkInferences_Call

func (*QueryService_GetLatestNetworkInferences_Call) Run added in v0.1.10 

func (_c *QueryService_GetLatestNetworkInferences_Call) Run(run func(ctx context.Context, topicID uint64)) *QueryService_GetLatestNetworkInferences_Call

func (*QueryService_GetLatestNetworkInferences_Call) RunAndReturn added in v0.1.10 

func (_c *QueryService_GetLatestNetworkInferences_Call) RunAndReturn(run func(context.Context, uint64) (*domain.QueryResult, error)) *QueryService_GetLatestNetworkInferences_Call

type QueryService_GetNaiveInfererNetworkRegret_Call added in v0.1.10 

type QueryService_GetNaiveInfererNetworkRegret_Call struct {
	*mock.Call
}

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

func (*QueryService_GetNaiveInfererNetworkRegret_Call) Return added in v0.1.10 

func (_c *QueryService_GetNaiveInfererNetworkRegret_Call) Return(_a0 *domain.QueryResult, _a1 error) *QueryService_GetNaiveInfererNetworkRegret_Call

func (*QueryService_GetNaiveInfererNetworkRegret_Call) Run added in v0.1.10 

func (_c *QueryService_GetNaiveInfererNetworkRegret_Call) Run(run func(ctx context.Context, topicID uint64)) *QueryService_GetNaiveInfererNetworkRegret_Call

func (*QueryService_GetNaiveInfererNetworkRegret_Call) RunAndReturn added in v0.1.10 

func (_c *QueryService_GetNaiveInfererNetworkRegret_Call) RunAndReturn(run func(context.Context, uint64) (*domain.QueryResult, error)) *QueryService_GetNaiveInfererNetworkRegret_Call

type QueryService_GetNextTopicID_Call added in v0.1.10 

type QueryService_GetNextTopicID_Call struct {
	*mock.Call
}

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

func (*QueryService_GetNextTopicID_Call) Return added in v0.1.10 

func (_c *QueryService_GetNextTopicID_Call) Return(_a0 uint64, _a1 error) *QueryService_GetNextTopicID_Call

func (*QueryService_GetNextTopicID_Call) Run added in v0.1.10 

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

func (*QueryService_GetNextTopicID_Call) RunAndReturn added in v0.1.10 

func (_c *QueryService_GetNextTopicID_Call) RunAndReturn(run func(context.Context) (uint64, error)) *QueryService_GetNextTopicID_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.