proxy

Documentation

Index

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

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, handshaker Handshaker) *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)

	// Pass the height of the current block
	DeliverTxAsync(tx []byte, height int64) *abcicli.ReqRes
	DeliverBucketedTxSync(tx []byte, height int64, bucketID string) (*types.ResponseDeliverTx, error)
	EndBlockSync(types.RequestEndBlock) (*types.ResponseEndBlock, error)
	GetValidatorSetSync(height int64) (*types.ResponseGetValidatorSet, error)
	CommitSync() (*types.ResponseCommit, error)
}

type AppConnMempool

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

	// Pass the height of the current block
	CheckTxAsync(tx []byte, height int64) *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
}

Demars-DMC's interface to the application consists of multiple connections

func NewAppConns

func NewAppConns(clientCreator ClientCreator, handshaker Handshaker) 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

type Handshaker

type Handshaker interface {
	Handshake(AppConns) error
}