builder

Documentation

Index

• func CheckGuardian(guardian *health.GuardianCheck) healthcheck.Check
• func NewAlertClient(cfg *config.Configuration) (alert.AlertClient, error)
• func NewAwsConfig(ctx context.Context, config *config.Configuration) (aws.Config, error)
• func NewCache[T any](name string, numKeys, maxCost int64) (cache.CacheInterface[T], error)
• func NewDatabase(ctx context.Context, cfg *config.Configuration, logger *zap.Logger) (*dbutil.Session, error)
• func NewDeduplicator(name string, cfg config.Cache, logger *zap.Logger) (*deduplicator.Deduplicator, error)
• func NewGossipChannels(cfg *config.Configuration) *gossip.GossipChannels
• func NewMetrics(cfg *config.Configuration) metrics.Metrics
• func NewObservationConsumePublish(ctx context.Context, config *config.Configuration, logger *zap.Logger) (health.Check, processor.ObservationQueueConsumeFunc, ...)
• func NewRedisClient(cfg *config.Configuration) *redis.Client
• func NewSQSConsumer(sqsURL string, ctx context.Context, cfg *config.Configuration) (*sqs.Consumer, error)
• func NewSQSProducer(awsConfig aws.Config, sqsURL string) (*sqs.Producer, error)
• func NewTxHashStore(ctx context.Context, config *config.Configuration, metrics metrics.Metrics, ...) (txhash.TxHashStore, error)
• func NewVAAConsumePublish(ctx context.Context, cfg *config.Configuration, logger *zap.Logger) (health.Check, processor.VAAQueueConsumeFunc, processor.VAAPushFunc)
• func NewVAANotifierFunc(cfg *config.Configuration, logger *zap.Logger) processor.VAANotifyFunc
• func NewVAARedisProducerFunc(cfg *config.Configuration, logger *zap.Logger) (producer.PushFunc, error)

Functions

func CheckGuardian

func CheckGuardian(guardian *health.GuardianCheck) healthcheck.Check

func NewAlertClient

func NewAlertClient(cfg *config.Configuration) (alert.AlertClient, error)

func NewAwsConfig

func NewAwsConfig(ctx context.Context, config *config.Configuration) (aws.Config, error)

func NewCache

func NewCache[T any](name string, numKeys, maxCost int64) (cache.CacheInterface[T], error)

func NewDatabase

func NewDatabase(ctx context.Context, cfg *config.Configuration, logger *zap.Logger) (*dbutil.Session, error)

func NewDeduplicator

func NewDeduplicator(name string, cfg config.Cache, logger *zap.Logger) (*deduplicator.Deduplicator, error)

func NewGossipChannels

func NewGossipChannels(cfg *config.Configuration) *gossip.GossipChannels

func NewMetrics

func NewMetrics(cfg *config.Configuration) metrics.Metrics

func NewObservationConsumePublish

func NewObservationConsumePublish(ctx context.Context, config *config.Configuration, logger *zap.Logger) (health.Check, processor.ObservationQueueConsumeFunc, processor.ObservationPushFunc)

Creates two callbacks depending on whether the execution is local (memory queue) or not (SQS queue) callback to obtain queue messages from a queue callback to publish vaa non pyth messages to a sink

func NewRedisClient

func NewRedisClient(cfg *config.Configuration) *redis.Client

func NewSQSConsumer

func NewSQSConsumer(sqsURL string, ctx context.Context, cfg *config.Configuration) (*sqs.Consumer, error)

func NewSQSProducer

func NewSQSProducer(awsConfig aws.Config, sqsURL string) (*sqs.Producer, error)

func NewTxHashStore

func NewTxHashStore(ctx context.Context, config *config.Configuration, metrics metrics.Metrics, db *mongo.Database, logger *zap.Logger) (txhash.TxHashStore, error)

func NewVAAConsumePublish

func NewVAAConsumePublish(ctx context.Context, cfg *config.Configuration, logger *zap.Logger) (health.Check, processor.VAAQueueConsumeFunc, processor.VAAPushFunc)

Creates two callbacks depending on whether the execution is local (memory queue) or not (SQS queue) callback to obtain queue messages from a queue callback to publish vaa non pyth messages to a sink

func NewVAANotifierFunc

func NewVAANotifierFunc(cfg *config.Configuration, logger *zap.Logger) processor.VAANotifyFunc

func NewVAARedisProducerFunc

func NewVAARedisProducerFunc(cfg *config.Configuration, logger *zap.Logger) (producer.PushFunc, error)

Creates a callback to publish VAA messages to a redis pubsub