terratxm

Documentation

Index

• type KeyWrapper
  • func NewKeyWrapper(key terrakey.Key) KeyWrapper
  • func (k KeyWrapper) Bytes() []byte
  • func (k KeyWrapper) Equals(a cryptotypes.LedgerPrivKey) bool
  • func (k KeyWrapper) ProtoMessage()
  • func (k KeyWrapper) PubKey() cryptotypes.PubKey
  • func (k KeyWrapper) Reset()
  • func (k KeyWrapper) Sign(msg []byte) ([]byte, error)
  • func (k KeyWrapper) String() string
  • func (k KeyWrapper) Type() string
• type ORM
  • func NewORM(chainID string, db *sqlx.DB, lggr logger.Logger, cfg pg.LogConfig) *ORM
  • func (o *ORM) InsertMsg(contractID string, msg []byte) (int64, error)
  • func (o *ORM) SelectMsgsWithIDs(ids []int64) (terra.Msgs, error)
  • func (o *ORM) SelectMsgsWithState(state db.State, limit int64) (terra.Msgs, error)
  • func (o *ORM) UpdateMsgsWithState(ids []int64, state db.State, txHash *string, qopts ...pg.QOpt) error
• type Txm
  • func NewTxm(db *sqlx.DB, tc func() (terraclient.ReaderWriter, error), ...) *Txm
  • func (txm *Txm) Close() error
  • func (txm *Txm) Enqueue(contractID string, msg []byte) (int64, error)
  • func (txm *Txm) Healthy() error
  • func (txm *Txm) Ready() error
  • func (txm *Txm) Start() error

Types

type KeyWrapper

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

KeyWrapper wrapper around a terra transmitter key for use in the terra txbuilder and client.

func NewKeyWrapper

func NewKeyWrapper(key terrakey.Key) KeyWrapper

NewKeyWrapper create a key wrapper

func (KeyWrapper) Bytes

func (k KeyWrapper) Bytes() []byte

Bytes does not expose private key

func (KeyWrapper) Equals

func (k KeyWrapper) Equals(a cryptotypes.LedgerPrivKey) bool

Equals compare against another key

func (KeyWrapper) ProtoMessage

func (k KeyWrapper) ProtoMessage()

ProtoMessage nop

func (KeyWrapper) PubKey

func (k KeyWrapper) PubKey() cryptotypes.PubKey

PubKey get the pubkey

func (KeyWrapper) Reset

func (k KeyWrapper) Reset()

Reset nop

func (KeyWrapper) Sign

func (k KeyWrapper) Sign(msg []byte) ([]byte, error)

Sign sign a message with key

func (KeyWrapper) String

func (k KeyWrapper) String() string

String nop

func (KeyWrapper) Type

func (k KeyWrapper) Type() string

Type nop

type ORM

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

ORM manages the data model for terra tx management.

func NewORM

func NewORM(chainID string, db *sqlx.DB, lggr logger.Logger, cfg pg.LogConfig) *ORM

NewORM creates an ORM scoped to chainID.

func (*ORM) InsertMsg

func (o *ORM) InsertMsg(contractID string, msg []byte) (int64, error)

InsertMsg inserts a terra msg, assumed to be a serialized terra ExecuteContractMsg.

func (*ORM) SelectMsgsWithIDs

func (o *ORM) SelectMsgsWithIDs(ids []int64) (terra.Msgs, error)

SelectMsgsWithIDs selects messages the given ids

func (*ORM) SelectMsgsWithState

func (o *ORM) SelectMsgsWithState(state db.State, limit int64) (terra.Msgs, error)

SelectMsgsWithState selects the oldest messages with a given state up to limit.

func (*ORM) UpdateMsgsWithState

func (o *ORM) UpdateMsgsWithState(ids []int64, state db.State, txHash *string, qopts ...pg.QOpt) error

UpdateMsgsWithState update the msgs with the given ids to the given state Note state transitions are validated at the db level.

type Txm

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

Txm manages transactions for the terra blockchain.

func NewTxm

func NewTxm(db *sqlx.DB, tc func() (terraclient.ReaderWriter, error), gpe terraclient.ComposedGasPriceEstimator, chainID string, cfg terra.Config, ks keystore.Terra, lggr logger.Logger, logCfg pg.LogConfig, eb pg.EventBroadcaster) *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(contractID string, msg []byte) (int64, error)

Enqueue enqueue a msg destined for the terra 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() error

Start subscribes to pg notifications about terra msg inserts and processes them.