mocks

Documentation

Index

• type BlockUpdateProcessUtilsMock
  • func (b *BlockUpdateProcessUtilsMock) ProcessBlockChangeSet() error
  • func (b *BlockUpdateProcessUtilsMock) SetChangeSet(changeSet []*types.StoreKVPair)
• type GRPCClientMock
  • func (g *GRPCClientMock) PushData(ctx context.Context, height uint64, pools []sqsdomain.PoolI, ...) error
• type NodeStatusCheckerMock
  • func (n *NodeStatusCheckerMock) IsNodeSyncing(ctx types.Context) (bool, error)
• type PoolsExtractorMock
  • func (p *PoolsExtractorMock) ExtractAll(ctx types.Context) (commondomain.BlockPools, map[uint64]commondomain.PoolCreation, error)
  • func (p *PoolsExtractorMock) ExtractChanged(ctx types.Context) (commondomain.BlockPools, error)
  • func (p *PoolsExtractorMock) ExtractCreated(ctx types.Context) (commondomain.BlockPools, map[uint64]commondomain.PoolCreation, error)
  • func (p *PoolsExtractorMock) ResetPoolTracker(ctx types.Context)
• type PoolsTransformerMock
  • func (p *PoolsTransformerMock) Transform(ctx types.Context, blockPools commondomain.BlockPools) ([]sqsdomain.PoolI, sqsdomain.TakerFeeMap, error)

Types

type BlockUpdateProcessUtilsMock

type BlockUpdateProcessUtilsMock struct {
	ProcessBlockReturn error
	LastSetChangeSet   []*types.StoreKVPair
}

func (*BlockUpdateProcessUtilsMock) ProcessBlockChangeSet

func (b *BlockUpdateProcessUtilsMock) ProcessBlockChangeSet() error

ProcessBlockChangeSet implements domain.BlockUpdateProcessUtilsI.

func (*BlockUpdateProcessUtilsMock) SetChangeSet

func (b *BlockUpdateProcessUtilsMock) SetChangeSet(changeSet []*types.StoreKVPair)

SetChangeSet implements domain.BlockUpdateProcessUtilsI.

type GRPCClientMock

type GRPCClientMock struct {
	Error error
}

func (*GRPCClientMock) PushData

func (g *GRPCClientMock) PushData(ctx context.Context, height uint64, pools []sqsdomain.PoolI, takerFeesMap sqsdomain.TakerFeeMap) error

PushData implements domain.SQSGRPClient.

type NodeStatusCheckerMock

type NodeStatusCheckerMock struct {
	// IsSyncing is the value to return when IsNodeSyncing is called.
	IsSyncing bool
	// IsNodeSyncingError is the error to return when IsNodeSyncing is called.
	IsNodeSyncingError error
	// IsNodeSyncingCalled is a flag indicating if IsNodeSyncing was called.
	IsNodeSyncingCalled bool
}

NodeStatusCheckerMock is a mock implementation of domain.NodeStatusChecker.

func (*NodeStatusCheckerMock) IsNodeSyncing

func (n *NodeStatusCheckerMock) IsNodeSyncing(ctx types.Context) (bool, error)

IsNodeSyncing implements domain.NodeStatusChecker.

type PoolsExtractorMock

type PoolsExtractorMock struct {
	// AllBlockDataError is the error to return when ProcessAllBlockData is called.
	AllBlockDataError error
	// ChangedBlockDataError is the error to return when ProcessChangedBlockData is called.
	ChangedBlockDataError error
	// IsProcessAllBlockDataCalled is a flag indicating if ProcessAllBlockData was called.
	IsProcessAllBlockDataCalled bool
	// IsProcessAllChangedDataCalled is a flag indicating if ProcessChangedBlockData was called.
	IsProcessAllChangedDataCalled bool
	// IsProcessAllCreatedDataCalled is a flag indicating if ProcessAllCreatedDataCalled was called.
	IsProcessAllCreatedDataCalled bool
	// IsPoolTrackerReset is a flag indicating if ResetPoolTracker was called.
	IsPoolTrackerReset bool
	// If this is non-empty, ProcessAllBlockData(...) will panic with this message.
	ProcessAllBlockDataPanicMsg string
	// Block pools to return
	BlockPools commondomain.BlockPools
	// CreatedPoolIDs is the map of pool IDs that were created in the block.
	CreatedPoolIDs map[uint64]commondomain.PoolCreation
}

func (*PoolsExtractorMock) ExtractAll

func (p *PoolsExtractorMock) ExtractAll(ctx types.Context) (commondomain.BlockPools, map[uint64]commondomain.PoolCreation, error)

ExtractAll implements commondomain.PoolExtractor.

func (*PoolsExtractorMock) ExtractChanged

func (p *PoolsExtractorMock) ExtractChanged(ctx types.Context) (commondomain.BlockPools, error)

ExtractChanged implements commondomain.PoolExtractor.

func (*PoolsExtractorMock) ExtractCreated

func (p *PoolsExtractorMock) ExtractCreated(ctx types.Context) (commondomain.BlockPools, map[uint64]commondomain.PoolCreation, error)

ExtractCreated implements commondomain.PoolExtractor.

func (*PoolsExtractorMock) ResetPoolTracker

func (p *PoolsExtractorMock) ResetPoolTracker(ctx types.Context)

ResetPoolTracker implements commondomain.PoolExtractor.

type PoolsTransformerMock

type PoolsTransformerMock struct {
	PoolReturn     []sqsdomain.PoolI
	TakerFeeReturn sqsdomain.TakerFeeMap
	ErrReturn      error
}

func (*PoolsTransformerMock) Transform

func (p *PoolsTransformerMock) Transform(ctx types.Context, blockPools commondomain.BlockPools) ([]sqsdomain.PoolI, sqsdomain.TakerFeeMap, error)

Transform implements domain.PoolsTransformer.