Documentation ¶
Index ¶
- Constants
- func DeliverTxFromCheckTx(ctr types.ResponseCheckTx) types.ResponseDeliverTx
- func ExecuteTx(logHeader string, executor execution.Executor, txDecoder txs.Decoder, ...) types.ResponseCheckTx
- func WithTags(logger *logging.Logger, tags []common.KVPair) *logging.Logger
- type App
- func (app *App) BeginBlock(block types.RequestBeginBlock) (respBeginBlock types.ResponseBeginBlock)
- func (app *App) CheckTx(txBytes []byte) types.ResponseCheckTx
- func (app *App) Commit() types.ResponseCommit
- func (app *App) DeliverTx(txBytes []byte) types.ResponseDeliverTx
- func (app *App) EndBlock(reqEndBlock types.RequestEndBlock) types.ResponseEndBlock
- func (app *App) Info(info types.RequestInfo) types.ResponseInfo
- func (app *App) InitChain(chain types.RequestInitChain) (respInitChain types.ResponseInitChain)
- func (app *App) Query(reqQuery types.RequestQuery) (respQuery types.ResponseQuery)
- func (app *App) SetMempoolLocker(mempoolLocker sync.Locker)
- func (app *App) SetOption(option types.RequestSetOption) (respSetOption types.ResponseSetOption)
- type PeersFilterProvider
- type Process
- type Validators
Constants ¶
View Source
const ( TendermintValidatorDelayInBlocks = 2 BurrowValidatorDelayInBlocks = 1 )
Variables ¶
This section is empty.
Functions ¶
func DeliverTxFromCheckTx ¶
func DeliverTxFromCheckTx(ctr types.ResponseCheckTx) types.ResponseDeliverTx
Types ¶
type App ¶
type App struct {
// contains filtered or unexported fields
}
func NewApp ¶
func NewApp(nodeInfo string, blockchain *bcm.Blockchain, validators Validators, checker execution.BatchExecutor, committer execution.BatchCommitter, txDecoder txs.Decoder, authorizedPeersProvider PeersFilterProvider, panicFunc func(error), logger *logging.Logger) *App
func (*App) BeginBlock ¶
func (app *App) BeginBlock(block types.RequestBeginBlock) (respBeginBlock types.ResponseBeginBlock)
func (*App) Commit ¶
func (app *App) Commit() types.ResponseCommit
func (*App) EndBlock ¶
func (app *App) EndBlock(reqEndBlock types.RequestEndBlock) types.ResponseEndBlock
func (*App) Info ¶
func (app *App) Info(info types.RequestInfo) types.ResponseInfo
func (*App) InitChain ¶
func (app *App) InitChain(chain types.RequestInitChain) (respInitChain types.ResponseInitChain)
func (*App) Query ¶
func (app *App) Query(reqQuery types.RequestQuery) (respQuery types.ResponseQuery)
func (*App) SetMempoolLocker ¶
Provide the Mempool lock. When provided we will attempt to acquire this lock in a goroutine during the Commit. We will keep the checker cache locked until we are able to acquire the mempool lock which signals the end of the commit and possible recheck on Tendermint's side.
func (*App) SetOption ¶
func (app *App) SetOption(option types.RequestSetOption) (respSetOption types.ResponseSetOption)
type PeersFilterProvider ¶
PeersFilterProvider provides current authorized nodes id and/or addresses
type Process ¶
type Process struct {
// contains filtered or unexported fields
}
func NewProcess ¶
func NewProcess(committer execution.BatchCommitter, blockchain *bcm.Blockchain, txDecoder txs.Decoder, commitInterval time.Duration, panicFunc func(error)) *Process
NewProcess returns a no-consensus ABCI process suitable for running a single node without Tendermint. The CheckTx function can be used to submit transactions which are processed according
type Validators ¶
Click to show internal directories.
Click to hide internal directories.