parser

Documentation

Index

• Constants
• Variables
• type IndexingTimestamps
• type ParsedVaaUpdate
• type Repository
  • func NewRepository(db *mongo.Database, log *zap.Logger) *Repository
  • func (s *Repository) UpsertParsedVaa(ctx context.Context, parsedVAA ParsedVaaUpdate) error

Constants

const ParsedVAACollection = "parsedVaa"

Variables

var ErrDocNotFound = errors.New("NOT FOUND")

repository errors

Types

type IndexingTimestamps

type IndexingTimestamps struct {
	IndexedAt time.Time `bson:"indexedAt"`
}

type ParsedVaaUpdate

type ParsedVaaUpdate struct {
	ID                        string                                  `bson:"_id" json:"id"`
	EmitterChain              sdk.ChainID                             `bson:"emitterChain" json:"emitterChain"`
	EmitterAddr               string                                  `bson:"emitterAddr" json:"emitterAddr"`
	Sequence                  string                                  `bson:"sequence" json:"sequence"`
	AppIDs                    []string                                `bson:"appIds" json:"appIds"`
	ParsedPayload             interface{}                             `bson:"parsedPayload" json:"parsedPayload"`
	RawStandardizedProperties vaaPayloadParser.StandardizedProperties `bson:"rawStandardizedProperties" json:"rawStandardizedProperties"`
	StandardizedProperties    vaaPayloadParser.StandardizedProperties `bson:"standardizedProperties" json:"standardizedProperties"`
	UpdatedAt                 *time.Time                              `bson:"updatedAt" json:"updatedAt"`
	Timestamp                 time.Time                               `bson:"-" json:"-"`
}

ParsedVaaUpdate represent a parsed vaa update.

type Repository

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

Repository definitions.

func NewRepository

func NewRepository(db *mongo.Database, log *zap.Logger) *Repository

NewRepository create a new respository instance.

func (*Repository) UpsertParsedVaa

func (s *Repository) UpsertParsedVaa(ctx context.Context, parsedVAA ParsedVaaUpdate) error

UpsertParsedVaa saves vaa information and parsed result.