soltxm

Mar 16, 2023

Changes in this version

+ const ConfirmedRevert

+ const ConfirmedSuccess

+ const NotFound

+ const Processed

+ func SortSignaturesAndResults(sigs []solana.Signature, res []*rpc.SignatureStatusesResult) ([]solana.Signature, []*rpc.SignatureStatusesResult, error)

type PendingTxContext

+ New func(sig solana.Signature, cancel context.CancelFunc) (uuid.UUID, error)

type Txm

+ func (txm *Txm) HealthReport() map[string]error

+ func (txm *Txm) Name() string

Jun 21, 2022

Changes in this version

+ const MaxRetryTimeMs

+ const MaxSigsToConfirm

+ const TxFailDrop

+ const TxFailReject

+ const TxFailRevert

+ const TxFailSimOther

+ const TxFailSimRevert

+ type PendingTxContext interface

+ Add func(sig solana.Signature, cancel context.CancelFunc) error

+ Expired func(sig solana.Signature, lifespan time.Duration) bool

+ ListAll func() []solana.Signature

+ OnError func(sig solana.Signature, errType int)

+ OnSuccess func(sig solana.Signature)

+ Remove func(sig solana.Signature)

type Txm

+ func (txm *Txm) InflightTxs() int

May 2, 2022

Changes in this version

+ const MaxQueueLen

+ type Txm struct

+ func NewTxm(tc func() (solanaClient.ReaderWriter, error), cfg config.Config, ...) *Txm

+ func (txm *Txm) Close() error

+ func (txm *Txm) Enqueue(accountID string, msg *solanaGo.Transaction) error

+ func (txm *Txm) Healthy() error

+ func (txm *Txm) Ready() error

+ func (txm *Txm) Start(context.Context) error