consumer

Documentation

Index

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

Types

type AggregatesConsumer

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

func NewAggregatesConsumer

func NewAggregatesConsumer(txs repository.Txs, srvAggregates service.Aggregates) 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 *model.Tx, txs repository.TransactionsCache,
) CacheConsumer

type SearchBlocksConsumer

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

func NewSearchBlocksConsumer

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

type SearchTxConsumer

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

func NewSearchTxConsumer

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