mocks

package

Go to main page

Versions in this module

v0

v0.1.21

Jan 8, 2025

v0.1.20

Dec 30, 2024

v0.1.19

Dec 23, 2024

v0.1.18

Dec 23, 2024

v0.1.17

Dec 20, 2024

v0.1.16

Dec 18, 2024

Changes in this version

type ProcessedBlockRepositoryInterface

+ func (_m *ProcessedBlockRepositoryInterface) MarkBlockAsFailed(ctx context.Context, height int64) error

+ func (_m *ProcessedBlockRepositoryInterface) MarkBlockEventAsFailed(ctx context.Context, height int64) error

type ProcessedBlockRepositoryInterface_Expecter

+ func (_e *ProcessedBlockRepositoryInterface_Expecter) MarkBlockAsFailed(ctx interface{}, height interface{}) *ProcessedBlockRepositoryInterface_MarkBlockAsFailed_Call

+ func (_e *ProcessedBlockRepositoryInterface_Expecter) MarkBlockEventAsFailed(ctx interface{}, height interface{}) *ProcessedBlockRepositoryInterface_MarkBlockEventAsFailed_Call

+ type ProcessedBlockRepositoryInterface_MarkBlockAsFailed_Call struct

+ func (_c *ProcessedBlockRepositoryInterface_MarkBlockAsFailed_Call) Return(_a0 error) *ProcessedBlockRepositoryInterface_MarkBlockAsFailed_Call

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

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

+ type ProcessedBlockRepositoryInterface_MarkBlockEventAsFailed_Call struct

+ func (_c *ProcessedBlockRepositoryInterface_MarkBlockEventAsFailed_Call) Return(_a0 error) *ProcessedBlockRepositoryInterface_MarkBlockEventAsFailed_Call

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

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

v0.1.15

Dec 12, 2024

v0.1.14

Dec 10, 2024

v0.1.13

Dec 9, 2024

v0.1.12

Dec 5, 2024

v0.1.11

Dec 3, 2024

v0.1.10

Nov 27, 2024

Changes in this version

type AlloraClientInterface

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

type AlloraClientInterface_Expecter

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

+ type AlloraClientInterface_Query_Call struct

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

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

+ func (_c *AlloraClientInterface_Query_Call) RunAndReturn(...) *AlloraClientInterface_Query_Call

+ type QueryProcessor struct

+ func NewQueryProcessor(t interface{ ... }) *QueryProcessor

+ func (_m *QueryProcessor) EXPECT() *QueryProcessor_Expecter

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

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

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

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

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

+ type QueryProcessor_Expecter struct

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

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

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

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

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

+ type QueryProcessor_GetMaxTopicID_Call struct

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

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

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

+ type QueryProcessor_ProcessEmissionInfo_Call struct

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

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

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

+ type QueryProcessor_ProcessInflation_Call struct

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

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

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

+ type QueryProcessor_ProcessNaiveInfererNetworkRegret_Call struct

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

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

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

+ type QueryProcessor_ProcessNetworkInferences_Call struct

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

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

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

+ type QueryProducer struct

+ func NewQueryProducer(t interface{ ... }) *QueryProducer

+ func (_m *QueryProducer) EXPECT() *QueryProducer_Expecter

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

+ type QueryProducer_Execute_Call struct

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

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

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

+ type QueryProducer_Expecter struct

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

+ type QueryResultRepositoryInterface struct

+ func NewQueryResultRepositoryInterface(t interface{ ... }) *QueryResultRepositoryInterface

+ func (_m *QueryResultRepositoryInterface) EXPECT() *QueryResultRepositoryInterface_Expecter

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

+ type QueryResultRepositoryInterface_Expecter struct

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

+ type QueryResultRepositoryInterface_SaveQueryResult_Call struct

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

+ func (_c *QueryResultRepositoryInterface_SaveQueryResult_Call) Run(...) *QueryResultRepositoryInterface_SaveQueryResult_Call

+ func (_c *QueryResultRepositoryInterface_SaveQueryResult_Call) RunAndReturn(...) *QueryResultRepositoryInterface_SaveQueryResult_Call

+ type QueryService struct

+ func NewQueryService(t interface{ ... }) *QueryService

+ func (_m *QueryService) EXPECT() *QueryService_Expecter

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

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

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

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

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

+ type QueryService_Expecter struct

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

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

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

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

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

+ type QueryService_GetEmissionInfo_Call struct

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

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

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

+ type QueryService_GetInflation_Call struct

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

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

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

+ type QueryService_GetLatestNetworkInferences_Call struct

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

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

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

+ type QueryService_GetNaiveInfererNetworkRegret_Call struct

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

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

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

+ type QueryService_GetNextTopicID_Call struct

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

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

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

v0.1.9

Nov 21, 2024

v0.1.8

Oct 31, 2024

v0.1.7

Oct 31, 2024

v0.1.6

Oct 24, 2024

v0.1.5

Oct 23, 2024

v0.1.4

Oct 9, 2024

Changes in this version

type CodecInterface

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

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

type CodecInterface_Expecter

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

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

+ type CodecInterface_IsTypedEvent_Call struct

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

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

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

+ type CodecInterface_ParseUntypedEvent_Call struct

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

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

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

v0.1.3

Oct 7, 2024

v0.1.2

Oct 7, 2024

v0.1.1

Oct 7, 2024

v0.1.0

Oct 7, 2024

Changes in this version

+ type AlloraClientInterface struct

+ func NewAlloraClientInterface(t interface{ ... }) *AlloraClientInterface

+ func (_m *AlloraClientInterface) EXPECT() *AlloraClientInterface_Expecter

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

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

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

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

+ type AlloraClientInterface_Expecter struct

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

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

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

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

+ type AlloraClientInterface_GetBlockByHeight_Call struct

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

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

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

+ type AlloraClientInterface_GetBlockResults_Call struct

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

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

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

+ type AlloraClientInterface_GetHeader_Call struct

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

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

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

+ type AlloraClientInterface_GetLatestBlockHeight_Call struct

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

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

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

+ type CodecInterface struct

+ func NewCodecInterface(t interface{ ... }) *CodecInterface

+ func (_m *CodecInterface) EXPECT() *CodecInterface_Expecter

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

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

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

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

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

+ type CodecInterface_Expecter struct

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

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

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

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

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

+ type CodecInterface_MarshalProtoJSON_Call struct

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

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

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

+ type CodecInterface_ParseEvent_Call struct

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

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

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

+ type CodecInterface_ParseTxMessage_Call struct

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

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

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

+ type CodecInterface_ParseTxMessages_Call struct

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

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

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

+ type CodecInterface_ParseTx_Call struct

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

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

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

+ type EventsProducer struct

+ func NewEventsProducer(t interface{ ... }) *EventsProducer

+ func (_m *EventsProducer) EXPECT() *EventsProducer_Expecter

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

+ type EventsProducer_Execute_Call struct

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

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

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

+ type EventsProducer_Expecter struct

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

+ type FilterInterface struct

+ func NewFilterInterface[T interface{}](t interface{ ... }) *FilterInterface[T]

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

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

+ type FilterInterface_Expecter struct

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

+ type FilterInterface_ShouldProcess_Call struct

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

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

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

+ type ProcessedBlockRepositoryInterface struct

+ func NewProcessedBlockRepositoryInterface(t interface{ ... }) *ProcessedBlockRepositoryInterface

+ func (_m *ProcessedBlockRepositoryInterface) EXPECT() *ProcessedBlockRepositoryInterface_Expecter

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

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

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

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

+ type ProcessedBlockRepositoryInterface_Expecter struct

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

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

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

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

+ type ProcessedBlockRepositoryInterface_GetLastProcessedBlockEvent_Call struct

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

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

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

+ type ProcessedBlockRepositoryInterface_GetLastProcessedBlock_Call struct

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

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

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

+ type ProcessedBlockRepositoryInterface_SaveProcessedBlockEvent_Call struct

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

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

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

+ type ProcessedBlockRepositoryInterface_SaveProcessedBlock_Call struct

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

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

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

+ type ProcessorService struct

+ func NewProcessorService(t interface{ ... }) *ProcessorService

+ func (_m *ProcessorService) EXPECT() *ProcessorService_Expecter

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

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

+ type ProcessorService_Expecter struct

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

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

+ type ProcessorService_ProcessBlockResults_Call struct

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

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

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

+ type ProcessorService_ProcessBlock_Call struct

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

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

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

+ type StreamingClient struct

+ func NewStreamingClient(t interface{ ... }) *StreamingClient

+ func (_m *StreamingClient) Close() error

+ func (_m *StreamingClient) EXPECT() *StreamingClient_Expecter

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

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

+ type StreamingClient_Close_Call struct

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

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

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

+ type StreamingClient_Expecter struct

+ func (_e *StreamingClient_Expecter) Close() *StreamingClient_Close_Call

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

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

+ type StreamingClient_Flush_Call struct

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

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

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

+ type StreamingClient_PublishAsync_Call struct

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

+ func (_c *StreamingClient_PublishAsync_Call) Run(...) *StreamingClient_PublishAsync_Call

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

+ type TopicRouter struct

+ func NewTopicRouter(t interface{ ... }) *TopicRouter

+ func (_m *TopicRouter) EXPECT() *TopicRouter_Expecter

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

+ type TopicRouter_Expecter struct

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

+ type TopicRouter_GetTopic_Call struct

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

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

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

+ type TransactionsProducer struct

+ func NewTransactionsProducer(t interface{ ... }) *TransactionsProducer

+ func (_m *TransactionsProducer) EXPECT() *TransactionsProducer_Expecter

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

+ type TransactionsProducer_Execute_Call struct

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

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

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

+ type TransactionsProducer_Expecter struct

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL