execute

Documentation

Index

• type Block
• type BlockParams
• type BlockState
• type BlockStateV1
  • func (s *BlockStateV1) ChangeSet() record.Record
  • 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(envelope *messaging.Envelope) ([]*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) Init(validators []*ValidatorUpdate) (additional []*ValidatorUpdate, err error)
  • func (x *ExecutorV1) LastBlock() (*execute.BlockParams, [32]byte, error)
  • func (x *ExecutorV1) StoreBlockTimers(ds *logging.DataSet)
  • func (x *ExecutorV1) Validate(envelope *messaging.Envelope, recheck bool) ([]*protocol.TransactionStatus, error)
• type Multi
  • func (m *Multi) Begin(params BlockParams) (Block, error)
  • func (m *Multi) EnableTimers()
  • func (m *Multi) Init(validators []*ValidatorUpdate) (additional []*ValidatorUpdate, err error)
  • func (m *Multi) LastBlock() (*execute.BlockParams, [32]byte, error)
  • func (m *Multi) StoreBlockTimers(ds *logging.DataSet)
  • func (m *Multi) Validate(envelope *messaging.Envelope, recheck bool) ([]*protocol.TransactionStatus, error)
• type Options
• type ValidatorUpdate

Types

type Block

type Block = execute.Block

type BlockParams

type BlockParams = execute.BlockParams

type BlockState

type BlockState = execute.BlockState

type BlockStateV1

type BlockStateV1 BlockV1

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

func (*BlockStateV1) ChangeSet

func (s *BlockStateV1) ChangeSet() record.Record

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(envelope *messaging.Envelope) ([]*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) Init

func (x *ExecutorV1) Init(validators []*ValidatorUpdate) (additional []*ValidatorUpdate, err error)

func (*ExecutorV1) LastBlock

func (x *ExecutorV1) LastBlock() (*execute.BlockParams, [32]byte, error)

func (*ExecutorV1) StoreBlockTimers

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

func (*ExecutorV1) Validate

func (x *ExecutorV1) Validate(envelope *messaging.Envelope, recheck bool) ([]*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) Init

func (m *Multi) Init(validators []*ValidatorUpdate) (additional []*ValidatorUpdate, err error)

func (*Multi) LastBlock

func (m *Multi) LastBlock() (*execute.BlockParams, [32]byte, error)

func (*Multi) StoreBlockTimers

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

func (*Multi) Validate

func (m *Multi) Validate(envelope *messaging.Envelope, recheck bool) ([]*protocol.TransactionStatus, error)

type Options

type Options = execute.Options

type ValidatorUpdate

type ValidatorUpdate = execute.ValidatorUpdate