Documentation ¶
Index ¶
- Constants
- type IndexingTimestamps
- type Pagination
- type VaaDoc
- type VaaQuery
- type 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 ¶
View Source
const ( VaaIdTxHash = "vaaIdTxHash" TransferPrices = "transferPrices" Vaas = "vaas" DuplicateVaas = "duplicateVaas" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IndexingTimestamps ¶
func IndexedAt ¶
func IndexedAt(t time.Time) IndexingTimestamps
type Pagination ¶
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) FindPage ¶
func (r *VaaRepository) FindPage(ctx context.Context, query VaaQuery, pagination Pagination) ([]*VaaDoc, error)
FindPage finds VAA by query and pagination.
Click to show internal directories.
Click to hide internal directories.