txhash

Documentation

Index

• Variables
• func NewCacheTxHash(cache cache.CacheInterface[string], expiration time.Duration, ...) *cacheTxHash
• func NewComposite(hashStores []TxHashStore, metrics metrics.Metrics, logger *zap.Logger) *composite
• func NewDedupTxHashStore(txHashStore TxHashStore, deduplicator *deduplicator.Deduplicator, ...) *dedupTxHashStore
• func NewMongoTxHash(database *mongo.Database, logger *zap.Logger) *mongoTxHash
• func NewRedisTxHash(client *redis.Client, prefix string, expiration time.Duration, ...) *redisTxHash
• type TxHash
  • func CreateTxHash(logger *zap.Logger, o *gossipv1.SignedObservation) (*TxHash, error)
• type TxHashStore

Variables

var ErrTxHashNotFound = errors.New("tx hash not found")

Functions

func NewCacheTxHash

func NewCacheTxHash(cache cache.CacheInterface[string],
	expiration time.Duration,
	logger *zap.Logger) *cacheTxHash

func NewComposite

func NewComposite(
	hashStores []TxHashStore,
	metrics metrics.Metrics,
	logger *zap.Logger) *composite

func NewDedupTxHashStore

func NewDedupTxHashStore(txHashStore TxHashStore, deduplicator *deduplicator.Deduplicator, logger *zap.Logger) *dedupTxHashStore

func NewMongoTxHash

func NewMongoTxHash(database *mongo.Database, logger *zap.Logger) *mongoTxHash

func NewRedisTxHash

func NewRedisTxHash(client *redis.Client,
	prefix string,
	expiration time.Duration,
	logger *zap.Logger) *redisTxHash

Types

type TxHash

type TxHash struct {
	ChainID  sdk.ChainID
	Emitter  string
	Sequence string
	TxHash   string
}

func CreateTxHash

func CreateTxHash(logger *zap.Logger, o *gossipv1.SignedObservation) (*TxHash, error)

type TxHashStore

type TxHashStore interface {
	Get(ctx context.Context, uniqueVaaID string) (*string, error)
	Set(ctx context.Context, uniqueVaaID string, txHash TxHash) error
	SetObservation(ctx context.Context, o *gossipv1.SignedObservation) error
	GetName() string
}