42 lines
1.1 KiB
Go
42 lines
1.1 KiB
Go
|
package storage
|
||
|
|
|
||
|
|
import (
|
||
|
|
"github.com/certusone/wormhole/node/pkg/vaa"
|
||
|
|
"time"
|
||
|
|
)
|
||
|
|
|
||
|
|
type IndexingTimestamps struct {
|
||
|
|
IndexedAt time.Time `bson:"indexedAt"`
|
||
|
|
}
|
||
|
|
|
||
|
|
type VaaUpdate struct {
|
||
|
|
ID string `bson:"_id"`
|
||
|
|
Version uint8 `bson:"version"`
|
||
|
|
EmitterChain vaa.ChainID `bson:"emitterChain"`
|
||
|
|
EmitterAddr string `bson:"emitterAddr"`
|
||
|
|
Sequence uint64 `bson:"sequence"`
|
||
|
|
GuardianSetIndex uint32 `bson:"guardianSetIndex"`
|
||
|
|
Vaa []byte `bson:"vaas"`
|
||
|
|
Timestamp *time.Time `bson:"timestamp"`
|
||
|
|
|
||
|
|
UpdatedAt *time.Time `bson:"updatedAt"`
|
||
|
|
}
|
||
|
|
|
||
|
|
type ObservationUpdate struct {
|
||
|
|
ChainID vaa.ChainID `bson:"chainId"`
|
||
|
|
Emitter string `bson:"emitter"`
|
||
|
|
Sequence uint64 `bson:"sequence"`
|
||
|
|
MessageID string `bson:"messageId"`
|
||
|
|
Hash []byte `bson:"hash"`
|
||
|
|
TxHash []byte `bson:"txHash"`
|
||
|
|
GuardianAddr string `bson:"guardianAddr"`
|
||
|
|
Signature []byte `bson:"signature"`
|
||
|
|
UpdatedAt *time.Time `bson:"updatedAt"`
|
||
|
|
}
|
||
|
|
|
||
|
|
func indexedAt(t time.Time) IndexingTimestamps {
|
||
|
|
return IndexingTimestamps{
|
||
|
|
IndexedAt: t,
|
||
|
|
}
|
||
|
|
}
|