batch

Documentation

Index

• type Parameter
  • func WithAddresses(addresses []types.Address) Parameter
  • func WithBalancesProvider(provider execclient.BalancesProvider) Parameter
  • func WithBalancesSetter(setter execdb.BalancesSetter) Parameter
  • func WithBlocksProvider(provider execclient.BlocksProvider) Parameter
  • func WithChainHeightProvider(provider execclient.ChainHeightProvider) Parameter
  • func WithDBBalancesProvider(provider execdb.BalancesProvider) Parameter
  • func WithInterval(interval time.Duration) Parameter
  • func WithLogLevel(logLevel zerolog.Level) Parameter
  • func WithMonitor(monitor metrics.Service) Parameter
  • func WithProcessConcurrency(concurrency int64) Parameter
  • func WithScheduler(scheduler scheduler.Service) Parameter
  • func WithStartHeight(startHeight int64) Parameter
  • func WithTrackDistance(trackDistance uint32) Parameter
• type Service
  • func New(ctx context.Context, params ...Parameter) (*Service, error)
  • func (s *Service) SetAddresses(addresses []types.Address)

Types

type Parameter

type Parameter interface {
	// contains filtered or unexported methods
}

Parameter is the interface for service parameters.

func WithAddresses

func WithAddresses(addresses []types.Address) Parameter

WithAddresses sets the addresses for this module.

func WithBalancesProvider

func WithBalancesProvider(provider execclient.BalancesProvider) Parameter

WithBalancesProvider sets the balances provider for this module.

func WithBalancesSetter

func WithBalancesSetter(setter execdb.BalancesSetter) Parameter

WithBalancesSetter sets the balances setter for this module.

func WithBlocksProvider

func WithBlocksProvider(provider execclient.BlocksProvider) Parameter

WithBlocksProvider sets the blocks provider for this module.

func WithChainHeightProvider

func WithChainHeightProvider(provider execclient.ChainHeightProvider) Parameter

WithChainHeightProvider sets the chain height provider for this module.

func WithDBBalancesProvider

func WithDBBalancesProvider(provider execdb.BalancesProvider) Parameter

WithDBBalancesProvider sets the database balances provider for this module.

func WithInterval

func WithInterval(interval time.Duration) Parameter

WithInterval sets the interval between updates.

func WithLogLevel

func WithLogLevel(logLevel zerolog.Level) Parameter

WithLogLevel sets the log level for the module.

func WithMonitor

func WithMonitor(monitor metrics.Service) Parameter

WithMonitor sets the monitor for the module.

func WithProcessConcurrency

func WithProcessConcurrency(concurrency int64) Parameter

WithProcessConcurrency sets the concurrency for the service.

func WithScheduler

func WithScheduler(scheduler scheduler.Service) Parameter

WithScheduler sets the scheduler for the module.

func WithStartHeight

func WithStartHeight(startHeight int64) Parameter

WithStartHeight sets the start height for this module.

func WithTrackDistance

func WithTrackDistance(trackDistance uint32) Parameter

WithTrackDistance sets the track distance for this module.

type Service

type Service struct {
	// contains filtered or unexported fields
}

Service is a chain database service.

func New

func New(ctx context.Context, params ...Parameter) (*Service, error)

New creates a new service.

func (*Service) SetAddresses

func (s *Service) SetAddresses(addresses []types.Address)

SetAddresses sets the addresses to monitor.