worker

Documentation

Index

• Variables
• type Config
• type Worker
  • func New(cfg Config, l zerolog.Logger, b rep.Broker, rpcCli rep.RPCClient, ...) *Worker
  • func (w *Worker) Start(_ context.Context) error
  • func (w *Worker) Stop(_ context.Context) error

Variables

var (
	ErrBlockProcessed  = errors.New("block already processed")
	ErrBlockProcessing = errors.New("block is processing right now")
	ErrBlockError      = errors.New("block processed with error")
)

Types

type Config

type Config struct {
	ProcessErrorBlocksInterval time.Duration `env:"PROCESS_ERROR_BLOCKS_INTERVAL" envDefault:"1m"`
	ProcessNewBlocks           bool          `env:"SUBSCRIBE_NEW_BLOCKS"` // FIXME: or use ws enabled???
	ProcessErrorBlocks         bool          `env:"PROCESS_ERROR_BLOCKS" envDefault:"true"`
	MetricsEnabled             bool          `env:"WORKER_METRICS_ENABLED" envDefault:"false"`
	RecoveryMode               bool          `env:"RECOVERY_MODE" envDefault:"false"`
	ProcessGenesis             bool          `env:"PROCESS_GENESIS" envDefault:"true"`
	WorkersCount               int           `env:"WORKERS_COUNT" envDefault:"1"`
	StartHeight                int64         `env:"START_HEIGHT" envDefault:"-1"`
	StopHeight                 int64         `env:"STOP_HEIGHT"`
}

type Worker

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

func New

func New(cfg Config, l zerolog.Logger, b rep.Broker, rpcCli rep.RPCClient, grpcCli rep.GrpcClient,
	modules []types.Module, s rep.Storage, marshaler codec.Codec, tbM tb.ToBroker, tsM ts.ToStorage) *Worker

func (*Worker) Start

func (w *Worker) Start(_ context.Context) error

func (*Worker) Stop

func (w *Worker) Stop(_ context.Context) error