task_tx

package
v0.57.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 31, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TxType_name = map[int32]string{
		0: "TxType_INVALID",
		1: "TxType_UPDATE_INPUTS",
		2: "TxType_START",
		3: "TxType_UPDATE_WITH_PASS_STATE",
		4: "TxType_COMPLETE",
		5: "TxType_RETRY",
	}
	TxType_value = map[string]int32{
		"TxType_INVALID":                0,
		"TxType_UPDATE_INPUTS":          1,
		"TxType_START":                  2,
		"TxType_UPDATE_WITH_PASS_STATE": 3,
		"TxType_COMPLETE":               4,
		"TxType_RETRY":                  5,
	}
)

Enum value maps for TxType.

View Source 
var WorldOperationTypeID = "forge/task/tx"

WorldOperationTypeID is the transaction object operation type id. Corresponds to a single *TransactionData object.

Functions

func LookupWorldOp 

func LookupWorldOp(ctx context.Context, opTypeID string) (world.Operation, error)

LookupWorldOp performs the lookup operation for the Task op types.

Types

type Transaction 

type Transaction interface {
	// MarshalVT marshals to binary.
	MarshalVT() ([]byte, error)
	// UnmarshalVT unmarshals from binary.
	UnmarshalVT(data []byte) error

	// GetTxType returns the type of transaction this is.
	GetTxType() TxType
	// Validate performs a cursory check of the transaction.
	// Note: this should not fetch network data.
	Validate() error
	// ExecuteTx executes the transaction against the task instance.
	// bcs is located at the task state root.
	// The result is written into bcs.
	ExecuteTx(
		ctx context.Context,
		worldState world.WorldState,
		sender peer.ID,
		objKey string,
		bcs *block.Cursor,
		root *forge_task.Task,
	) error
}

Transaction is an instance of a transaction object.

func NewTxCompleteTxn 

func NewTxCompleteTxn() Transaction

NewTxCompleteTxn constructs the COMPLETE transaction.

func NewTxRetryTxn added in v0.57.0 

func NewTxRetryTxn() Transaction

NewTxRetryTxn constructs a new RETRY transaction.

func NewTxStartTxn 

func NewTxStartTxn() Transaction

NewTxStartTxn constructs a new START transaction.

func NewTxUpdateInputsTxn 

func NewTxUpdateInputsTxn() Transaction

NewTxUpdateInputsTxn constructs a new UPDATE_INPUTS transaction.

func NewTxUpdateWithPassStateTxn 

func NewTxUpdateWithPassStateTxn() Transaction

NewTxUpdateWithPassStateTxn constructs a new UPDATE_WITH_PASS_STATE transaction.

type Tx 

type Tx struct {

	// TxType is the kind of transaction this is.
	TxType TxType `protobuf:"varint,1,opt,name=tx_type,json=txType,proto3" json:"txType,omitempty"`
	// TaskObjectKey is the Task object ID this is associated with.
	// The Task object must already exist.
	TaskObjectKey string `protobuf:"bytes,2,opt,name=task_object_key,json=taskObjectKey,proto3" json:"taskObjectKey,omitempty"`
	// TxUpdateInputs updates the Task with the latest Target and Inputs.
	// TxType_UPDATE_INPUTS
	TxUpdateInputs *TxUpdateInputs `protobuf:"bytes,3,opt,name=tx_update_inputs,json=txUpdateInputs,proto3" json:"txUpdateInputs,omitempty"`
	// TxStart contains the start transaction tx.
	// TxType_START
	TxStart *TxStart `protobuf:"bytes,4,opt,name=tx_start,json=txStart,proto3" json:"txStart,omitempty"`
	// TxUpdatePassState contains the update pass state tx.
	// TxType_UPDATE_WITH_PASS_STATE
	TxUpdateWithPassState *TxUpdateWithPassState `` /* 126-byte string literal not displayed */
	// TxComplete contains the complete tx.
	// TxType_COMPLETE
	TxComplete *TxComplete `protobuf:"bytes,6,opt,name=tx_complete,json=txComplete,proto3" json:"txComplete,omitempty"`
	// TxRetry contains the explicit retry transaction.
	// TxType_RETRY
	TxRetry *TxRetry `protobuf:"bytes,7,opt,name=tx_retry,json=txRetry,proto3" json:"txRetry,omitempty"`
	// contains filtered or unexported fields
}

Tx is the on-the-wire representation of a transaction.

func ByteSliceToTx 

func ByteSliceToTx(blk block.Block) (*Tx, error)

ByteSliceToTx converts a byte slice block a Tx. If blk is nil, returns nil, nil If the blk is already parsed to a MockWorldOp, returns the MockWorldOp.

func NewTxComplete 

func NewTxComplete(objKey string, result *forge_value.Result) *Tx

NewTxComplete constructs the COMPLETE transaction.

func NewTxRetry added in v0.57.0 

func NewTxRetry(objKey string, expectedPassNonce uint64, nextInputs *forge_target.ValueSet) *Tx

NewTxRetry constructs a RETRY transaction for a failed Pass.

func NewTxStart 

func NewTxStart(objKey string, assignSelf bool) *Tx

NewTxStart constructs a new START transaction.

func NewTxUpdateInputs 

func NewTxUpdateInputs(objKey string) *Tx

NewTxUpdateInputs constructs a new UPDATE_INPUTS transaction.

func NewTxUpdateWithPassState 

func NewTxUpdateWithPassState(objKey string) *Tx

NewTxUpdateWithPassState constructs a new UPDATE_WITH_PASS_STATE transaction.

func (*Tx) ApplyWorldObjectOp 

func (t *Tx) ApplyWorldObjectOp(ctx context.Context, le *logrus.Entry, objectHandle world.ObjectState, sender peer.ID) (sysErr bool, err error)

ApplyWorldObjectOp applies the operation to a world object handle.

func (*Tx) ApplyWorldOp 

func (t *Tx) ApplyWorldOp(
	ctx context.Context,
	le *logrus.Entry,
	worldHandle world.WorldState,
	sender peer.ID,
) (sysErr bool, err error)

ApplyWorldOp applies the operation as a world operation.

func (*Tx) CloneMessageVT 

func (m *Tx) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*Tx) CloneVT 

func (m *Tx) CloneVT() *Tx

func (*Tx) EqualMessageVT 

func (this *Tx) EqualMessageVT(thatMsg any) bool

func (*Tx) EqualVT 

func (this *Tx) EqualVT(that *Tx) bool

func (*Tx) GetOperationTypeId 

func (t *Tx) GetOperationTypeId() string

GetOperationTypeId returns the operation type identifier.

func (*Tx) GetTaskObjectKey 

func (x *Tx) GetTaskObjectKey() string

func (*Tx) GetTxComplete 

func (x *Tx) GetTxComplete() *TxComplete

func (*Tx) GetTxRetry added in v0.57.0 

func (x *Tx) GetTxRetry() *TxRetry

func (*Tx) GetTxStart 

func (x *Tx) GetTxStart() *TxStart

func (*Tx) GetTxType 

func (x *Tx) GetTxType() TxType

func (*Tx) GetTxUpdateInputs 

func (x *Tx) GetTxUpdateInputs() *TxUpdateInputs

func (*Tx) GetTxUpdateWithPassState 

func (x *Tx) GetTxUpdateWithPassState() *TxUpdateWithPassState

func (*Tx) LocateTx 

func (t *Tx) LocateTx() (Transaction, error)

LocateTx returns the sub-block for the transaction.

func (*Tx) MarshalBlock 

func (t *Tx) MarshalBlock() ([]byte, error)

MarshalBlock marshals the block to binary. This is the initial step of marshaling, before transformations.

func (*Tx) MarshalJSON 

func (x *Tx) MarshalJSON() ([]byte, error)

MarshalJSON marshals the Tx to JSON.

func (*Tx) MarshalProtoJSON 

func (x *Tx) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the Tx message to JSON.

func (*Tx) MarshalProtoText 

func (x *Tx) MarshalProtoText() string

func (*Tx) MarshalToSizedBufferVT 

func (m *Tx) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Tx) MarshalToVT 

func (m *Tx) MarshalToVT(dAtA []byte) (int, error)

func (*Tx) MarshalVT 

func (m *Tx) MarshalVT() (dAtA []byte, err error)

func (*Tx) ProtoMessage 

func (*Tx) ProtoMessage()

func (*Tx) Reset 

func (x *Tx) Reset()

func (*Tx) SizeVT 

func (m *Tx) SizeVT() (n int)

func (*Tx) String 

func (x *Tx) String() string

func (*Tx) UnmarshalBlock 

func (t *Tx) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the block to the object. This is the final step of decoding, after transformations.

func (*Tx) UnmarshalJSON 

func (x *Tx) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the Tx from JSON.

func (*Tx) UnmarshalProtoJSON 

func (x *Tx) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the Tx message from JSON.

func (*Tx) UnmarshalVT 

func (m *Tx) UnmarshalVT(dAtA []byte) error

func (*Tx) Validate 

func (t *Tx) Validate() error

Validate checks the transaction (cursory checks only)

type TxComplete 

type TxComplete struct {

	// Result is information about the outcome of a completed pass.
	Result *value.Result `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// ValueSet is the set of outputs from the task.
	// Inputs must be empty.
	// Must match the outputs calculated from the Pass and Execution objects.
	// Must be empty if the result is not success.
	ValueSet *target.ValueSet `protobuf:"bytes,2,opt,name=value_set,json=valueSet,proto3" json:"valueSet,omitempty"`
	// contains filtered or unexported fields
}

TxComplete completes the execution by setting the result. If failed, may transition from any state. If success, must be in the CHECKING state. If success, the most recent Pass must be in COMPLETE state and not failed. TxType: TxType_COMPLETE

func (*TxComplete) CloneMessageVT 

func (m *TxComplete) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*TxComplete) CloneVT 

func (m *TxComplete) CloneVT() *TxComplete

func (*TxComplete) EqualMessageVT 

func (this *TxComplete) EqualMessageVT(thatMsg any) bool

func (*TxComplete) EqualVT 

func (this *TxComplete) EqualVT(that *TxComplete) bool

func (*TxComplete) ExecuteTx 

func (t *TxComplete) ExecuteTx(
	ctx context.Context,
	worldState world.WorldState,
	sender peer.ID,
	objKey string,
	bcs *block.Cursor,
	root *forge_task.Task,
) error

ExecuteTx executes the transaction against the Task instance.

func (*TxComplete) GetResult 

func (x *TxComplete) GetResult() *value.Result

func (*TxComplete) GetTxType 

func (t *TxComplete) GetTxType() TxType

GetTxType returns the type of transaction this is.

func (*TxComplete) GetValueSet 

func (x *TxComplete) GetValueSet() *target.ValueSet

func (*TxComplete) MarshalJSON 

func (x *TxComplete) MarshalJSON() ([]byte, error)

MarshalJSON marshals the TxComplete to JSON.

func (*TxComplete) MarshalProtoJSON 

func (x *TxComplete) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the TxComplete message to JSON.

func (*TxComplete) MarshalProtoText 

func (x *TxComplete) MarshalProtoText() string

func (*TxComplete) MarshalToSizedBufferVT 

func (m *TxComplete) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TxComplete) MarshalToVT 

func (m *TxComplete) MarshalToVT(dAtA []byte) (int, error)

func (*TxComplete) MarshalVT 

func (m *TxComplete) MarshalVT() (dAtA []byte, err error)

func (*TxComplete) ProtoMessage 

func (*TxComplete) ProtoMessage()

func (*TxComplete) Reset 

func (x *TxComplete) Reset()

func (*TxComplete) SizeVT 

func (m *TxComplete) SizeVT() (n int)

func (*TxComplete) String 

func (x *TxComplete) String() string

func (*TxComplete) UnmarshalJSON 

func (x *TxComplete) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the TxComplete from JSON.

func (*TxComplete) UnmarshalProtoJSON 

func (x *TxComplete) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the TxComplete message from JSON.

func (*TxComplete) UnmarshalVT 

func (m *TxComplete) UnmarshalVT(dAtA []byte) error

func (*TxComplete) Validate 

func (t *TxComplete) Validate() error

Validate performs a cursory check of the transaction. Note: this should not fetch network data.

type TxRetry added in v0.57.0 

type TxRetry struct {

	// ExpectedPassNonce identifies the failed Pass being retried.
	ExpectedPassNonce uint64 `protobuf:"varint,1,opt,name=expected_pass_nonce,json=expectedPassNonce,proto3" json:"expectedPassNonce,omitempty"`
	// NextInputs contains the named inputs for the successor Pass.
	// Outputs must be empty.
	NextInputs *target.ValueSet `protobuf:"bytes,2,opt,name=next_inputs,json=nextInputs,proto3" json:"nextInputs,omitempty"`
	// contains filtered or unexported fields
}

TxRetry authorizes a successor Pass after a terminal failed Pass. The scheduler supplies the named inputs for the successor.

func (*TxRetry) CloneMessageVT added in v0.57.0 

func (m *TxRetry) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*TxRetry) CloneVT added in v0.57.0 

func (m *TxRetry) CloneVT() *TxRetry

func (*TxRetry) EqualMessageVT added in v0.57.0 

func (this *TxRetry) EqualMessageVT(thatMsg any) bool

func (*TxRetry) EqualVT added in v0.57.0 

func (this *TxRetry) EqualVT(that *TxRetry) bool

func (*TxRetry) ExecuteTx added in v0.57.0 

func (t *TxRetry) ExecuteTx(
	ctx context.Context,
	worldState world.WorldState,
	sender peer.ID,
	objKey string,
	bcs *block.Cursor,
	root *forge_task.Task,
) error

ExecuteTx executes the transaction against the Task instance.

func (*TxRetry) GetExpectedPassNonce added in v0.57.0 

func (x *TxRetry) GetExpectedPassNonce() uint64

func (*TxRetry) GetNextInputs added in v0.57.0 

func (x *TxRetry) GetNextInputs() *target.ValueSet

func (*TxRetry) GetTxType added in v0.57.0 

func (t *TxRetry) GetTxType() TxType

GetTxType returns the type of transaction this is.

func (*TxRetry) MarshalJSON added in v0.57.0 

func (x *TxRetry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the TxRetry to JSON.

func (*TxRetry) MarshalProtoJSON added in v0.57.0 

func (x *TxRetry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the TxRetry message to JSON.

func (*TxRetry) MarshalProtoText added in v0.57.0 

func (x *TxRetry) MarshalProtoText() string

func (*TxRetry) MarshalToSizedBufferVT added in v0.57.0 

func (m *TxRetry) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TxRetry) MarshalToVT added in v0.57.0 

func (m *TxRetry) MarshalToVT(dAtA []byte) (int, error)

func (*TxRetry) MarshalVT added in v0.57.0 

func (m *TxRetry) MarshalVT() (dAtA []byte, err error)

func (*TxRetry) ProtoMessage added in v0.57.0 

func (*TxRetry) ProtoMessage()

func (*TxRetry) Reset added in v0.57.0 

func (x *TxRetry) Reset()

func (*TxRetry) SizeVT added in v0.57.0 

func (m *TxRetry) SizeVT() (n int)

func (*TxRetry) String added in v0.57.0 

func (x *TxRetry) String() string

func (*TxRetry) UnmarshalJSON added in v0.57.0 

func (x *TxRetry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the TxRetry from JSON.

func (*TxRetry) UnmarshalProtoJSON added in v0.57.0 

func (x *TxRetry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the TxRetry message from JSON.

func (*TxRetry) UnmarshalVT added in v0.57.0 

func (m *TxRetry) UnmarshalVT(dAtA []byte) error

func (*TxRetry) Validate added in v0.57.0 

func (t *TxRetry) Validate() error

Validate performs a cursory check of the transaction. Note: this should not fetch network data.

type TxStart 

type TxStart struct {

	// AssignSelf assigns the sender of the tx to the new Pass.
	AssignSelf bool `protobuf:"varint,1,opt,name=assign_self,json=assignSelf,proto3" json:"assignSelf,omitempty"`
	// contains filtered or unexported fields
}

TxStart starts a Task by creating a Pass. Transitions PENDING to RUNNING only after every predecessor Pass is complete. Requests cancellation without creating a successor while a predecessor lives.

TxType: TxType_START

func (*TxStart) CloneMessageVT 

func (m *TxStart) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*TxStart) CloneVT 

func (m *TxStart) CloneVT() *TxStart

func (*TxStart) EqualMessageVT 

func (this *TxStart) EqualMessageVT(thatMsg any) bool

func (*TxStart) EqualVT 

func (this *TxStart) EqualVT(that *TxStart) bool

func (*TxStart) ExecuteTx 

func (t *TxStart) ExecuteTx(
	ctx context.Context,
	worldState world.WorldState,
	sender peer.ID,
	objKey string,
	bcs *block.Cursor,
	root *forge_task.Task,
) error

ExecuteTx executes the transaction against the pass instance.

func (*TxStart) GetAssignSelf 

func (x *TxStart) GetAssignSelf() bool

func (*TxStart) GetTxType 

func (t *TxStart) GetTxType() TxType

GetTxType returns the type of transaction this is.

func (*TxStart) MarshalJSON 

func (x *TxStart) MarshalJSON() ([]byte, error)

MarshalJSON marshals the TxStart to JSON.

func (*TxStart) MarshalProtoJSON 

func (x *TxStart) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the TxStart message to JSON.

func (*TxStart) MarshalProtoText 

func (x *TxStart) MarshalProtoText() string

func (*TxStart) MarshalToSizedBufferVT 

func (m *TxStart) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TxStart) MarshalToVT 

func (m *TxStart) MarshalToVT(dAtA []byte) (int, error)

func (*TxStart) MarshalVT 

func (m *TxStart) MarshalVT() (dAtA []byte, err error)

func (*TxStart) ProtoMessage 

func (*TxStart) ProtoMessage()

func (*TxStart) Reset 

func (x *TxStart) Reset()

func (*TxStart) SizeVT 

func (m *TxStart) SizeVT() (n int)

func (*TxStart) String 

func (x *TxStart) String() string

func (*TxStart) UnmarshalJSON 

func (x *TxStart) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the TxStart from JSON.

func (*TxStart) UnmarshalProtoJSON 

func (x *TxStart) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the TxStart message from JSON.

func (*TxStart) UnmarshalVT 

func (m *TxStart) UnmarshalVT(dAtA []byte) error

func (*TxStart) Validate 

func (t *TxStart) Validate() error

Validate performs a cursory check of the transaction. Note: this should not fetch network data.

type TxType 

type TxType int32

TxType indicates the kind of transaction. 

const (
	TxType_TxType_INVALID TxType = 0
	// TxType_UPDATE_INPUTS updates the ValueSet inputs and target.
	// If changed outside a live Pass, transitions to PENDING.
	// If a Pass is live, requests cancellation and stays RUNNING until drain.
	TxType_TxType_UPDATE_INPUTS TxType = 1
	// TxType_START starts the Task when every predecessor Pass is complete.
	// Transitions PENDING to RUNNING and creates the next Pass.
	TxType_TxType_START TxType = 2
	// TxType_UPDATE_WITH_PASS_STATE updates the Task from the current Pass.
	// Canceled completion transitions to PENDING; other completion to CHECKING.
	// A nonterminal Pass leaves the Task state unchanged.
	TxType_TxType_UPDATE_WITH_PASS_STATE TxType = 3
	// TxType_COMPLETE sets the result of the Task.
	// If failed, can transition from any state.
	// If success, must transition from CHECKING state.
	// If success, all Execution states must be Successful.
	TxType_TxType_COMPLETE TxType = 4
	// TxType_RETRY authorizes one successor Pass for a failed predecessor.
	// The expected pass nonce is the idempotency fence.
	TxType_TxType_RETRY TxType = 5
)

func (TxType) Enum 

func (x TxType) Enum() *TxType

func (TxType) MarshalJSON 

func (x TxType) MarshalJSON() ([]byte, error)

MarshalJSON marshals the TxType to JSON.

func (TxType) MarshalProtoJSON 

func (x TxType) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the TxType to JSON.

func (TxType) MarshalProtoText 

func (x TxType) MarshalProtoText() string

func (TxType) MarshalText 

func (x TxType) MarshalText() ([]byte, error)

MarshalText marshals the TxType to text.

func (TxType) String 

func (x TxType) String() string

func (*TxType) UnmarshalJSON 

func (x *TxType) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the TxType from JSON.

func (*TxType) UnmarshalProtoJSON 

func (x *TxType) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the TxType from JSON.

func (*TxType) UnmarshalText 

func (x *TxType) UnmarshalText(b []byte) error

UnmarshalText unmarshals the TxType from text.

func (TxType) Validate 

func (t TxType) Validate() error

Validate checks the execution tx type is in range.

type TxUpdateInputs 

type TxUpdateInputs struct {

	// UpdateTarget indicates to update the TargetRef if necessary.
	UpdateTarget bool `protobuf:"varint,1,opt,name=update_target,json=updateTarget,proto3" json:"updateTarget,omitempty"`
	// ResetInputs indicates to clear the existing inputs before setting.
	ResetInputs bool `protobuf:"varint,2,opt,name=reset_inputs,json=resetInputs,proto3" json:"resetInputs,omitempty"`
	// ValueSet is the set of inputs to set for the task.
	// Outputs must be empty.
	// Any Value with Type=UNKNOWN (0) will be deleted.
	ValueSet *target.ValueSet `protobuf:"bytes,3,opt,name=value_set,json=valueSet,proto3" json:"valueSet,omitempty"`
	// contains filtered or unexported fields
}

TxUpdateInputs updates the Task with the latest Target and Inputs. If changed outside a live Pass, transitions to PENDING. If a Pass is live, requests cancellation and stays RUNNING until drain.

TxType: TxType_UPDATE_INPUTS

func (*TxUpdateInputs) CloneMessageVT 

func (m *TxUpdateInputs) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*TxUpdateInputs) CloneVT 

func (m *TxUpdateInputs) CloneVT() *TxUpdateInputs

func (*TxUpdateInputs) EqualMessageVT 

func (this *TxUpdateInputs) EqualMessageVT(thatMsg any) bool

func (*TxUpdateInputs) EqualVT 

func (this *TxUpdateInputs) EqualVT(that *TxUpdateInputs) bool

func (*TxUpdateInputs) ExecuteTx 

func (t *TxUpdateInputs) ExecuteTx(
	ctx context.Context,
	worldState world.WorldState,
	sender peer.ID,
	objKey string,
	bcs *block.Cursor,
	root *forge_task.Task,
) error

ExecuteTx executes the transaction against the Task instance.

func (*TxUpdateInputs) GetResetInputs 

func (x *TxUpdateInputs) GetResetInputs() bool

func (*TxUpdateInputs) GetTxType 

func (t *TxUpdateInputs) GetTxType() TxType

GetTxType returns the type of transaction this is.

func (*TxUpdateInputs) GetUpdateTarget 

func (x *TxUpdateInputs) GetUpdateTarget() bool

func (*TxUpdateInputs) GetValueSet 

func (x *TxUpdateInputs) GetValueSet() *target.ValueSet

func (*TxUpdateInputs) MarshalJSON 

func (x *TxUpdateInputs) MarshalJSON() ([]byte, error)

MarshalJSON marshals the TxUpdateInputs to JSON.

func (*TxUpdateInputs) MarshalProtoJSON 

func (x *TxUpdateInputs) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the TxUpdateInputs message to JSON.

func (*TxUpdateInputs) MarshalProtoText 

func (x *TxUpdateInputs) MarshalProtoText() string

func (*TxUpdateInputs) MarshalToSizedBufferVT 

func (m *TxUpdateInputs) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TxUpdateInputs) MarshalToVT 

func (m *TxUpdateInputs) MarshalToVT(dAtA []byte) (int, error)

func (*TxUpdateInputs) MarshalVT 

func (m *TxUpdateInputs) MarshalVT() (dAtA []byte, err error)

func (*TxUpdateInputs) ProtoMessage 

func (*TxUpdateInputs) ProtoMessage()

func (*TxUpdateInputs) Reset 

func (x *TxUpdateInputs) Reset()

func (*TxUpdateInputs) SizeVT 

func (m *TxUpdateInputs) SizeVT() (n int)

func (*TxUpdateInputs) String 

func (x *TxUpdateInputs) String() string

func (*TxUpdateInputs) UnmarshalJSON 

func (x *TxUpdateInputs) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the TxUpdateInputs from JSON.

func (*TxUpdateInputs) UnmarshalProtoJSON 

func (x *TxUpdateInputs) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the TxUpdateInputs message from JSON.

func (*TxUpdateInputs) UnmarshalVT 

func (m *TxUpdateInputs) UnmarshalVT(dAtA []byte) error

func (*TxUpdateInputs) Validate 

func (t *TxUpdateInputs) Validate() error

Validate performs a cursory check of the transaction. Note: this should not fetch network data.

type TxUpdateWithPassState 

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

TxUpdateWithPassState updates the Task from the current Pass. Canceled completion transitions to PENDING; other completion to CHECKING. A nonterminal Pass leaves the Task state unchanged. TxType: TxType_UPDATE_WITH_PASS_STATE

func (*TxUpdateWithPassState) CloneMessageVT 

func (m *TxUpdateWithPassState) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*TxUpdateWithPassState) CloneVT 

func (m *TxUpdateWithPassState) CloneVT() *TxUpdateWithPassState

func (*TxUpdateWithPassState) EqualMessageVT 

func (this *TxUpdateWithPassState) EqualMessageVT(thatMsg any) bool

func (*TxUpdateWithPassState) EqualVT 

func (this *TxUpdateWithPassState) EqualVT(that *TxUpdateWithPassState) bool

func (*TxUpdateWithPassState) ExecuteTx 

func (t *TxUpdateWithPassState) ExecuteTx(
	ctx context.Context,
	worldState world.WorldState,
	sender peer.ID,
	objKey string,
	bcs *block.Cursor,
	root *forge_task.Task,
) error

ExecuteTx executes the transaction against the Task instance.

func (*TxUpdateWithPassState) GetTxType 

func (t *TxUpdateWithPassState) GetTxType() TxType

GetTxType returns the type of transaction this is.

func (*TxUpdateWithPassState) MarshalJSON 

func (x *TxUpdateWithPassState) MarshalJSON() ([]byte, error)

MarshalJSON marshals the TxUpdateWithPassState to JSON.

func (*TxUpdateWithPassState) MarshalProtoJSON 

func (x *TxUpdateWithPassState) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the TxUpdateWithPassState message to JSON.

func (*TxUpdateWithPassState) MarshalProtoText 

func (x *TxUpdateWithPassState) MarshalProtoText() string

func (*TxUpdateWithPassState) MarshalToSizedBufferVT 

func (m *TxUpdateWithPassState) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TxUpdateWithPassState) MarshalToVT 

func (m *TxUpdateWithPassState) MarshalToVT(dAtA []byte) (int, error)

func (*TxUpdateWithPassState) MarshalVT 

func (m *TxUpdateWithPassState) MarshalVT() (dAtA []byte, err error)

func (*TxUpdateWithPassState) ProtoMessage 

func (*TxUpdateWithPassState) ProtoMessage()

func (*TxUpdateWithPassState) Reset 

func (x *TxUpdateWithPassState) Reset()

func (*TxUpdateWithPassState) SizeVT 

func (m *TxUpdateWithPassState) SizeVT() (n int)

func (*TxUpdateWithPassState) String 

func (x *TxUpdateWithPassState) String() string

func (*TxUpdateWithPassState) UnmarshalJSON 

func (x *TxUpdateWithPassState) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the TxUpdateWithPassState from JSON.

func (*TxUpdateWithPassState) UnmarshalProtoJSON 

func (x *TxUpdateWithPassState) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the TxUpdateWithPassState message from JSON.

func (*TxUpdateWithPassState) UnmarshalVT 

func (m *TxUpdateWithPassState) UnmarshalVT(dAtA []byte) error

func (*TxUpdateWithPassState) Validate 

func (t *TxUpdateWithPassState) Validate() error

Validate performs a cursory check of the transaction. Note: this should not fetch network data.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.