migration

Documentation

Index

• type GlobalTransaction
• type MigrateSourceChainTx
  • func NewMigrationSourceChainTx(db *mongo.Database, pageSize int, chainID sdk.ChainID, FromDate time.Time, ...) *MigrateSourceChainTx
  • func (m *MigrateSourceChainTx) Run(ctx context.Context) error
• type OriginTx
• type VAASourceChain

Types

type GlobalTransaction

type GlobalTransaction struct {
	ID       string    `bson:"_id" json:"id"`
	OriginTx *OriginTx `bson:"originTx" json:"originTx"`
}

GlobalTransaction represents a global transaction.

type MigrateSourceChainTx

type MigrateSourceChainTx struct {
	FromDate time.Time
	ToDate   time.Time
	// contains filtered or unexported fields
}

MigrateSourceChainTx is the job to migrate vaa txHash and timestamp from vaa collection to globalTx collection.

func NewMigrationSourceChainTx

func NewMigrationSourceChainTx(
	db *mongo.Database,
	pageSize int,
	chainID sdk.ChainID,
	FromDate time.Time,
	ToDate time.Time,
	txTrackerAPIClient txtrackerProcessVaa.TxTrackerAPIClient,
	sleepTime time.Duration,
	logger *zap.Logger) *MigrateSourceChainTx

NewMigrationSourceChainTx creates a new migration job.

func (*MigrateSourceChainTx) Run

func (m *MigrateSourceChainTx) Run(ctx context.Context) error

type OriginTx

type OriginTx struct {
	TxHash string `bson:"nativeTxHash" json:"txHash"`
	From   string `bson:"from" json:"from"`
	Status string `bson:"status" json:"status"`
}

OriginTx represents a origin transaction.

type VAASourceChain

type VAASourceChain struct {
	ID           string      `bson:"_id"`
	EmitterChain sdk.ChainID `bson:"emitterChain" json:"emitterChain"`
	Timestamp    *time.Time  `bson:"timestamp" json:"timestamp"`
	TxHash       *string     `bson:"txHash" json:"txHash,omitempty"`
}

VAASourceChain defines the structure of vaa fields needed for migration.