proxy

Documentation

Index

• Variables
• func NewAppConnConsensus(appConn abcicli.Client) *appConnConsensus
• func NewAppConnMempool(appConn abcicli.Client) *appConnMempool
• func NewAppConnQuery(appConn abcicli.Client) *appConnQuery
• func NewAppConnState(appConn abcicli.Client) *appConnState
• func NewMultiAppConn(clientCreator ClientCreator) *multiAppConn
• type AppConnConsensus
• type AppConnMempool
• type AppConnQuery
• type AppConnState
• type AppConns
  • func NewAppConns(clientCreator ClientCreator) AppConns
• type ClientCreator
  • func DefaultClientCreator(addr, transport, dbDir string) ClientCreator
  • func NewLocalClientCreator(app types.Application) ClientCreator
  • func NewRemoteClientCreator(addr, transport string, mustConnect bool) ClientCreator

Variables

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.

Functions

func NewAppConnConsensus

func NewAppConnConsensus(appConn abcicli.Client) *appConnConsensus

func NewAppConnMempool

func NewAppConnMempool(appConn abcicli.Client) *appConnMempool

func NewAppConnQuery

func NewAppConnQuery(appConn abcicli.Client) *appConnQuery

func NewAppConnState

func NewAppConnState(appConn abcicli.Client) *appConnState

func NewMultiAppConn

func NewMultiAppConn(clientCreator ClientCreator) *multiAppConn

Make all necessary abci connections to the application

Types

type AppConnConsensus

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

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

	BeginBlockSync(types.RequestBeginBlock) (*types.ResponseBeginBlock, error)
	DeliverTxAsync(tx []byte) *abcicli.ReqRes
	EndBlockSync(types.RequestEndBlock) (*types.ResponseEndBlock, error)
	CommitSync() (*types.ResponseCommit, error)
}

type AppConnMempool

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

	CheckTxAsync(tx []byte) *abcicli.ReqRes
	ReCheckTxAsync(tx []byte) *abcicli.ReqRes

	FlushAsync() *abcicli.ReqRes
	FlushSync() error
}

type AppConnQuery

type AppConnQuery interface {
	Error() error

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

type AppConnState

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

	LatestSnapshot() (height int64, numKeys []int64, err error)
	ReadSnapshotChunk(height int64, startIndex, endIndex int64) (chunk [][]byte, err error)
	StartRecovery(height int64, numKeys []int64) error
	WriteRecoveryChunk(chunk [][]byte) error
	EndRecovery(height int64) error
}

type AppConns

type AppConns interface {
	cmn.Service

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

Tendermint's interface to the application consists of multiple connections

func NewAppConns

func NewAppConns(clientCreator ClientCreator) AppConns

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

func NewRemoteClientCreator

func NewRemoteClientCreator(addr, transport string, mustConnect bool) ClientCreator