proxy

Documentation

Index

• Variables
• func NewAppConnConsensus(appConn abcicli.Client) *appConnConsensus
• func NewAppConnMempool(appConn abcicli.Client) *appConnMempool
• func NewAppConnQuery(appConn abcicli.Client) *appConnQuery
• func NewMultiAppConn(clientCreator ClientCreator) *multiAppConn
• type AppConnConsensus
• type AppConnMempool
• type AppConnQuery
• 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 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(types.RequestDeliverTx) *abcicli.ReqRes
	EndBlockSync(types.RequestEndBlock) (*types.ResponseEndBlock, error)
	CommitSync() (*types.ResponseCommit, error)
}

type AppConnMempool

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

	CheckTxAsync(types.RequestCheckTx) *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 AppConns

type AppConns interface {
	cmn.Service

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

Aphelion'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