Versions in this module Expand all Collapse all v0 v0.31.5 Apr 16, 2019 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) + 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 + Prove bool + type Client interface + type EventsClient interface + Subscribe func(ctx context.Context, subscriber, query string, outCapacity ...int) (out <-chan ctypes.ResultEvent, err error) + Unsubscribe func(ctx context.Context, subscriber, query string) error + UnsubscribeAll func(ctx context.Context, subscriber string) error + 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) 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) ConsensusState() (*ctypes.ResultConsensusState, 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, page, perPage int) (*ctypes.ResultTxSearch, error) + func (c *HTTP) UnconfirmedTxs(limit int) (*ctypes.ResultUnconfirmedTxs, 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 + Logger log.Logger + func NewLocal(node *nm.Node) *Local + func (c *Local) ABCIInfo() (*ctypes.ResultABCIInfo, error) + func (c *Local) ABCIQuery(path string, data cmn.HexBytes) (*ctypes.ResultABCIQuery, error) + func (c *Local) ABCIQueryWithOptions(path string, data cmn.HexBytes, opts ABCIQueryOptions) (*ctypes.ResultABCIQuery, error) + func (c *Local) Block(height *int64) (*ctypes.ResultBlock, error) + func (c *Local) BlockResults(height *int64) (*ctypes.ResultBlockResults, error) + func (c *Local) BlockchainInfo(minHeight, maxHeight int64) (*ctypes.ResultBlockchainInfo, error) + func (c *Local) BroadcastTxAsync(tx types.Tx) (*ctypes.ResultBroadcastTx, error) + func (c *Local) BroadcastTxCommit(tx types.Tx) (*ctypes.ResultBroadcastTxCommit, error) + func (c *Local) BroadcastTxSync(tx types.Tx) (*ctypes.ResultBroadcastTx, error) + func (c *Local) Commit(height *int64) (*ctypes.ResultCommit, error) + func (c *Local) ConsensusState() (*ctypes.ResultConsensusState, error) + func (c *Local) DialPeers(peers []string, persistent bool) (*ctypes.ResultDialPeers, error) + func (c *Local) DialSeeds(seeds []string) (*ctypes.ResultDialSeeds, error) + func (c *Local) DumpConsensusState() (*ctypes.ResultDumpConsensusState, error) + func (c *Local) Genesis() (*ctypes.ResultGenesis, error) + func (c *Local) Health() (*ctypes.ResultHealth, error) + func (c *Local) NetInfo() (*ctypes.ResultNetInfo, error) + func (c *Local) NumUnconfirmedTxs() (*ctypes.ResultUnconfirmedTxs, error) + func (c *Local) SetLogger(l log.Logger) + func (c *Local) Status() (*ctypes.ResultStatus, error) + func (c *Local) Subscribe(ctx context.Context, subscriber, query string, outCapacity ...int) (out <-chan ctypes.ResultEvent, err error) + func (c *Local) Tx(hash []byte, prove bool) (*ctypes.ResultTx, error) + func (c *Local) TxSearch(query string, prove bool, page, perPage int) (*ctypes.ResultTxSearch, error) + func (c *Local) UnconfirmedTxs(limit int) (*ctypes.ResultUnconfirmedTxs, error) + func (c *Local) Unsubscribe(ctx context.Context, subscriber, query string) error + func (c *Local) UnsubscribeAll(ctx context.Context, subscriber string) error + func (c *Local) Validators(height *int64) (*ctypes.ResultValidators, error) + type MempoolClient interface + NumUnconfirmedTxs func() (*ctypes.ResultUnconfirmedTxs, error) + UnconfirmedTxs func(limit int) (*ctypes.ResultUnconfirmedTxs, error) + type NetworkClient interface + ConsensusState func() (*ctypes.ResultConsensusState, error) + 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, page, perPage int) (*ctypes.ResultTxSearch, error) + Validators func(height *int64) (*ctypes.ResultValidators, error) + type StatusClient interface + 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, query string, outCapacity ...int) (out <-chan ctypes.ResultEvent, err error) + func (w *WSEvents) Unsubscribe(ctx context.Context, subscriber, query string) error + func (w *WSEvents) UnsubscribeAll(ctx context.Context, subscriber string) error + type Waiter func(delta int64) (abort error)
Go to main page