topic

Documentation

Index

• type Event
• type PushFunc
• type SNS
  • func NewVAASNS(producer *sns.Producer, alertClient alert.AlertClient, metrics metrics.Metrics, ...) *SNS
  • func (s *SNS) Publish(ctx context.Context, message *Event) error
• type VAAInMemory
  • func NewVAAInMemory(logger *zap.Logger) *VAAInMemory
  • func (i *VAAInMemory) Publish(_ context.Context, message *Event) error
• type VAAInMemoryOption

Types

type Event

type Event struct {
	ID             string     `json:"id"`
	ChainID        uint16     `json:"emitterChain"`
	EmitterAddress string     `json:"emitterAddr"`
	Sequence       string     `json:"sequence"`
	PhylaxSetIndex uint32     `json:"phylaxSetIndex"`
	Vaa            []byte     `json:"vaas"`
	IndexedAt      time.Time  `json:"indexedAt"`
	Timestamp      *time.Time `json:"timestamp"`
	UpdatedAt      *time.Time `json:"updatedAt"`
	TxHash         string     `json:"txHash"`
	Version        uint16     `json:"version"`
	Revision       uint16     `json:"revision"`
}

Event represents a vaa data to be handle by the pipeline.

type PushFunc

type PushFunc func(context.Context, *Event) error

PushFunc is a function to push VAAEvent.

type SNS

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

SQS represents a VAA queue in SNS.

func NewVAASNS

func NewVAASNS(producer *sns.Producer, alertClient alert.AlertClient, metrics metrics.Metrics, logger *zap.Logger) *SNS

NewVAASNS creates a VAA topic in SNS instances.

func (*SNS) Publish

func (s *SNS) Publish(ctx context.Context, message *Event) error

Publish sends the message to a SNS topic.

type VAAInMemory

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

VAAInMemory represents VAA queue in memory.

func NewVAAInMemory

func NewVAAInMemory(logger *zap.Logger) *VAAInMemory

NewVAAInMemory creates a VAA queue in memory instances.

func (*VAAInMemory) Publish

func (i *VAAInMemory) Publish(_ context.Context, message *Event) error

Publish sends the message to a channel.

type VAAInMemoryOption

type VAAInMemoryOption func(*VAAInMemory)

VAAInMemoryOption represents a VAA queue in memory option function.