mocks

Documentation

Index

• 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, error)
  • func (p *PoolsExtractorMock) ExtractChanged(ctx types.Context) (commondomain.BlockPools, error)
• type PoolsTransformerMock
  • func (p *PoolsTransformerMock) Transform(ctx types.Context, blockPools commondomain.BlockPools) ([]sqsdomain.PoolI, sqsdomain.TakerFeeMap, error)

Types

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
	// If this is non-empty, ProcessAllBlockData(...) will panic with this message.
	ProcessAllBlockDataPanicMsg string
	// Block pools to return
	BlockPools commondomain.BlockPools
}

func (*PoolsExtractorMock) ExtractAll

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

ExtractAll implements commondomain.PoolExtractor.

func (*PoolsExtractorMock) ExtractChanged

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

ExtractChanged 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.