proxy

Documentation

Index

• Variables
• type AppConnConsensus
  • func NewAppConnConsensus(appConn abcicli.Client) AppConnConsensus
• type AppConnMempool
  • func NewAppConnMempool(appConn abcicli.Client) AppConnMempool
• type AppConnQuery
  • func NewAppConnQuery(appConn abcicli.Client) AppConnQuery
• type AppConns
  • func NewAppConns(clientCreator ClientCreator) AppConns
  • func NewMultiAppConn(clientCreator ClientCreator) AppConns
• type ClientCreator
  • func DefaultClientCreator(addr, transport, dbDir string) ClientCreator
  • func NewLocalClientCreator(app types.Application) ClientCreator

Variables

var IBCRequestInfo = abci.RequestInfo{
	Version:      version.Version,
	BlockVersion: version.IBCBlockProtocol.Uint64(),
	P2PVersion:   version.IBCP2PProtocol.Uint64(),
}

var RequestInfo = abci.RequestInfo{
	Version:      version.Version,
	BlockVersion: version.BlockProtocol.Uint64(),
	P2PVersion:   version.P2PProtocol.Uint64(),
}

RequestInfo contains all the information for sending the abci.RequestInfo message during handshake with the app. It contains only compile-time version information.

Types

type AppConnConsensus

type AppConnConsensus interface {
	SetResponseCallback(abcicli.Callback)
	Error() error

	InitChainSync(types.RequestInitChain) (*types.ResponseInitChain, error)

	BeginBlockSync(types.RequestBeginBlock) (*types.ResponseBeginBlock, error)
	DeliverTxAsync(types.RequestDeliverTx) *abcicli.ReqRes
	PreDeliverRealTxAsync(req []byte) types.TxEssentials
	DeliverRealTxAsync(essentials types.TxEssentials) *abcicli.ReqRes
	EndBlockSync(types.RequestEndBlock) (*types.ResponseEndBlock, error)
	CommitSync(types.RequestCommit) (*types.ResponseCommit, error)
	SetOptionAsync(req types.RequestSetOption) *abcicli.ReqRes
	ParallelTxs([][]byte, bool) []*types.ResponseDeliverTx
	SetOptionSync(req types.RequestSetOption) (*types.ResponseSetOption, error)
}

func NewAppConnConsensus

func NewAppConnConsensus(appConn abcicli.Client) AppConnConsensus

type AppConnMempool

type AppConnMempool interface {
	SetResponseCallback(abcicli.Callback)
	Error() error

	CheckTxAsync(types.RequestCheckTx) *abcicli.ReqRes

	FlushAsync() *abcicli.ReqRes
	FlushSync() error

	SetOptionAsync(types.RequestSetOption) *abcicli.ReqRes

	QuerySync(req types.RequestQuery) (*types.ResponseQuery, error)
}

func NewAppConnMempool

func NewAppConnMempool(appConn abcicli.Client) AppConnMempool

type AppConnQuery

type AppConnQuery interface {
	Error() error

	EchoSync(string) (*types.ResponseEcho, error)
	InfoSync(types.RequestInfo) (*types.ResponseInfo, error)
	QuerySync(types.RequestQuery) (*types.ResponseQuery, error)
}

func NewAppConnQuery

func NewAppConnQuery(appConn abcicli.Client) AppConnQuery

type AppConns

type AppConns interface {
	service.Service

	Mempool() AppConnMempool
	Consensus() AppConnConsensus
	Query() AppConnQuery
}

Tendermint's interface to the application consists of multiple connections

func NewAppConns

func NewAppConns(clientCreator ClientCreator) AppConns

func NewMultiAppConn

func NewMultiAppConn(clientCreator ClientCreator) AppConns

Make all necessary abci connections to the application

type ClientCreator

type ClientCreator interface {
	NewABCIClient() (abcicli.Client, error)
}

NewABCIClient returns newly connected client

func DefaultClientCreator

func DefaultClientCreator(addr, transport, dbDir string) ClientCreator

func NewLocalClientCreator

func NewLocalClientCreator(app types.Application) ClientCreator