repository

Documentation

Index

• Constants
• type GuardianSetDoc
• type GuardianSetKeyDoc
• type GuardianSetRepository
  • func NewGuardianSetRepository(db *mongo.Database, logger *zap.Logger) *GuardianSetRepository
  • func (r *GuardianSetRepository) FindAll(ctx context.Context) ([]*GuardianSetDoc, error)
  • func (r *GuardianSetRepository) FindByIndex(ctx context.Context, index uint32) (*GuardianSetDoc, error)
  • func (r *GuardianSetRepository) Upsert(ctx context.Context, doc *GuardianSetDoc) error
• type IndexingTimestamps
  • func IndexedAt(t time.Time) IndexingTimestamps
• type Pagination
• type VaaDoc
• type VaaQuery
• type VaaRepository
  • func NewVaaRepository(db *mongo.Database, logger *zap.Logger) *VaaRepository
  • func (r *VaaRepository) FindById(ctx context.Context, id string) (*VaaDoc, error)
  • func (r *VaaRepository) FindPage(ctx context.Context, query VaaQuery, pagination Pagination) ([]*VaaDoc, error)
  • func (r *VaaRepository) FindPageByTimeRange(ctx context.Context, startTime time.Time, endTime time.Time, ...) ([]*VaaDoc, error)

Constants

const (
	VaaIdTxHash      = "vaaIdTxHash"
	TransferPrices   = "transferPrices"
	Vaas             = "vaas"
	DuplicateVaas    = "duplicateVaas"
	GuardianSets     = "guardianSets"
	NodeGovernorVaas = "nodeGovernorVaas"
	GovernorVaas     = "governorVaas"
	Observations     = "observations"
)

Types

type GuardianSetDoc

type GuardianSetDoc struct {
	GuardianSetIndex uint32              `bson:"_id" json:"guardianSetIndex"`
	Keys             []GuardianSetKeyDoc `bson:"keys" json:"keys"`
	ExpirationTime   *time.Time          `bson:"expirationTime" json:"expirationTime"`
	UpdatedAt        time.Time           `bson:"updatedAt"`
}

GuardianSetDoc is a document for GuardianSet.

type GuardianSetKeyDoc

type GuardianSetKeyDoc struct {
	Index   uint32 `bson:"index" json:"index"`
	Address []byte `bson:"address" json:"address"`
}

GuardianSetKeyDoc is a key document for GuardianSet.

type GuardianSetRepository

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

func NewGuardianSetRepository

func NewGuardianSetRepository(db *mongo.Database, logger *zap.Logger) *GuardianSetRepository

NewGuardianSetRepository create a new guardian set repository.

func (*GuardianSetRepository) FindAll

func (r *GuardianSetRepository) FindAll(ctx context.Context) ([]*GuardianSetDoc, error)

FindAll finds all guardian sets.

func (*GuardianSetRepository) FindByIndex

func (r *GuardianSetRepository) FindByIndex(ctx context.Context, index uint32) (*GuardianSetDoc, error)

FindByIndex finds guardian set by index.

func (*GuardianSetRepository) Upsert

func (r *GuardianSetRepository) Upsert(ctx context.Context, doc *GuardianSetDoc) error

Upsert upserts a guardian set document.

type IndexingTimestamps

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

func IndexedAt

func IndexedAt(t time.Time) IndexingTimestamps

type Pagination

type Pagination struct {
	Page     int64
	PageSize int64
	SortAsc  bool
}

Pagination is a pagination for VAA.

type VaaDoc

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

VaaDoc is a document for VAA.

type VaaQuery

type VaaQuery struct {
	StartTime      *time.Time
	EndTime        *time.Time
	EmitterChainID *sdk.ChainID
	EmitterAddress *string
	Sequence       *string
}

VaaQuery is a query for VAA.

type VaaRepository

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

VaaRepository is a repository for VAA.

func NewVaaRepository

func NewVaaRepository(db *mongo.Database, logger *zap.Logger) *VaaRepository

NewVaaRepository create a new Vaa repository.

func (*VaaRepository) FindById

func (r *VaaRepository) FindById(ctx context.Context, id string) (*VaaDoc, error)

FindById finds VAA by id.

func (*VaaRepository) FindPage

func (r *VaaRepository) FindPage(ctx context.Context, query VaaQuery, pagination Pagination) ([]*VaaDoc, error)

FindPage finds VAA by query and pagination.

func (*VaaRepository) FindPageByTimeRange

func (r *VaaRepository) FindPageByTimeRange(ctx context.Context, startTime time.Time, endTime time.Time, page, pageSize int64, sortAsc bool) ([]*VaaDoc, error)

FindPageByTimeRange finds VAA by time range.