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 NewDeduplicator(name string, cfg config.Cache, logger *zap.Logger) (*deduplicator.Deduplicator, error)
• func NewEventDispatcher(ctx context.Context, config *config.Configuration, logger *zap.Logger) (event.EventDispatcher, health.Check)
• func NewGossipChannels(cfg *config.Configuration) *gossip.GossipChannels
• func NewGuardianSetSynchronizer(ctx context.Context, mongo *dbutil.Session, postgres *db.DB, ...) (*guardiansets.GuardianSetSynchronizer, error)
• func NewLegacyTxHashStore(ctx context.Context, cfg *config.Configuration, metrics metrics.Metrics, ...) (txhash.TxHashStore, error)
• func NewMetrics(cfg *config.Configuration) metrics.Metrics
• func NewMongoDatabase(ctx context.Context, cfg *config.Configuration, logger *zap.Logger) (*dbutil.Session, error)
• func NewObservationConsumePublish(ctx context.Context, config *config.Configuration, logger *zap.Logger) (health.Check, processor.ObservationQueueConsumeFunc, ...)
• func NewPostgresDatabase(ctx context.Context, cfg *config.Configuration, logger *zap.Logger) (*db.DB, error)
• 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, cfg *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 NewDeduplicator

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

func NewEventDispatcher

func NewEventDispatcher(ctx context.Context, config *config.Configuration, logger *zap.Logger) (event.EventDispatcher, health.Check)

func NewGossipChannels

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

func NewGuardianSetSynchronizer

func NewGuardianSetSynchronizer(ctx context.Context, mongo *dbutil.Session, postgres *db.DB, heartbeatChannel chan *gossipv1.Heartbeat, logger *zap.Logger, cfg *config.Configuration, alertClient alert.AlertClient) (*guardiansets.GuardianSetSynchronizer, error)

func NewLegacyTxHashStore

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

func NewMetrics

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

func NewMongoDatabase

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

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 NewPostgresDatabase

func NewPostgresDatabase(ctx context.Context, cfg *config.Configuration, logger *zap.Logger) (*db.DB, error)

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, cfg *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