abci

package

v0.34.4 Latest Latest Go to latest Published: Jul 23, 2021 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/hyperledger/burrow

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DeliverTxFromCheckTx(ctr types.ResponseCheckTx) types.ResponseDeliverTx
func ExecuteTx(logHeader string, executor execution.Executor, txDecoder txs.Decoder, ...) types.ResponseCheckTx
func WithEvents(logger *logging.Logger, events []types.Event) *logging.Logger
type App
- func NewApp(nodeInfo string, blockchain *bcm.Blockchain, validators Validators, ...) *App
type AuthorizedPeers
type PeerLists
- func NewPeerLists() *PeerLists
type Process
- func NewProcess(committer execution.BatchCommitter, blockchain *bcm.Blockchain, ...) *Process
- func (p *Process) CheckTx(tx tmTypes.Tx, cb func(*types.Response), txInfo mempool.TxInfo) error
- func (p *Process) Shutdown(ctx context.Context) (err error)
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

func ExecuteTx ¶

func ExecuteTx(logHeader string, executor execution.Executor, txDecoder txs.Decoder, txBytes []byte) types.ResponseCheckTx

Attempt to execute a transaction using ABCI conventions and codes

func WithEvents ¶ added in v0.29.0

func WithEvents(logger *logging.Logger, events []types.Event) *logging.Logger

Types ¶

type App ¶

type App struct {
	// Provides a no-op implementation for all methods (in particular snapshots for now will abort)
	types.BaseApplication
	// 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, authorizedPeers AuthorizedPeers,
	panicFunc func(error), logger *logging.Logger) *App

func (*App) BeginBlock ¶

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

func (*App) CheckTx ¶

func (app *App) CheckTx(req types.RequestCheckTx) types.ResponseCheckTx

func (*App) Commit ¶

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

func (*App) DeliverTx ¶

func (app *App) DeliverTx(req types.RequestDeliverTx) types.ResponseDeliverTx

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) types.ResponseInitChain

func (*App) Query ¶

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

type AuthorizedPeers ¶ added in v0.29.0

type AuthorizedPeers interface {
	NumPeers() int
	QueryPeerByID(id string) bool
	QueryPeerByAddress(id string) bool
}

AuthorizedPeers provides current authorized nodes id and/or addresses

type PeerLists ¶ added in v0.29.0

type PeerLists struct {
	IDs       map[string]struct{}
	Addresses map[string]struct{}
}

func NewPeerLists ¶ added in v0.29.0

func NewPeerLists() *PeerLists

func (PeerLists) NumPeers ¶ added in v0.29.0

func (p PeerLists) NumPeers() int

func (PeerLists) QueryPeerByAddress ¶ added in v0.29.0

func (p PeerLists) QueryPeerByAddress(id string) bool

func (PeerLists) QueryPeerByID ¶ added in v0.29.0

func (p PeerLists) QueryPeerByID(id string) bool

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

func (*Process) CheckTx ¶

func (p *Process) CheckTx(tx tmTypes.Tx, cb func(*types.Response), txInfo mempool.TxInfo) error

func (*Process) Shutdown ¶

func (p *Process) Shutdown(ctx context.Context) (err error)

type Validators ¶

type Validators interface {
	validator.History
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL