abci

Documentation

Index

• type App
  • func NewApp(nodeInfo string, blockchain *bcm.Blockchain, checker execution.BatchExecutor, ...) *App
  • func (app *App) BeginBlock(block abciTypes.RequestBeginBlock) (respBeginBlock abciTypes.ResponseBeginBlock)
  • func (app *App) CheckTx(txBytes []byte) abciTypes.ResponseCheckTx
  • func (app *App) Commit() abciTypes.ResponseCommit
  • func (app *App) DeliverTx(txBytes []byte) abciTypes.ResponseDeliverTx
  • func (app *App) EndBlock(reqEndBlock abciTypes.RequestEndBlock) abciTypes.ResponseEndBlock
  • func (app *App) Info(info abciTypes.RequestInfo) abciTypes.ResponseInfo
  • func (app *App) InitChain(chain abciTypes.RequestInitChain) (respInitChain abciTypes.ResponseInitChain)
  • func (app *App) Query(reqQuery abciTypes.RequestQuery) (respQuery abciTypes.ResponseQuery)
  • func (app *App) SetMempoolLocker(mempoolLocker sync.Locker)
  • func (app *App) SetOption(option abciTypes.RequestSetOption) (respSetOption abciTypes.ResponseSetOption)

Types

type App

type App struct {
	// contains filtered or unexported fields
}

func NewApp

func NewApp(nodeInfo string, blockchain *bcm.Blockchain, checker execution.BatchExecutor, committer execution.BatchCommitter,
	txDecoder txs.Decoder, panicFunc func(error), logger *logging.Logger) *App

func (*App) BeginBlock

func (app *App) BeginBlock(block abciTypes.RequestBeginBlock) (respBeginBlock abciTypes.ResponseBeginBlock)

func (*App) CheckTx

func (app *App) CheckTx(txBytes []byte) abciTypes.ResponseCheckTx

func (*App) Commit

func (app *App) Commit() abciTypes.ResponseCommit

func (*App) DeliverTx

func (app *App) DeliverTx(txBytes []byte) abciTypes.ResponseDeliverTx

func (*App) EndBlock

func (app *App) EndBlock(reqEndBlock abciTypes.RequestEndBlock) abciTypes.ResponseEndBlock

func (*App) Info

func (app *App) Info(info abciTypes.RequestInfo) abciTypes.ResponseInfo

func (*App) InitChain

func (app *App) InitChain(chain abciTypes.RequestInitChain) (respInitChain abciTypes.ResponseInitChain)

func (*App) Query

func (app *App) Query(reqQuery abciTypes.RequestQuery) (respQuery abciTypes.ResponseQuery)

func (*App) SetMempoolLocker

func (app *App) SetMempoolLocker(mempoolLocker sync.Locker)

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 abciTypes.RequestSetOption) (respSetOption abciTypes.ResponseSetOption)