tendermint

Documentation

Index

• func CheckDispatchError(err error) error
• func NewDispatcher(router routing.Router, self map[string]DispatcherClient) execute.Dispatcher
• func NewHTTPClient(ctx context.Context, peer coretypes.Peer, offset config.PortOffset) (*http.HTTP, error)
• func WalkPeers(ctx context.Context, client WalkClient, ...)
• type Client
• type DeferredClient
  • func NewDeferredClient() *DeferredClient
  • func (d *DeferredClient) ABCIInfo(ctx context.Context) (*ctypes.ResultABCIInfo, error)
  • func (d *DeferredClient) ABCIQuery(ctx context.Context, path string, data bytes.HexBytes) (*ctypes.ResultABCIQuery, error)
  • func (d *DeferredClient) ABCIQueryWithOptions(ctx context.Context, path string, data bytes.HexBytes, ...) (*ctypes.ResultABCIQuery, error)
  • func (d *DeferredClient) BroadcastTxAsync(ctx context.Context, tx types.Tx) (*ctypes.ResultBroadcastTx, error)
  • func (d *DeferredClient) BroadcastTxCommit(ctx context.Context, tx types.Tx) (*ctypes.ResultBroadcastTxCommit, error)
  • func (d *DeferredClient) BroadcastTxSync(ctx context.Context, tx types.Tx) (*ctypes.ResultBroadcastTx, error)
  • func (d *DeferredClient) CheckTx(ctx context.Context, tx types.Tx) (*ctypes.ResultCheckTx, error)
  • func (d *DeferredClient) ConsensusParams(ctx context.Context, height *int64) (*ctypes.ResultConsensusParams, error)
  • func (d *DeferredClient) ConsensusState(ctx context.Context) (*ctypes.ResultConsensusState, error)
  • func (d *DeferredClient) DumpConsensusState(ctx context.Context) (*ctypes.ResultDumpConsensusState, error)
  • func (d *DeferredClient) Health(ctx context.Context) (*ctypes.ResultHealth, error)
  • func (d *DeferredClient) NetInfo(ctx context.Context) (*ctypes.ResultNetInfo, error)
  • func (d *DeferredClient) NumUnconfirmedTxs(ctx context.Context) (*ctypes.ResultUnconfirmedTxs, error)
  • func (d *DeferredClient) Set(client Client)
  • func (d *DeferredClient) Status(ctx context.Context) (*ctypes.ResultStatus, error)
  • func (d *DeferredClient) UnconfirmedTxs(ctx context.Context, limit *int) (*ctypes.ResultUnconfirmedTxs, error)
• type DispatcherClient
• type WalkClient

Functions

func CheckDispatchError

func CheckDispatchError(err error) error

CheckDispatchError ignores errors we don't care about.

func NewDispatcher

func NewDispatcher(router routing.Router, self map[string]DispatcherClient) execute.Dispatcher

NewDispatcher creates a new dispatcher. NewDispatcher will panic if self does not include a client for the directory network.

func NewHTTPClient

func NewHTTPClient(ctx context.Context, peer coretypes.Peer, offset config.PortOffset) (*http.HTTP, error)

NewHTTPClient creates a new Tendermint RPC HTTP client for the given peer.

func WalkPeers

func WalkPeers(ctx context.Context, client WalkClient, visit func(context.Context, coretypes.Peer) (WalkClient, bool))

WalkPeers walks a Tendermint network, using the nodes' peer lists. WalkPeers calls visit for each (unique) discovered peer. If visit returns false, WalkPeers will return immediately; otherwise it will return once every peer has been visited.

Types

type Client

type Client interface {
	client.ABCIClient
	client.NetworkClient
	client.MempoolClient
	client.StatusClient
}

type DeferredClient

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

func NewDeferredClient

func NewDeferredClient() *DeferredClient

func (*DeferredClient) ABCIInfo

func (d *DeferredClient) ABCIInfo(ctx context.Context) (*ctypes.ResultABCIInfo, error)

func (*DeferredClient) ABCIQuery

func (d *DeferredClient) ABCIQuery(ctx context.Context, path string, data bytes.HexBytes) (*ctypes.ResultABCIQuery, error)

func (*DeferredClient) ABCIQueryWithOptions

func (d *DeferredClient) ABCIQueryWithOptions(ctx context.Context, path string, data bytes.HexBytes, opts client.ABCIQueryOptions) (*ctypes.ResultABCIQuery, error)

func (*DeferredClient) BroadcastTxAsync

func (d *DeferredClient) BroadcastTxAsync(ctx context.Context, tx types.Tx) (*ctypes.ResultBroadcastTx, error)

func (*DeferredClient) BroadcastTxCommit

func (d *DeferredClient) BroadcastTxCommit(ctx context.Context, tx types.Tx) (*ctypes.ResultBroadcastTxCommit, error)

func (*DeferredClient) BroadcastTxSync

func (d *DeferredClient) BroadcastTxSync(ctx context.Context, tx types.Tx) (*ctypes.ResultBroadcastTx, error)

func (*DeferredClient) CheckTx

func (d *DeferredClient) CheckTx(ctx context.Context, tx types.Tx) (*ctypes.ResultCheckTx, error)

func (*DeferredClient) ConsensusParams

func (d *DeferredClient) ConsensusParams(ctx context.Context, height *int64) (*ctypes.ResultConsensusParams, error)

func (*DeferredClient) ConsensusState

func (d *DeferredClient) ConsensusState(ctx context.Context) (*ctypes.ResultConsensusState, error)

func (*DeferredClient) DumpConsensusState

func (d *DeferredClient) DumpConsensusState(ctx context.Context) (*ctypes.ResultDumpConsensusState, error)

func (*DeferredClient) Health

func (d *DeferredClient) Health(ctx context.Context) (*ctypes.ResultHealth, error)

func (*DeferredClient) NetInfo

func (d *DeferredClient) NetInfo(ctx context.Context) (*ctypes.ResultNetInfo, error)

func (*DeferredClient) NumUnconfirmedTxs

func (d *DeferredClient) NumUnconfirmedTxs(ctx context.Context) (*ctypes.ResultUnconfirmedTxs, error)

func (*DeferredClient) Set

func (d *DeferredClient) Set(client Client)

Set sets the client. Set will panic if it is called more than once.

func (*DeferredClient) Status

func (d *DeferredClient) Status(ctx context.Context) (*ctypes.ResultStatus, error)

func (*DeferredClient) UnconfirmedTxs

func (d *DeferredClient) UnconfirmedTxs(ctx context.Context, limit *int) (*ctypes.ResultUnconfirmedTxs, error)

type DispatcherClient

type DispatcherClient interface {
	tm.SubmitClient
	rpc.NetworkClient
}

type WalkClient

type WalkClient interface {
	NetInfo(context.Context) (*coretypes.ResultNetInfo, error)
}

WalkClient is the subset of client.NetworkClient needed for WalkPeers.