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.QConfig) *ORM
  • func (o *ORM) GetMsgs(ids ...int64) (terra.Msgs, error)
  • func (o *ORM) GetMsgsState(state db.State, limit int64, qopts ...pg.QOpt) (terra.Msgs, error)
  • func (o *ORM) InsertMsg(contractID, typeURL string, msg []byte, qopts ...pg.QOpt) (int64, error)
  • func (o *ORM) UpdateMsgs(ids []int64, state db.State, txHash *string, qopts ...pg.QOpt) error
  • func (o *ORM) UpdateMsgsContract(contractID string, from, to db.State, 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 sdk.Msg) (int64, error)
  • func (txm *Txm) GasPrice() (sdk.DecCoin, error)
  • func (txm *Txm) GetMsgs(ids ...int64) (terra.Msgs, error)
  • func (txm *Txm) Healthy() error
  • func (txm *Txm) Ready() error
  • func (txm *Txm) Start(context.Context) 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.QConfig) *ORM

NewORM creates an ORM scoped to chainID.

func (*ORM) GetMsgs

func (o *ORM) GetMsgs(ids ...int64) (terra.Msgs, error)

GetMsgs returns any messages matching ids.

func (*ORM) GetMsgsState

func (o *ORM) GetMsgsState(state db.State, limit int64, qopts ...pg.QOpt) (terra.Msgs, error)

GetMsgsState returns the oldest messages with a given state up to limit.

func (*ORM) InsertMsg

func (o *ORM) InsertMsg(contractID, typeURL string, msg []byte, qopts ...pg.QOpt) (int64, error)

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

func (*ORM) UpdateMsgs

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

UpdateMsgs updates msgs with the given ids. Note state transitions are validated at the db level.

func (*ORM) UpdateMsgsContract

func (o *ORM) UpdateMsgsContract(contractID string, from, to db.State, qopts ...pg.QOpt) error

UpdateMsgsContract updates messages for the given contract.

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.QConfig, 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 sdk.Msg) (int64, error)

Enqueue enqueue a msg destined for the terra chain.

func (*Txm) GasPrice

func (txm *Txm) GasPrice() (sdk.DecCoin, error)

GasPrice returns the gas price from the estimator in uluna.

func (*Txm) GetMsgs

func (txm *Txm) GetMsgs(ids ...int64) (terra.Msgs, error)

GetMsgs returns any messages matching ids.

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 pg notifications about terra msg inserts and processes them.