forge_task_ops

package

v0.51.0 Latest Latest Go to latest Published: May 1, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/s4wave/spacewave

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func LookupForgeTaskCreateOp(ctx context.Context, operationTypeID string) (world.Operation, error)
type ForgeTaskCreateOp

Constants ¶

This section is empty.

Variables ¶

View Source

var ForgeTaskCreateOpId = "spacewave/forge/task/create"

ForgeTaskCreateOpId is the operation id for ForgeTaskCreateOp.

Functions ¶

func LookupForgeTaskCreateOp ¶

func LookupForgeTaskCreateOp(ctx context.Context, operationTypeID string) (world.Operation, error)

LookupForgeTaskCreateOp looks up a ForgeTaskCreateOp operation type.

Types ¶

type ForgeTaskCreateOp ¶

type ForgeTaskCreateOp struct {

	// TaskKey is the object key for the new Task.
	TaskKey string `protobuf:"bytes,1,opt,name=task_key,json=taskKey,proto3" json:"taskKey,omitempty"`
	// Name is the task name (must be a valid DNS label).
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// JobKey is the object key of the Job to link the Task to.
	// If empty, the Task is created without a Job link.
	JobKey string `protobuf:"bytes,3,opt,name=job_key,json=jobKey,proto3" json:"jobKey,omitempty"`
	// Timestamp is the creation timestamp.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

ForgeTaskCreateOp creates a Forge Task and optionally links it to a Job. Wraps CreateTaskWithTarget + graph linking in a single world op.

func (*ForgeTaskCreateOp) ApplyWorldObjectOp ¶

func (o *ForgeTaskCreateOp) ApplyWorldObjectOp(
	ctx context.Context,
	le *logrus.Entry,
	os world.ObjectState,
	sender peer.ID,
) (sysErr bool, err error)

ApplyWorldObjectOp applies the operation to a world object handle.

func (*ForgeTaskCreateOp) ApplyWorldOp ¶

func (o *ForgeTaskCreateOp) ApplyWorldOp(
	ctx context.Context,
	le *logrus.Entry,
	ws world.WorldState,
	sender peer.ID,
) (sysErr bool, err error)

ApplyWorldOp applies the operation as a world operation.

func (*ForgeTaskCreateOp) CloneMessageVT ¶

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

func (*ForgeTaskCreateOp) CloneVT ¶

func (m *ForgeTaskCreateOp) CloneVT() *ForgeTaskCreateOp

func (*ForgeTaskCreateOp) EqualMessageVT ¶

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

func (*ForgeTaskCreateOp) EqualVT ¶

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

func (*ForgeTaskCreateOp) GetJobKey ¶

func (x *ForgeTaskCreateOp) GetJobKey() string

func (*ForgeTaskCreateOp) GetName ¶

func (x *ForgeTaskCreateOp) GetName() string

func (*ForgeTaskCreateOp) GetOperationTypeId ¶

func (o *ForgeTaskCreateOp) GetOperationTypeId() string

GetOperationTypeId returns the operation type identifier.

func (*ForgeTaskCreateOp) GetTaskKey ¶

func (x *ForgeTaskCreateOp) GetTaskKey() string

func (*ForgeTaskCreateOp) GetTimestamp ¶

func (x *ForgeTaskCreateOp) GetTimestamp() *timestamppb.Timestamp

func (*ForgeTaskCreateOp) MarshalBlock ¶

func (o *ForgeTaskCreateOp) MarshalBlock() ([]byte, error)

MarshalBlock marshals the block to binary.

func (*ForgeTaskCreateOp) MarshalJSON ¶

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

MarshalJSON marshals the ForgeTaskCreateOp to JSON.

func (*ForgeTaskCreateOp) MarshalProtoJSON ¶

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

MarshalProtoJSON marshals the ForgeTaskCreateOp message to JSON.

func (*ForgeTaskCreateOp) MarshalProtoText ¶

func (x *ForgeTaskCreateOp) MarshalProtoText() string

func (*ForgeTaskCreateOp) MarshalToSizedBufferVT ¶

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

func (*ForgeTaskCreateOp) MarshalToVT ¶

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

func (*ForgeTaskCreateOp) MarshalVT ¶

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

func (*ForgeTaskCreateOp) ProtoMessage ¶

func (*ForgeTaskCreateOp) ProtoMessage()

func (*ForgeTaskCreateOp) Reset ¶

func (x *ForgeTaskCreateOp) Reset()

func (*ForgeTaskCreateOp) SizeVT ¶

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

func (*ForgeTaskCreateOp) String ¶

func (x *ForgeTaskCreateOp) String() string

func (*ForgeTaskCreateOp) UnmarshalBlock ¶

func (o *ForgeTaskCreateOp) UnmarshalBlock(data []byte) error

UnmarshalBlock unmarshals the block to the object.

func (*ForgeTaskCreateOp) UnmarshalJSON ¶

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

UnmarshalJSON unmarshals the ForgeTaskCreateOp from JSON.

func (*ForgeTaskCreateOp) UnmarshalProtoJSON ¶

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

UnmarshalProtoJSON unmarshals the ForgeTaskCreateOp message from JSON.

func (*ForgeTaskCreateOp) UnmarshalVT ¶

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

func (*ForgeTaskCreateOp) Validate ¶

func (o *ForgeTaskCreateOp) Validate() error

Validate performs cursory validation of the operation.

Source Files ¶

View all Source files

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