processor

Documentation

Index

• type Processor
  • func New(parser vaaPayloadParser.ParserVAAAPIClient, repository *parser.Repository, ...) *Processor
  • func (p *Processor) Process(ctx context.Context, vaaBytes []byte) (*parser.ParsedVaaUpdate, error)
• type ProcessorFunc

Types

type Processor

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

func New

func New(parser vaaPayloadParser.ParserVAAAPIClient, repository *parser.Repository, alert alert.AlertClient, metrics metrics.Metrics, logger *zap.Logger) *Processor

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, vaaBytes []byte) (*parser.ParsedVaaUpdate, error)

type ProcessorFunc

type ProcessorFunc func(context.Context, []byte) (*parser.ParsedVaaUpdate, error)

ProcessorFunc is a function to process vaa message.