proxy

package
v0.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 3, 2017 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAppConnConsensus added in v0.7.1

func NewAppConnConsensus(appConn abcicli.Client) *appConnConsensus

func NewAppConnMempool added in v0.7.1

func NewAppConnMempool(appConn abcicli.Client) *appConnMempool

func NewAppConnQuery added in v0.7.1

func NewAppConnQuery(appConn abcicli.Client) *appConnQuery

func NewMultiAppConn added in v0.7.1

func NewMultiAppConn(clientCreator ClientCreator, handshaker Handshaker) *multiAppConn

Make all necessary abci connections to the application

Types

type AppConnConsensus added in v0.7.1

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

	InitChainSync(validators []*types.Validator) (err error)

	BeginBlockSync(hash []byte, header *types.Header) (err error)
	DeliverTxAsync(tx []byte) *abcicli.ReqRes
	EndBlockSync(height uint64) (types.ResponseEndBlock, error)
	CommitSync() (res types.Result)
}

type AppConnMempool added in v0.7.1

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

	CheckTxAsync(tx []byte) *abcicli.ReqRes

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

type AppConnQuery added in v0.7.1

type AppConnQuery interface {
	Error() error

	EchoSync(string) (res types.Result)
	InfoSync() (resInfo types.ResponseInfo, err error)
	QuerySync(reqQuery types.RequestQuery) (resQuery types.ResponseQuery, err error)
}

type AppConns added in v0.7.1

type AppConns interface {
	cmn.Service

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

Tendermint's interface to the application consists of multiple connections

func NewAppConns added in v0.7.1

func NewAppConns(clientCreator ClientCreator, handshaker Handshaker) AppConns

type ClientCreator added in v0.7.1

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

NewABCIClient returns newly connected client

func DefaultClientCreator added in v0.7.1

func DefaultClientCreator(addr, transport, dbDir string) ClientCreator

func NewLocalClientCreator added in v0.7.1

func NewLocalClientCreator(app types.Application) ClientCreator

func NewRemoteClientCreator added in v0.7.1

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

type Handshaker added in v0.8.0

type Handshaker interface {
	Handshake(AppConns) error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL