Documentation ¶
Overview ¶
Package commitment defines a roothash commitment.
Index ¶
Constants ¶
const ( // TimeoutNever is the timeout value that never expires. TimeoutNever = 0 // LogEventDiscrepancyMajorityFailure is a log event value that dependency resoluton with majority failure. LogEventDiscrepancyMajorityFailure = "pool/discrepancy_majority_failure" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ComputeBody ¶
type ComputeBody struct { Header ComputeResultsHeader `json:"header"` Failure ExecutorCommitmentFailure `json:"failure,omitempty"` TxnSchedSig signature.Signature `json:"txn_sched_sig"` InputRoot hash.Hash `json:"input_root"` InputStorageSigs []signature.Signature `json:"input_storage_sigs"` StorageSignatures []signature.Signature `json:"storage_signatures,omitempty"` RakSig *signature.RawSignature `json:"rak_sig,omitempty"` Messages []message.Message `json:"messages,omitempty"` }
ComputeBody holds the data signed in a compute worker commitment.
type ComputeResultsHeader ¶
type ComputeResultsHeader struct { Round uint64 `json:"round"` PreviousHash hash.Hash `json:"previous_hash"` IORoot *hash.Hash `json:"io_root,omitempty"` StateRoot *hash.Hash `json:"state_root,omitempty"` MessagesHash *hash.Hash `json:"messages_hash,omitempty"` }
ComputeResultsHeader is the header of a computed batch output by a runtime. This header is a compressed representation (e.g., hashes instead of full content) of the actual results.
These headers are signed by RAK inside the runtime and included in executor commitments.
Keep the roothash RAK validation in sync with changes to this structure.
type ExecutorCommitment ¶
ExecutorCommitment is a roothash commitment from an executor worker.
The signed content is ComputeBody.
type ExecutorCommitmentFailure ¶
type ExecutorCommitmentFailure uint8
ExecutorCommitmentFailure is the executor commitment failure reason.
const ( // FailureNone indicates that no failure has occurred. FailureNone ExecutorCommitmentFailure = 0 // FailureUnknown indicates a generic failure. FailureUnknown ExecutorCommitmentFailure = 1 // storage being unavailable. FailureStorageUnavailable ExecutorCommitmentFailure = 2 )
type MessageValidator ¶
MessageValidator is an arbitrary function that validates messages for validity. It can be used for gas accounting.
type OpenExecutorCommitment ¶
type OpenExecutorCommitment struct { ExecutorCommitment Body *ComputeBody `json:"-"` // No need to serialize as it can be reconstructed. }
OpenExecutorCommitment is an executor commitment that has been verified and deserialized.
The open commitment still contains the original signed commitment.
func (*OpenExecutorCommitment) UnmarshalCBOR ¶
func (c *OpenExecutorCommitment) UnmarshalCBOR(data []byte) error
UnmarshalCBOR handles CBOR unmarshalling from passed data.
type Pool ¶
type Pool struct { // Runtime is the runtime descriptor this pool is collecting the // commitments for. Runtime *registry.Runtime `json:"runtime"` // Committee is the committee this pool is collecting the commitments for. Committee *scheduler.Committee `json:"committee"` // Round is the current protocol round. Round uint64 `json:"round"` // ExecuteCommitments are the commitments in the pool iff Committee.Kind // is scheduler.KindComputeExecutor. ExecuteCommitments map[signature.PublicKey]OpenExecutorCommitment `json:"execute_commitments,omitempty"` // Discrepancy is a flag signalling that a discrepancy has been detected. Discrepancy bool `json:"discrepancy"` // NextTimeout is the time when the next call to TryFinalize(true) should // be scheduled to be executed. Zero means that no timeout is to be scheduled. NextTimeout int64 `json:"next_timeout"` // contains filtered or unexported fields }
Pool is a serializable pool of commitments that can be used to perform discrepancy detection.
The pool is not safe for concurrent use.
type ProposedBatch ¶
type ProposedBatch struct { // IORoot is the I/O root containing the inputs (transactions) that // the executor node should use. IORoot hash.Hash `json:"io_root"` // StorageSignatures are the storage receipt signatures for the I/O root. StorageSignatures []signature.Signature `json:"storage_signatures"` // Header is the block header on which the batch should be based. Header block.Header `json:"header"` }
ProposedBatch is the message sent from the transaction scheduler to executor workers after a batch is ready to be executed.
Don't forget to bump CommitteeProtocol version in go/common/version if you change anything in this struct.
type SignedProposedBatch ¶
SignedProposedBatch is a ProposedBatch, signed by the transaction scheduler.