execute

Documentation

Index

• type Block
• type BlockParams
• type BlockState
• type BlockStateV1
  • func (s *BlockStateV1) Commit() error
  • func (s *BlockStateV1) DidCompleteMajorBlock() (uint64, time.Time, bool)
  • func (s *BlockStateV1) Discard()
  • func (s *BlockStateV1) IsEmpty() bool
  • func (b *BlockStateV1) Params() execute.BlockParams
• type BlockV1
  • func (b *BlockV1) Close() (execute.BlockState, error)
  • func (b *BlockV1) Params() execute.BlockParams
  • func (b *BlockV1) Process(messages []messaging.Message) ([]*protocol.TransactionStatus, error)
• type Dispatcher
• type Executor
  • func NewExecutor(opts Options) (Executor, error)
• type ExecutorV1
  • func (x *ExecutorV1) Begin(params execute.BlockParams) (execute.Block, error)
  • func (x *ExecutorV1) EnableTimers()
  • func (x *ExecutorV1) InitChainValidators(initVal []abcitypes.ValidatorUpdate) (additional [][]byte, err error)
  • func (x *ExecutorV1) LoadStateRoot(batch *database.Batch) ([]byte, error)
  • func (x *ExecutorV1) RestoreSnapshot(batch database.Beginner, snapshot ioutil2.SectionReader) error
  • func (x *ExecutorV1) StoreBlockTimers(ds *logging.DataSet)
  • func (x *ExecutorV1) Validate(batch *database.Batch, messages []messaging.Message) ([]*protocol.TransactionStatus, error)
• type Multi
  • func (m *Multi) Begin(params BlockParams) (Block, error)
  • func (m *Multi) EnableTimers()
  • func (m *Multi) InitChainValidators(initVal []abcitypes.ValidatorUpdate) (additional [][]byte, err error)
  • func (m *Multi) LoadStateRoot(batch *database.Batch) ([]byte, error)
  • func (m *Multi) RestoreSnapshot(db database.Beginner, snapshot ioutil2.SectionReader) error
  • func (m *Multi) StoreBlockTimers(ds *logging.DataSet)
  • func (m *Multi) Validate(batch *database.Batch, messages []messaging.Message) ([]*protocol.TransactionStatus, error)
• type Options

Types

type Block

type Block = execute.Block

type BlockParams

type BlockParams = execute.BlockParams

type BlockState

type BlockState = execute.BlockState

type BlockStateV1

type BlockStateV1 block.Block

BlockStateV1 translates execute.BlockState calls for a v1 executor block.

func (*BlockStateV1) Commit

func (s *BlockStateV1) Commit() error

func (*BlockStateV1) DidCompleteMajorBlock

func (s *BlockStateV1) DidCompleteMajorBlock() (uint64, time.Time, bool)

func (*BlockStateV1) Discard

func (s *BlockStateV1) Discard()

func (*BlockStateV1) IsEmpty

func (s *BlockStateV1) IsEmpty() bool

func (*BlockStateV1) Params

func (b *BlockStateV1) Params() execute.BlockParams

type BlockV1

type BlockV1 struct {
	Block    *block.Block
	Executor *block.Executor
}

BlockV1 translates execute.Block calls for a v1 executor/block.

func (*BlockV1) Close

func (b *BlockV1) Close() (execute.BlockState, error)

Close ends the block and returns the block state.

func (*BlockV1) Params

func (b *BlockV1) Params() execute.BlockParams

func (*BlockV1) Process

func (b *BlockV1) Process(messages []messaging.Message) ([]*protocol.TransactionStatus, error)

Process converts the message to a delivery and processes it. Process returns an error if the message is not a [message.LegacyMessage].

type Dispatcher

type Dispatcher = execute.Dispatcher

type Executor

type Executor = execute.Executor

func NewExecutor

func NewExecutor(opts Options) (Executor, error)

NewExecutor creates a new executor.

type ExecutorV1

type ExecutorV1 block.Executor

ExecutorV1 implements execute.Executor calls for a v1 executor.

func (*ExecutorV1) Begin

func (x *ExecutorV1) Begin(params execute.BlockParams) (execute.Block, error)

Begin constructs a BlockV1 and calls block.Executor.BeginBlock.

func (*ExecutorV1) EnableTimers

func (x *ExecutorV1) EnableTimers()

func (*ExecutorV1) InitChainValidators

func (x *ExecutorV1) InitChainValidators(initVal []abcitypes.ValidatorUpdate) (additional [][]byte, err error)

func (*ExecutorV1) LoadStateRoot

func (x *ExecutorV1) LoadStateRoot(batch *database.Batch) ([]byte, error)

func (*ExecutorV1) RestoreSnapshot

func (x *ExecutorV1) RestoreSnapshot(batch database.Beginner, snapshot ioutil2.SectionReader) error

func (*ExecutorV1) StoreBlockTimers

func (x *ExecutorV1) StoreBlockTimers(ds *logging.DataSet)

func (*ExecutorV1) Validate

func (x *ExecutorV1) Validate(batch *database.Batch, messages []messaging.Message) ([]*protocol.TransactionStatus, error)

Validate converts the message to a delivery and validates it. Validate returns an error if the message is not a [message.LegacyMessage].

type Multi

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

func (*Multi) Begin

func (m *Multi) Begin(params BlockParams) (Block, error)

func (*Multi) EnableTimers

func (m *Multi) EnableTimers()

func (*Multi) InitChainValidators

func (m *Multi) InitChainValidators(initVal []abcitypes.ValidatorUpdate) (additional [][]byte, err error)

func (*Multi) LoadStateRoot

func (m *Multi) LoadStateRoot(batch *database.Batch) ([]byte, error)

func (*Multi) RestoreSnapshot

func (m *Multi) RestoreSnapshot(db database.Beginner, snapshot ioutil2.SectionReader) error

func (*Multi) StoreBlockTimers

func (m *Multi) StoreBlockTimers(ds *logging.DataSet)

func (*Multi) Validate

func (m *Multi) Validate(batch *database.Batch, messages []messaging.Message) ([]*protocol.TransactionStatus, error)

type Options

type Options = execute.Options