Documentation ¶
Index ¶
- Variables
- func NewBlockstore(path string, relayer string) (*utils.Blockstore, error)
- func StartBlock(bs *utils.Blockstore, blk uint64) (uint64, error)
- type Chain
- func (c *Chain) GetAddressPrefix(denom string) (*stafiHubXRBankTypes.QueryAddressPrefixResponse, error)
- func (c *Chain) GetIcaPools(denom string) (*stafiHubXLedgerTypes.QueryIcaPoolListResponse, error)
- func (c *Chain) GetPoolDetail(denom, pool string) (*stafiHubXLedgerTypes.QueryGetPoolDetailResponse, error)
- func (c *Chain) GetPools(denom string) (*stafiHubXLedgerTypes.QueryBondedPoolsByDenomResponse, error)
- func (c *Chain) GetRParams(denom string) (*stafiHubXLedgerTypes.QueryGetRParamsResponse, error)
- func (c *Chain) GetSelectedValidators(denom, pool string) (*stafiHubXRValidatorTypes.QueryRValidatorListResponse, error)
- func (c *Chain) Initialize(cfg *config.RawChainConfig, logger log.Logger, sysErr chan<- error) error
- func (c *Chain) Name() string
- func (c *Chain) RSymbol() core.RSymbol
- func (c *Chain) SetRouter(r *core.Router)
- func (c *Chain) Start() error
- func (c *Chain) Stop()
- type ConfigOption
- type Connection
- type Handler
- type Listener
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrEventAttributeNumberUnMatch = errors.New("ErrEventAttributeNumberTooFew") SimulateBondReportedEvent = types.StringEvent{ Type: stafiHubXLedgerTypes.EventTypeBondReported, Attributes: []types.Attribute{ {Key: stafiHubXLedgerTypes.AttributeKeyDenom, Value: "uratom"}, {Key: stafiHubXLedgerTypes.AttributeKeyShotId, Value: "710f75313464e035f1156c115ecc1ea5b8e1cf15e5070b7198fa211273388996"}}, } )
View Source
var ( BlockRetryInterval = time.Second * 6 BlockRetryLimit = 50 BlockConfirmNumber = int64(3) )
View Source
var (
ErrorTerminated = errors.New("terminated")
)
Functions ¶
func NewBlockstore ¶
func NewBlockstore(path string, relayer string) (*utils.Blockstore, error)
func StartBlock ¶
func StartBlock(bs *utils.Blockstore, blk uint64) (uint64, error)
Types ¶
type Chain ¶
type Chain struct {
// contains filtered or unexported fields
}
func (*Chain) GetAddressPrefix ¶
func (c *Chain) GetAddressPrefix(denom string) (*stafiHubXRBankTypes.QueryAddressPrefixResponse, error)
func (*Chain) GetIcaPools ¶ added in v1.4.0
func (c *Chain) GetIcaPools(denom string) (*stafiHubXLedgerTypes.QueryIcaPoolListResponse, error)
func (*Chain) GetPoolDetail ¶
func (c *Chain) GetPoolDetail(denom, pool string) (*stafiHubXLedgerTypes.QueryGetPoolDetailResponse, error)
func (*Chain) GetPools ¶
func (c *Chain) GetPools(denom string) (*stafiHubXLedgerTypes.QueryBondedPoolsByDenomResponse, error)
func (*Chain) GetRParams ¶
func (c *Chain) GetRParams(denom string) (*stafiHubXLedgerTypes.QueryGetRParamsResponse, error)
func (*Chain) GetSelectedValidators ¶ added in v1.3.0
func (c *Chain) GetSelectedValidators(denom, pool string) (*stafiHubXRValidatorTypes.QueryRValidatorListResponse, error)
func (*Chain) Initialize ¶
type ConfigOption ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func NewConnection ¶
func NewConnection(cfg *config.RawChainConfig, option *ConfigOption, log log.Logger) (*Connection, error)
func (*Connection) BlockStoreUseAddress ¶
func (c *Connection) BlockStoreUseAddress() string
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
func NewHandler ¶
func NewHandler(conn *Connection, log log.Logger, stopChan <-chan struct{}, sysErrChan chan<- error) *Handler
func (*Handler) HandleMessage ¶
resolve msg from other chains
type Listener ¶
type Listener struct {
// contains filtered or unexported fields
}
func NewListener ¶
Click to show internal directories.
Click to hide internal directories.