avm

Documentation

Index

• type Worker
  • func NewWorker(indexClient *client.IndexClient, store *store.DB, codec codec.Manager, ...) 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(
	indexClient *client.IndexClient,
	store *store.DB,
	codec codec.Manager,
	chain string,
	asset string,
) 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)