migration

Dec 22, 2020

Changes in this version

+ const MigrationQueueBurnedName

+ const MigrationQueueMultisigName

+ const MigrationQueueName

+ var ErrRateLimited = errors.New("rate limited")

+ var MigrationAllowedCounter = prometheus.NewCounter(prometheus.CounterOpts{ ... })

+ var MigrationRateLimitedCounter = prometheus.NewCounter(prometheus.CounterOpts{ ... })

+ func MigrateTransferAccounts(ctx context.Context, hc horizon.ClientInterface, m Migrator, ...) error

type Migrator

+ GetMigrationAccount func(ctx context.Context, account ed25519.PublicKey) (ed25519.PublicKey, error)

+ type Processor struct

+ func NewProcessor(queueCtr taskqueue.ProcessorCtor, burnedQueueSubmitter taskqueue.Submitter, ...) (p *Processor, err error)

+ func (p *Processor) Queue(ctx context.Context, req *migrationpb.QueueRequest) (*migrationpb.VoidResponse, error)

+ func (p *Processor) SetRateLimit(_ context.Context, req *migrationpb.SetRateLimitRequest) (*migrationpb.VoidResponse, error)

+ func (p *Processor) SetState(_ context.Context, req *migrationpb.SetStateRequest) (*migrationpb.VoidResponse, error)

+ func (p *Processor) Shutdown()

+ func (p *Processor) Write(ctx context.Context, account ed25519.PublicKey, ignoreZeroBalance bool) error

type Store

+ GetCount func(ctx context.Context, account ed25519.PublicKey) (int, error)

+ IncrementCount func(ctx context.Context, account ed25519.PublicKey) error

Dec 15, 2020

Changes in this version

+ var OnDemandFailureCounterVec = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var OnDemandSuccessCounterVec = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

Dec 15, 2020

Changes in this version

+ var ErrBurned = errors.New("account was burned")

+ var ErrMultisig = errors.New("multisig wallet")

+ var ErrNotFound = errors.New("account not found")

+ func DeriveMigrationAccount(source ed25519.PublicKey, secret []byte) (ed25519.PublicKey, ed25519.PrivateKey, error)

+ func HasMigrationHeader(ctx context.Context) (bool, error)

+ func MarkComplete(ctx context.Context, store Store, account ed25519.PublicKey, prev State) error

+ func MigrateBatch(ctx context.Context, m Migrator, accounts ...ed25519.PublicKey) error

+ type Migrator interface

+ InitiateMigration func(context.Context, ed25519.PublicKey, solana.Commitment) error

+ func NewContextAwareMigrator(base Migrator) Migrator

+ func NewNoopMigrator() Migrator

+ func NewTeeMigrator(a, b Migrator) Migrator

Dec 8, 2020

Changes in this version

+ var ErrStatusMismatch = errors.New("previous state does not match stored")

+ type State struct

+ LastModified time.Time

+ Signature solana.Signature

+ Status Status

+ var ZeroState State

+ type Status int

+ const StatusComplete

+ const StatusInProgress

+ const StatusNone

+ type Store interface

+ Get func(ctx context.Context, account ed25519.PublicKey) (State, error)

+ Update func(ctx context.Context, account ed25519.PublicKey, prev, next State) error