solana

Documentation

Index

• type Processor
  • func NewProcessor(logger logger.Logger, bcProvider solana.Provider, users []config.UserConfig) *Processor
  • func (p *Processor) Process(ctx context.Context, workerID int, msg kafka.Message) error

Types

type Processor

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

func NewProcessor

func NewProcessor(logger logger.Logger, bcProvider solana.Provider, users []config.UserConfig) *Processor

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, workerID int, msg kafka.Message) error