abci

Documentation

Index

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

Types

type App

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

func NewApp

func NewApp(blockchain bcm.MutableBlockchain,
	checker execution.BatchExecutor,
	committer execution.BatchCommitter,
	logger *logging.Logger) *App

func (*App) BeginBlock

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

func (*App) CheckTx

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

func (*App) Commit

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

func (*App) DeliverTx

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

func (*App) EndBlock

func (app *App) EndBlock(reqEndBlock abci_types.RequestEndBlock) (respEndBlock abci_types.ResponseEndBlock)

func (*App) Info

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

func (*App) InitChain

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

func (*App) Query

func (app *App) Query(reqQuery abci_types.RequestQuery) (respQuery abci_types.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 abci_types.RequestSetOption) (respSetOption abci_types.ResponseSetOption)