Versions in this module Expand all Collapse all v0 v0.0.2 May 13, 2020 v0.0.1 May 13, 2020 Changes in this version + var DefaultABCIQueryOptions = ABCIQueryOptions + func DefaultWaitStrategy(delta int64) (abort error) + func WaitForHeight(c StatusClient, h int64, waiter Waiter) error + func WaitForOneEvent(c EventsClient, evtTyp string, timeout time.Duration) (types.TMEventData, error) + type ABCIClient interface + ABCIInfo func() (*ctypes.ResultABCIInfo, error) + ABCIQuery func(path string, data cmn.HexBytes) (*ctypes.ResultABCIQuery, error) + ABCIQueryEx func(path string) (*ctypes.ResultABCIQueryEx, error) + ABCIQueryExWithOptions func(path string) (*ctypes.ResultABCIQueryEx, error) + ABCIQueryWithOptions func(path string, data cmn.HexBytes, opts ABCIQueryOptions) (*ctypes.ResultABCIQuery, error) + BroadcastTxAsync func(tx types.Tx) (*ctypes.ResultBroadcastTx, error) + BroadcastTxCommit func(tx types.Tx) (*ctypes.ResultBroadcastTxCommit, error) + BroadcastTxSync func(tx types.Tx) (*ctypes.ResultBroadcastTx, error) + type ABCIQueryOptions struct + Height int64 + Trusted bool + type Client interface + type EventsClient interface + type HTTP struct + func NewHTTP(remote, wsEndpoint string) *HTTP + func (c *HTTP) ABCIInfo() (*ctypes.ResultABCIInfo, error) + func (c *HTTP) ABCIQuery(path string, data cmn.HexBytes) (*ctypes.ResultABCIQuery, error) + func (c *HTTP) ABCIQueryEx(path string) (*ctypes.ResultABCIQueryEx, error) + func (c *HTTP) ABCIQueryExWithOptions(path string) (*ctypes.ResultABCIQueryEx, error) + func (c *HTTP) ABCIQueryWithOptions(path string, data cmn.HexBytes, opts ABCIQueryOptions) (*ctypes.ResultABCIQuery, error) + func (c *HTTP) Block(height *int64) (*ctypes.ResultBlock, error) + func (c *HTTP) BlockResults(height *int64) (*ctypes.ResultBlockResults, error) + func (c *HTTP) BlockchainInfo(minHeight, maxHeight int64) (*ctypes.ResultBlockchainInfo, error) + func (c *HTTP) BroadcastTxAsync(tx types.Tx) (*ctypes.ResultBroadcastTx, error) + func (c *HTTP) BroadcastTxCommit(tx types.Tx) (*ctypes.ResultBroadcastTxCommit, error) + func (c *HTTP) BroadcastTxSync(tx types.Tx) (*ctypes.ResultBroadcastTx, error) + func (c *HTTP) Commit(height *int64) (*ctypes.ResultCommit, error) + func (c *HTTP) DumpConsensusState() (*ctypes.ResultDumpConsensusState, error) + func (c *HTTP) Genesis() (*ctypes.ResultGenesis, error) + func (c *HTTP) Health() (*ctypes.ResultHealth, error) + func (c *HTTP) NetInfo() (*ctypes.ResultNetInfo, error) + func (c *HTTP) NumUnConfirmedTxs() (*ctypes.ResultUnconfirmedTxs, error) + func (c *HTTP) Status() (*ctypes.ResultStatus, error) + func (c *HTTP) Tx(hash []byte, prove bool) (*ctypes.ResultTx, error) + func (c *HTTP) TxSearch(query string, prove bool) ([]*ctypes.ResultTx, error) + func (c *HTTP) Validators(height *int64) (*ctypes.ResultValidators, error) + type HistoryClient interface + BlockchainInfo func(minHeight, maxHeight int64) (*ctypes.ResultBlockchainInfo, error) + Genesis func() (*ctypes.ResultGenesis, error) + type Local struct + func NewLocal(node *nm.Node) *Local + func (Local) ABCIInfo() (*ctypes.ResultABCIInfo, error) + func (Local) ABCIQueryExWithOptions(path string) (*ctypes.ResultABCIQueryEx, error) + func (Local) ABCIQueryWithOptions(path string, data cmn.HexBytes, opts ABCIQueryOptions) (*ctypes.ResultABCIQuery, error) + func (Local) Block(height *int64) (*ctypes.ResultBlock, error) + func (Local) BlockResults(height *int64) (*ctypes.ResultBlockResults, error) + func (Local) BlockchainInfo(minHeight, maxHeight int64) (*ctypes.ResultBlockchainInfo, error) + func (Local) BroadcastTxAsync(tx types.Tx) (*ctypes.ResultBroadcastTx, error) + func (Local) BroadcastTxCommit(tx types.Tx) (*ctypes.ResultBroadcastTxCommit, error) + func (Local) BroadcastTxSync(tx types.Tx) (*ctypes.ResultBroadcastTx, error) + func (Local) Commit(height *int64) (*ctypes.ResultCommit, error) + func (Local) DialPeers(peers []string, persistent bool) (*ctypes.ResultDialPeers, error) + func (Local) DialSeeds(seeds []string) (*ctypes.ResultDialSeeds, error) + func (Local) DumpConsensusState() (*ctypes.ResultDumpConsensusState, error) + func (Local) Genesis() (*ctypes.ResultGenesis, error) + func (Local) Health() (*ctypes.ResultHealth, error) + func (Local) NetInfo() (*ctypes.ResultNetInfo, error) + func (Local) NumUnConfirmedTxs() (*ctypes.ResultUnconfirmedTxs, error) + func (Local) Status() (*ctypes.ResultStatus, error) + func (Local) Tx(hash []byte, prove bool) (*ctypes.ResultTx, error) + func (Local) TxSearch(query string, prove bool) ([]*ctypes.ResultTx, error) + func (Local) Validators(height *int64) (*ctypes.ResultValidators, error) + func (c *Local) ABCIQuery(path string, data cmn.HexBytes) (*ctypes.ResultABCIQuery, error) + func (c *Local) ABCIQueryEx(path string) (*ctypes.ResultABCIQueryEx, error) + func (c *Local) Subscribe(ctx context.Context, subscriber string, query tmpubsub.Query, ...) error + func (c *Local) Unsubscribe(ctx context.Context, subscriber string, query tmpubsub.Query) error + func (c *Local) UnsubscribeAll(ctx context.Context, subscriber string) error + type NetworkClient interface + DumpConsensusState func() (*ctypes.ResultDumpConsensusState, error) + Health func() (*ctypes.ResultHealth, error) + NetInfo func() (*ctypes.ResultNetInfo, error) + type SignClient interface + Block func(height *int64) (*ctypes.ResultBlock, error) + BlockResults func(height *int64) (*ctypes.ResultBlockResults, error) + Commit func(height *int64) (*ctypes.ResultCommit, error) + Tx func(hash []byte, prove bool) (*ctypes.ResultTx, error) + TxSearch func(query string, prove bool) ([]*ctypes.ResultTx, error) + Validators func(height *int64) (*ctypes.ResultValidators, error) + type StatusClient interface + NumUnConfirmedTxs func() (*ctypes.ResultUnconfirmedTxs, error) + Status func() (*ctypes.ResultStatus, error) + type WSEvents struct + func (w *WSEvents) OnStart() error + func (w *WSEvents) OnStop() + func (w *WSEvents) Subscribe(ctx context.Context, subscriber string, query tmpubsub.Query, ...) error + func (w *WSEvents) Unsubscribe(ctx context.Context, subscriber string, query tmpubsub.Query) error + func (w *WSEvents) UnsubscribeAll(ctx context.Context, subscriber string) error + type Waiter func(delta int64) (abort error)