consumer

Documentation

Index

• func NewAggregatesConsumer(totals repository.TotalsCache, blocks repository.Blocks, txs repository.Txs) *aggregatesConsumer
• func NewCacheConsumer(blocks repository.BlocksCache, blocksCh chan *model.BlockInfo, ...) *cacheConsumer
• func NewSearchBlocksConsumer(rdb *redis.Client, blocksTopic string, repo repository.Search) *searchBlocks
• func NewSearchTxConsumer(rdb *redis.Client, blocksTopic string, repo repository.Search) *searchTxPublisher
• type SearchBlocksConsumer
• type SearchTxConsumer

Functions

func NewAggregatesConsumer

func NewAggregatesConsumer(totals repository.TotalsCache, blocks repository.Blocks, txs repository.Txs) *aggregatesConsumer

func NewCacheConsumer

func NewCacheConsumer(blocks repository.BlocksCache, blocksCh chan *model.BlockInfo,
	txCh chan *models.Tx, txs repository.TransactionsCache) *cacheConsumer

func NewSearchBlocksConsumer

func NewSearchBlocksConsumer(rdb *redis.Client,
	blocksTopic string, repo repository.Search) *searchBlocks

func NewSearchTxConsumer

func NewSearchTxConsumer(rdb *redis.Client,
	blocksTopic string, repo repository.Search) *searchTxPublisher

Types

type SearchBlocksConsumer

type SearchBlocksConsumer interface {
	Consume(ctx context.Context) error
}

type SearchTxConsumer

type SearchTxConsumer interface {
	Consume(ctx context.Context) error
}