blockchainstate

Documentation

Index

• type BlockchainStatePublishUseCase
  • func NewBlockchainStatePublishUseCase(logger *slog.Logger, cache redis.Cacher) BlockchainStatePublishUseCase
• type BlockchainStateSubscribeUseCase
  • func NewBlockchainStateSubscribeUseCase(logger *slog.Logger, cache redis.Cacher) BlockchainStateSubscribeUseCase
• type BlockchainStateUpdateDetectorUseCase
  • func NewBlockchainStateUpdateDetectorUseCase(config *config.Configuration, logger *slog.Logger, ...) BlockchainStateUpdateDetectorUseCase
• type GetBlockchainStateUseCase
  • func NewGetBlockchainStateUseCase(config *config.Configuration, logger *slog.Logger, ...) GetBlockchainStateUseCase
• type UpsertBlockchainStateUseCase
  • func NewUpsertBlockchainStateUseCase(config *config.Configuration, logger *slog.Logger, ...) UpsertBlockchainStateUseCase

Types

type BlockchainStatePublishUseCase

type BlockchainStatePublishUseCase interface {
	Execute(ctx context.Context, bcState *domain.BlockchainState) error
}

func NewBlockchainStatePublishUseCase

func NewBlockchainStatePublishUseCase(
	logger *slog.Logger,
	cache redis.Cacher,
) BlockchainStatePublishUseCase

type BlockchainStateSubscribeUseCase

type BlockchainStateSubscribeUseCase interface {
	Execute(ctx context.Context) redis.RedisSubscriber
}

func NewBlockchainStateSubscribeUseCase

func NewBlockchainStateSubscribeUseCase(
	logger *slog.Logger,
	cache redis.Cacher,
) BlockchainStateSubscribeUseCase

type BlockchainStateUpdateDetectorUseCase

type BlockchainStateUpdateDetectorUseCase interface {
	Execute(ctx context.Context) (*domain.BlockchainState, error)
	Terminate()
}

func NewBlockchainStateUpdateDetectorUseCase

func NewBlockchainStateUpdateDetectorUseCase(config *config.Configuration, logger *slog.Logger, repo domain.BlockchainStateRepository) BlockchainStateUpdateDetectorUseCase

type GetBlockchainStateUseCase

type GetBlockchainStateUseCase interface {
	Execute(ctx context.Context, chainID uint16) (*domain.BlockchainState, error)
}

func NewGetBlockchainStateUseCase

func NewGetBlockchainStateUseCase(
	config *config.Configuration,
	logger *slog.Logger,
	repo domain.BlockchainStateRepository,
) GetBlockchainStateUseCase

type UpsertBlockchainStateUseCase

type UpsertBlockchainStateUseCase interface {
	Execute(ctx context.Context, bcs *domain.BlockchainState) error
}

func NewUpsertBlockchainStateUseCase

func NewUpsertBlockchainStateUseCase(
	config *config.Configuration,
	logger *slog.Logger,
	repo domain.BlockchainStateRepository,
) UpsertBlockchainStateUseCase