cvm

Documentation

Index

• type Worker
  • func NewWorker(store *store.DB, codec codec.Manager, indexClient *client.IndexClient, ...) Worker
  • func (w Worker) ProcessMessage(message *model.RawMessage) error
  • func (w *Worker) Run() error
  • func (w *Worker) Start(ctx context.Context)

Types

type Worker

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

func NewWorker

func NewWorker(
	store *store.DB,
	codec codec.Manager,
	indexClient *client.IndexClient,
	evmClient *client.EvmClient,
	chain string,
	avaxAsset string,
	ethChainID *big.Int,
) Worker

func (Worker) ProcessMessage

func (w Worker) ProcessMessage(message *model.RawMessage) error

func (*Worker) Run

func (w *Worker) Run() error

func (*Worker) Start

func (w *Worker) Start(ctx context.Context)