soltxm

Documentation

Index

• Constants
• type Txm
  • 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

Constants

const MaxQueueLen = 1000

Types

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(tc func() (solanaClient.ReaderWriter, error), cfg config.Config, 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, msg *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) Ready

func (txm *Txm) Ready() error

Ready service is ready

func (*Txm) Start

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

Start subscribes to queuing channel and processes them.