cosmostxm

Documentation

Index

• type KeyWrapper
  • func NewKeyWrapper(adapter *KeystoreAdapter, account string) *KeyWrapper
  • func (a *KeyWrapper) Bytes() []byte
  • func (a *KeyWrapper) Equals(other cryptotypes.LedgerPrivKey) bool
  • func (a *KeyWrapper) ProtoMessage()
  • func (a *KeyWrapper) PubKey() cryptotypes.PubKey
  • func (a *KeyWrapper) Reset()
  • func (a *KeyWrapper) Sign(msg []byte) ([]byte, error)
  • func (a *KeyWrapper) String() string
  • func (a *KeyWrapper) Type() string
• type KeystoreAdapter
  • func NewKeystoreAdapter(keystore loop.Keystore, accountPrefix string) *KeystoreAdapter
  • func (ka *KeystoreAdapter) PubKey(address string) (cryptotypes.PubKey, error)
  • func (ka *KeystoreAdapter) Sign(ctx context.Context, id string, hash []byte) ([]byte, error)
• type ORM
  • func NewORM(chainID string, db *sqlx.DB, lggr logger.Logger, cfg pg.QConfig) *ORM
  • func (o *ORM) GetMsgs(ids ...int64) (adapters.Msgs, error)
  • func (o *ORM) GetMsgsState(state db.State, limit int64, qopts ...pg.QOpt) (adapters.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() (cosmosclient.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) (adapters.Msgs, error)
  • func (txm *Txm) HealthReport() map[string]error
  • func (txm *Txm) Healthy() error
  • func (txm *Txm) Name() string
  • func (txm *Txm) Ready() error
  • func (txm *Txm) Start(context.Context) error

Types

type KeyWrapper

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

KeyWrapper uses a KeystoreAdapter to implement the cosmos-sdk PrivKey interface for a specific key.

func NewKeyWrapper

func NewKeyWrapper(adapter *KeystoreAdapter, account string) *KeyWrapper

func (*KeyWrapper) Bytes

func (a *KeyWrapper) Bytes() []byte

func (*KeyWrapper) Equals

func (a *KeyWrapper) Equals(other cryptotypes.LedgerPrivKey) bool

func (*KeyWrapper) ProtoMessage

func (a *KeyWrapper) ProtoMessage()

func (*KeyWrapper) PubKey

func (a *KeyWrapper) PubKey() cryptotypes.PubKey

func (*KeyWrapper) Reset

func (a *KeyWrapper) Reset()

func (*KeyWrapper) Sign

func (a *KeyWrapper) Sign(msg []byte) ([]byte, error)

func (*KeyWrapper) String

func (a *KeyWrapper) String() string

func (*KeyWrapper) Type

func (a *KeyWrapper) Type() string

type KeystoreAdapter

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

An adapter for a Cosmos loop.Keystore to translate public keys into bech32-prefixed account addresses.

func NewKeystoreAdapter

func NewKeystoreAdapter(keystore loop.Keystore, accountPrefix string) *KeystoreAdapter

func (*KeystoreAdapter) PubKey

func (ka *KeystoreAdapter) PubKey(address string) (cryptotypes.PubKey, error)

Returns the cosmos PubKey associated with the prefixed address.

func (*KeystoreAdapter) Sign

func (ka *KeystoreAdapter) Sign(ctx context.Context, id string, hash []byte) ([]byte, error)

type ORM

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

ORM manages the data model for cosmos 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) (adapters.Msgs, error)

GetMsgs returns any messages matching ids.

func (*ORM) GetMsgsState

func (o *ORM) GetMsgsState(state db.State, limit int64, qopts ...pg.QOpt) (adapters.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 cosmos msg, assumed to be a serialized cosmos 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 cosmos blockchain.

func NewTxm

func NewTxm(db *sqlx.DB, tc func() (cosmosclient.ReaderWriter, error), gpe cosmosclient.ComposedGasPriceEstimator, chainID string, cfg coscfg.Config, ks loop.Keystore, 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 cosmos chain.

func (*Txm) GasPrice

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

GasPrice returns the gas price from the estimator in the configured fee token.

func (*Txm) GetMsgs

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

GetMsgs returns any messages matching ids.

func (*Txm) HealthReport

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

func (*Txm) Healthy

func (txm *Txm) Healthy() error

Healthy service is healthy

func (*Txm) Name

func (txm *Txm) Name() string

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 cosmos msg inserts and processes them.