repository

package
v0.0.0-...-3f71ca0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 2, 2024 License: Apache-2.0 Imports: 7 Imported by: 11

Documentation

Index

Constants

View Source
const (
	VaaIdTxHash    = "vaaIdTxHash"
	TransferPrices = "transferPrices"
	Vaas           = "vaas"
	DuplicateVaas  = "duplicateVaas"
)

Variables

This section is empty.

Functions

This section is empty.

Types

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL