eth

Documentation

Index

• type Config
• type EthEvents
  • func NewEthEvents(ctx context.Context, config *Config, db *db.BoltDB, logger *zap.Logger) (*EthEvents, error)
  • func (e *EthEvents) FetchAddedOperatorEvents() error
  • func (e *EthEvents) ListenAddedOperatorEvents() error
  • func (e *EthEvents) Start() error

Types

type Config

type Config struct {
	RPCUrl          string `yaml:"RPCUrl" env:"ETH_RPC_URL" env-description:"Ethereum RPC URL"`
	ContractAddress string `yaml:"ContractAddress" env:"ETH_CONTRACT_ADDRESS" env-description:"Ethereum contract address"`
}

type EthEvents

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

func NewEthEvents

func NewEthEvents(ctx context.Context, config *Config, db *db.BoltDB, logger *zap.Logger) (*EthEvents, error)

func (*EthEvents) FetchAddedOperatorEvents

func (e *EthEvents) FetchAddedOperatorEvents() error

func (*EthEvents) ListenAddedOperatorEvents

func (e *EthEvents) ListenAddedOperatorEvents() error

func (*EthEvents) Start

func (e *EthEvents) Start() error