consumer

Documentation

Index

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

Functions

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 AggregatesConsumer

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

func NewAggregatesConsumer

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

type CacheConsumer

type CacheConsumer interface {
	RunBlocks(ctx context.Context) error
	RunTransactions(ctx context.Context) error
}

func NewCacheConsumer

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

type SearchBlocksConsumer

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

type SearchTxConsumer

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