soltxm

Documentation

Index

• Constants
• func SortSignaturesAndResults(sigs []solana.Signature, res []*rpc.SignatureStatusesResult) ([]solana.Signature, []*rpc.SignatureStatusesResult, error)
• type PendingTxContext
• type Txm
  • func NewTxm(chainID string, tc func() (solanaClient.ReaderWriter, error), ...) *Txm
  • func (txm *Txm) Close() error
  • func (txm *Txm) Enqueue(accountID string, tx *solanaGo.Transaction) error
  • func (txm *Txm) Healthy() error
  • func (txm *Txm) InflightTxs() int
  • func (txm *Txm) Ready() error
  • func (txm *Txm) Start(ctx context.Context) error

Constants

const (
	TxFailRevert = iota
	TxFailReject
	TxFailDrop
	TxFailSimRevert
	TxFailSimOther
)

const (
	MaxQueueLen      = 1000
	MaxRetryTimeMs   = 250 // max tx retry time (exponential retry will taper to retry every 0.25s)
	MaxSigsToConfirm = 256 // max number of signatures in GetSignatureStatus call
)

const (
	NotFound = iota
	Processed
	ConfirmedRevert
	ConfirmedSuccess
)

tx not found < tx processed < tx confirmed/finalized + revert < tx confirmed/finalized + success

Functions

func SortSignaturesAndResults

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

Types

type PendingTxContext

type PendingTxContext interface {
	New(sig solana.Signature, cancel context.CancelFunc) (uuid.UUID, error)
	Add(id uuid.UUID, sig solana.Signature) error
	Remove(sig solana.Signature) uuid.UUID
	ListAll() []solana.Signature
	Expired(sig solana.Signature, lifespan time.Duration) bool
	// state change hooks
	OnSuccess(sig solana.Signature) uuid.UUID
	OnError(sig solana.Signature, errType int) uuid.UUID // match err type using enum
}

type Txm

type Txm struct {
	// contains filtered or unexported fields
}

Txm manages transactions for the solana blockchain. simple implementation with no persistently stored txs

func NewTxm

func NewTxm(chainID string, tc func() (solanaClient.ReaderWriter, error), cfg config.Config, ks keystore.Solana, lggr logger.Logger) *Txm

NewTxm creates a txm. Uses simulation so should only be used to send txes to trusted contracts i.e. OCR.

func (*Txm) Close

func (txm *Txm) Close() error

Close close service

func (*Txm) Enqueue

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

Enqueue enqueue a msg destined for the solana chain.

func (*Txm) Healthy

func (txm *Txm) Healthy() error

Healthy service is healthy

func (*Txm) InflightTxs

func (txm *Txm) InflightTxs() int

func (*Txm) Ready

func (txm *Txm) Ready() error

Ready service is ready

func (*Txm) Start

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

Start subscribes to queuing channel and processes them.