Versions in this module Expand all Collapse all v0 v0.0.4 Jul 18, 2024 v0.0.1 Jul 18, 2024 Changes in this version + const MetricsSubsystem + var RequestInfo = &abci.RequestInfo + type AppConnConsensus interface + Commit func(context.Context) (*types.ResponseCommit, error) + Error func() error + ExtendVote func(context.Context, *types.RequestExtendVote) (*types.ResponseExtendVote, error) + FinalizeBlock func(context.Context, *types.RequestFinalizeBlock) (*types.ResponseFinalizeBlock, error) + InitChain func(context.Context, *types.RequestInitChain) (*types.ResponseInitChain, error) + PrepareProposal func(context.Context, *types.RequestPrepareProposal) (*types.ResponsePrepareProposal, error) + ProcessProposal func(context.Context, *types.RequestProcessProposal) (*types.ResponseProcessProposal, error) + VerifyVoteExtension func(context.Context, *types.RequestVerifyVoteExtension) (*types.ResponseVerifyVoteExtension, error) + func NewAppConnConsensus(appConn abcicli.Client, metrics *Metrics) AppConnConsensus + type AppConnMempool interface + CheckTx func(context.Context, *types.RequestCheckTx) (*types.ResponseCheckTx, error) + CheckTxAsync func(context.Context, *types.RequestCheckTx) (*abcicli.ReqRes, error) + Error func() error + Flush func(context.Context) error + SetResponseCallback func(abcicli.Callback) + func NewAppConnMempool(appConn abcicli.Client, metrics *Metrics) AppConnMempool + type AppConnQuery interface + Echo func(context.Context, string) (*types.ResponseEcho, error) + Error func() error + Info func(context.Context, *types.RequestInfo) (*types.ResponseInfo, error) + Query func(context.Context, *types.RequestQuery) (*types.ResponseQuery, error) + func NewAppConnQuery(appConn abcicli.Client, metrics *Metrics) AppConnQuery + type AppConnSnapshot interface + ApplySnapshotChunk func(context.Context, *types.RequestApplySnapshotChunk) (*types.ResponseApplySnapshotChunk, error) + Error func() error + ListSnapshots func(context.Context, *types.RequestListSnapshots) (*types.ResponseListSnapshots, error) + LoadSnapshotChunk func(context.Context, *types.RequestLoadSnapshotChunk) (*types.ResponseLoadSnapshotChunk, error) + OfferSnapshot func(context.Context, *types.RequestOfferSnapshot) (*types.ResponseOfferSnapshot, error) + func NewAppConnSnapshot(appConn abcicli.Client, metrics *Metrics) AppConnSnapshot + type AppConns interface + Consensus func() AppConnConsensus + Mempool func() AppConnMempool + Query func() AppConnQuery + Snapshot func() AppConnSnapshot + func NewAppConns(clientCreator ClientCreator, metrics *Metrics) AppConns + func NewMultiAppConn(clientCreator ClientCreator, metrics *Metrics) AppConns + type ClientCreator interface + NewABCIClient func() (abcicli.Client, error) + func DefaultClientCreator(addr, transport, dbDir string) ClientCreator + func NewConnSyncLocalClientCreator(app types.Application) ClientCreator + func NewLocalClientCreator(app types.Application) ClientCreator + func NewRemoteClientCreator(addr, transport string, mustConnect bool) ClientCreator + type Metrics struct + MethodTimingSeconds metrics.Histogram + func NopMetrics() *Metrics + func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics