runtimev1

type AcknowledgeCancellationRequest struct {
	Identity               *AttemptIdentity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	ExpectedAttemptVersion int64            `` /* 130-byte string literal not displayed */
	IdempotencyKey         string           `protobuf:"bytes,3,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

type AcknowledgeCancellationResponse struct {
	AttemptVersion int64 `protobuf:"varint,1,opt,name=attempt_version,json=attemptVersion,proto3" json:"attempt_version,omitempty"`
	RunVersion     int64 `protobuf:"varint,2,opt,name=run_version,json=runVersion,proto3" json:"run_version,omitempty"`
	TaskVersion    int64 `protobuf:"varint,3,opt,name=task_version,json=taskVersion,proto3" json:"task_version,omitempty"`
	// contains filtered or unexported fields
}

type ArtifactReference struct {
	Uri       string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Sha256    string `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	SizeBytes int64  `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	MediaType string `protobuf:"bytes,4,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
	// contains filtered or unexported fields
}

type Assignment struct {
	Identity             *AttemptIdentity       `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	RunId                string                 `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskId               string                 `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	AgentVersionRef      string                 `protobuf:"bytes,4,opt,name=agent_version_ref,json=agentVersionRef,proto3" json:"agent_version_ref,omitempty"`
	Goal                 string                 `protobuf:"bytes,5,opt,name=goal,proto3" json:"goal,omitempty"`
	WorkloadSpecJson     []byte                 `protobuf:"bytes,6,opt,name=workload_spec_json,json=workloadSpecJson,proto3" json:"workload_spec_json,omitempty"`
	RuntimeClass         string                 `protobuf:"bytes,7,opt,name=runtime_class,json=runtimeClass,proto3" json:"runtime_class,omitempty"`
	RuntimePoolId        string                 `protobuf:"bytes,8,opt,name=runtime_pool_id,json=runtimePoolId,proto3" json:"runtime_pool_id,omitempty"`
	RuntimeInstanceId    string                 `protobuf:"bytes,9,opt,name=runtime_instance_id,json=runtimeInstanceId,proto3" json:"runtime_instance_id,omitempty"`
	AttemptVersion       int64                  `protobuf:"varint,10,opt,name=attempt_version,json=attemptVersion,proto3" json:"attempt_version,omitempty"`
	LeaseVersion         int64                  `protobuf:"varint,11,opt,name=lease_version,json=leaseVersion,proto3" json:"lease_version,omitempty"`
	LeaseExpiresAt       *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=lease_expires_at,json=leaseExpiresAt,proto3" json:"lease_expires_at,omitempty"`
	ResumeCheckpoint     *CheckpointReference   `protobuf:"bytes,13,opt,name=resume_checkpoint,json=resumeCheckpoint,proto3" json:"resume_checkpoint,omitempty"`
	Phase                string                 `protobuf:"bytes,14,opt,name=phase,proto3" json:"phase,omitempty"`
	ApprovalId           string                 `protobuf:"bytes,15,opt,name=approval_id,json=approvalId,proto3" json:"approval_id,omitempty"`
	AgentVersionSpecJson []byte                 `` /* 126-byte string literal not displayed */
	// workflow lineage of a workflow-originated task (v1.3): "workflow_id/
	// step_name/version", empty for standalone tasks. The adapter injects it
	// into the fenced MCP identity so fenced.task.spawn can extend the run.
	WorkflowLineage string `protobuf:"bytes,17,opt,name=workflow_lineage,json=workflowLineage,proto3" json:"workflow_lineage,omitempty"`
	// contains filtered or unexported fields
}

type AttemptIdentity struct {
	TenantId     string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	AttemptId    string `protobuf:"bytes,2,opt,name=attempt_id,json=attemptId,proto3" json:"attempt_id,omitempty"`
	FencingToken int64  `protobuf:"varint,3,opt,name=fencing_token,json=fencingToken,proto3" json:"fencing_token,omitempty"`
	// contains filtered or unexported fields
}

type AttemptPhase int32

type CheckpointReference struct {
	CheckpointId        string                 `protobuf:"bytes,1,opt,name=checkpoint_id,json=checkpointId,proto3" json:"checkpoint_id,omitempty"`
	AgentVersionRef     string                 `protobuf:"bytes,2,opt,name=agent_version_ref,json=agentVersionRef,proto3" json:"agent_version_ref,omitempty"`
	RuntimeClass        string                 `protobuf:"bytes,3,opt,name=runtime_class,json=runtimeClass,proto3" json:"runtime_class,omitempty"`
	Provider            string                 `protobuf:"bytes,4,opt,name=provider,proto3" json:"provider,omitempty"`
	RuntimeAbi          string                 `protobuf:"bytes,5,opt,name=runtime_abi,json=runtimeAbi,proto3" json:"runtime_abi,omitempty"`
	SchemaVersion       string                 `protobuf:"bytes,6,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	State               *ArtifactReference     `protobuf:"bytes,7,opt,name=state,proto3" json:"state,omitempty"`
	ConfirmedReceiptIds []string               `protobuf:"bytes,8,rep,name=confirmed_receipt_ids,json=confirmedReceiptIds,proto3" json:"confirmed_receipt_ids,omitempty"`
	EnvelopeSha256      string                 `protobuf:"bytes,9,opt,name=envelope_sha256,json=envelopeSha256,proto3" json:"envelope_sha256,omitempty"`
	CreatedAt           *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

type CommitCheckpointRequest struct {
	Identity               *AttemptIdentity   `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	ExpectedAttemptVersion int64              `` /* 130-byte string literal not displayed */
	IdempotencyKey         string             `protobuf:"bytes,3,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	CheckpointId           string             `protobuf:"bytes,4,opt,name=checkpoint_id,json=checkpointId,proto3" json:"checkpoint_id,omitempty"`
	AgentVersionRef        string             `protobuf:"bytes,5,opt,name=agent_version_ref,json=agentVersionRef,proto3" json:"agent_version_ref,omitempty"`
	Provider               string             `protobuf:"bytes,6,opt,name=provider,proto3" json:"provider,omitempty"`
	RuntimeAbi             string             `protobuf:"bytes,7,opt,name=runtime_abi,json=runtimeAbi,proto3" json:"runtime_abi,omitempty"`
	SchemaVersion          string             `protobuf:"bytes,8,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	State                  *ArtifactReference `protobuf:"bytes,9,opt,name=state,proto3" json:"state,omitempty"`
	ConfirmedReceiptIds    []string           `protobuf:"bytes,10,rep,name=confirmed_receipt_ids,json=confirmedReceiptIds,proto3" json:"confirmed_receipt_ids,omitempty"`
	// contains filtered or unexported fields
}

type CommitCheckpointResponse struct {
	Checkpoint     *CheckpointReference `protobuf:"bytes,1,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	AttemptVersion int64                `protobuf:"varint,2,opt,name=attempt_version,json=attemptVersion,proto3" json:"attempt_version,omitempty"`
	// contains filtered or unexported fields
}

type CompleteAttemptRequest struct {
	Identity               *AttemptIdentity   `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	ExpectedAttemptVersion int64              `` /* 130-byte string literal not displayed */
	IdempotencyKey         string             `protobuf:"bytes,3,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	Result                 *ArtifactReference `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type CompleteAttemptResponse struct {
	AttemptVersion int64  `protobuf:"varint,1,opt,name=attempt_version,json=attemptVersion,proto3" json:"attempt_version,omitempty"`
	RunVersion     int64  `protobuf:"varint,2,opt,name=run_version,json=runVersion,proto3" json:"run_version,omitempty"`
	TaskVersion    int64  `protobuf:"varint,3,opt,name=task_version,json=taskVersion,proto3" json:"task_version,omitempty"`
	ResultRef      string `protobuf:"bytes,4,opt,name=result_ref,json=resultRef,proto3" json:"result_ref,omitempty"`
	// contains filtered or unexported fields
}

type GetAssignmentRequest struct {
	Identity *AttemptIdentity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

type GetAssignmentResponse struct {
	Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3" json:"assignment,omitempty"`
	// contains filtered or unexported fields
}

type HeartbeatRequest struct {
	Identity             *AttemptIdentity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	ExpectedLeaseVersion int64            `protobuf:"varint,2,opt,name=expected_lease_version,json=expectedLeaseVersion,proto3" json:"expected_lease_version,omitempty"`
	IdempotencyKey       string           `protobuf:"bytes,3,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	RequestedTtlSeconds  int64            `protobuf:"varint,4,opt,name=requested_ttl_seconds,json=requestedTtlSeconds,proto3" json:"requested_ttl_seconds,omitempty"`
	// contains filtered or unexported fields
}

type HeartbeatResponse struct {
	LeaseVersion    int64                  `protobuf:"varint,1,opt,name=lease_version,json=leaseVersion,proto3" json:"lease_version,omitempty"`
	ExpiresAt       *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	CancelRequested bool                   `protobuf:"varint,3,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	AttemptVersion  int64                  `protobuf:"varint,4,opt,name=attempt_version,json=attemptVersion,proto3" json:"attempt_version,omitempty"`
	// contains filtered or unexported fields
}

type PollAssignmentRequest struct {
	TenantId          string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	RuntimeInstanceId string `protobuf:"bytes,2,opt,name=runtime_instance_id,json=runtimeInstanceId,proto3" json:"runtime_instance_id,omitempty"`
	// contains filtered or unexported fields
}

type PollAssignmentResponse struct {
	Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3" json:"assignment,omitempty"`
	// contains filtered or unexported fields
}

type RuntimeControlServiceClient interface {
	PollAssignment(ctx context.Context, in *PollAssignmentRequest, opts ...grpc.CallOption) (*PollAssignmentResponse, error)
	GetAssignment(ctx context.Context, in *GetAssignmentRequest, opts ...grpc.CallOption) (*GetAssignmentResponse, error)
	TransitionAttempt(ctx context.Context, in *TransitionAttemptRequest, opts ...grpc.CallOption) (*TransitionAttemptResponse, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	CommitCheckpoint(ctx context.Context, in *CommitCheckpointRequest, opts ...grpc.CallOption) (*CommitCheckpointResponse, error)
	CompleteAttempt(ctx context.Context, in *CompleteAttemptRequest, opts ...grpc.CallOption) (*CompleteAttemptResponse, error)
	AcknowledgeCancellation(ctx context.Context, in *AcknowledgeCancellationRequest, opts ...grpc.CallOption) (*AcknowledgeCancellationResponse, error)
}

type RuntimeControlServiceServer interface {
	PollAssignment(context.Context, *PollAssignmentRequest) (*PollAssignmentResponse, error)
	GetAssignment(context.Context, *GetAssignmentRequest) (*GetAssignmentResponse, error)
	TransitionAttempt(context.Context, *TransitionAttemptRequest) (*TransitionAttemptResponse, error)
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	CommitCheckpoint(context.Context, *CommitCheckpointRequest) (*CommitCheckpointResponse, error)
	CompleteAttempt(context.Context, *CompleteAttemptRequest) (*CompleteAttemptResponse, error)
	AcknowledgeCancellation(context.Context, *AcknowledgeCancellationRequest) (*AcknowledgeCancellationResponse, error)
	// contains filtered or unexported methods
}

type SpawnStepRequest struct {

	// Identity is injected by the runtime worker and validated against the
	// current assignment before any workflow mutation is attempted.
	Identity   *AttemptIdentity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	WorkflowId string           `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// parent_step names the step whose task is spawning; its depth bounds the
	// recursion guard.
	ParentStep      string `protobuf:"bytes,3,opt,name=parent_step,json=parentStep,proto3" json:"parent_step,omitempty"`
	Name            string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Goal            string `protobuf:"bytes,5,opt,name=goal,proto3" json:"goal,omitempty"`
	AgentVersionRef string `protobuf:"bytes,6,opt,name=agent_version_ref,json=agentVersionRef,proto3" json:"agent_version_ref,omitempty"`
	// spec_json is the merged task spec of the spawned step.
	SpecJson    string `protobuf:"bytes,7,opt,name=spec_json,json=specJson,proto3" json:"spec_json,omitempty"`
	MaxAttempts int32  `protobuf:"varint,8,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	// idempotency_key fingerprints the spawning tool call; arguments_json
	// completes the spawn key (same call replays the same step).
	IdempotencyKey string `protobuf:"bytes,9,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	ArgumentsJson  string `protobuf:"bytes,10,opt,name=arguments_json,json=argumentsJson,proto3" json:"arguments_json,omitempty"`
	// contains filtered or unexported fields
}

type SpawnStepResponse struct {

	// outcome: "created", "replayed", or a guard denial code
	// (SPAWN_DEPTH_EXCEEDED, SPAWN_DYNAMIC_LIMIT_EXCEEDED, ...).
	Outcome    string `protobuf:"bytes,1,opt,name=outcome,proto3" json:"outcome,omitempty"`
	Message    string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	StepName   string `protobuf:"bytes,3,opt,name=step_name,json=stepName,proto3" json:"step_name,omitempty"`
	SpawnDepth int32  `protobuf:"varint,4,opt,name=spawn_depth,json=spawnDepth,proto3" json:"spawn_depth,omitempty"`
	// contains filtered or unexported fields
}

type TransitionAttemptRequest struct {
	Identity               *AttemptIdentity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	ExpectedAttemptVersion int64            `` /* 130-byte string literal not displayed */
	IdempotencyKey         string           `protobuf:"bytes,3,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	TargetPhase            AttemptPhase     `` /* 131-byte string literal not displayed */
	FailureCode            string           `protobuf:"bytes,5,opt,name=failure_code,json=failureCode,proto3" json:"failure_code,omitempty"`
	FailureMessage         string           `protobuf:"bytes,6,opt,name=failure_message,json=failureMessage,proto3" json:"failure_message,omitempty"`
	// contains filtered or unexported fields
}

type TransitionAttemptResponse struct {
	Phase          AttemptPhase `protobuf:"varint,1,opt,name=phase,proto3,enum=fenced.runtime.v1.AttemptPhase" json:"phase,omitempty"`
	AttemptVersion int64        `protobuf:"varint,2,opt,name=attempt_version,json=attemptVersion,proto3" json:"attempt_version,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedRuntimeControlServiceServer struct{}

type UnimplementedWorkflowSpawnServiceServer struct{}

type UnsafeRuntimeControlServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeWorkflowSpawnServiceServer interface {
	// contains filtered or unexported methods
}

type WorkflowSpawnServiceClient interface {
	// SpawnStep creates one dynamic workflow step (or replays the step an
	// identical spawn already created).
	SpawnStep(ctx context.Context, in *SpawnStepRequest, opts ...grpc.CallOption) (*SpawnStepResponse, error)
}

type WorkflowSpawnServiceServer interface {
	// SpawnStep creates one dynamic workflow step (or replays the step an
	// identical spawn already created).
	SpawnStep(context.Context, *SpawnStepRequest) (*SpawnStepResponse, error)
	// contains filtered or unexported methods
}