processor

Documentation

Index

• func NewVAAGossipConsumer(guardianSets *guardiansets.GuardianSets, ...) *vaaGossipConsumer
• type Message
• type VAANotifyFunc
• type VAAPushFunc
• type VAAQueueConsumer
  • func NewVAAQueueConsumer(messageQueue <-chan *Message, repository *storage.Repository, ...) *VAAQueueConsumer
  • func (c *VAAQueueConsumer) Start(ctx context.Context)

Functions

func NewVAAGossipConsumer

func NewVAAGossipConsumer(
	guardianSets *guardiansets.GuardianSets,
	deduplicator *deduplicator.Deduplicator,
	messageQueue chan<- *Message,
	logger *zap.Logger) *vaaGossipConsumer

NewVAAGossipConsumer creates a new processor instances.

Types

type Message

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

type VAANotifyFunc

type VAANotifyFunc func(context.Context, *vaa.VAA, []byte) error

VAANotifyFunc is a function to notify saved VAA message.

type VAAPushFunc

type VAAPushFunc func(context.Context, *vaa.VAA, []byte) error

VAAPushFunc is a function to push VAA message.

type VAAQueueConsumer

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

VAAQueueConsumer represents a VAA queue consumer.

func NewVAAQueueConsumer

func NewVAAQueueConsumer(
	messageQueue <-chan *Message,
	repository *storage.Repository,
	notifyFunc VAANotifyFunc,
	logger *zap.Logger) *VAAQueueConsumer

NewVAAQueueConsumer creates a new VAA queue consumer instances.

func (*VAAQueueConsumer) Start

func (c *VAAQueueConsumer) Start(ctx context.Context)

Start consumes messages from VAA queue and store those messages in a repository.