goblinv1

package
v0.1.0-proto2g Latest Latest
Warning

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

 Go to latest Published: Aug 6, 2026 License: MPL-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CheckpointFetchStatus_name = map[int32]string{
		0: "CHECKPOINT_FETCH_STATUS_UNSPECIFIED",
		1: "CHECKPOINT_FETCH_STATUS_OK",
		2: "CHECKPOINT_FETCH_STATUS_NOT_FOUND",
		3: "CHECKPOINT_FETCH_STATUS_UNAUTHORIZED",
		4: "CHECKPOINT_FETCH_STATUS_INTERNAL",
	}
	CheckpointFetchStatus_value = map[string]int32{
		"CHECKPOINT_FETCH_STATUS_UNSPECIFIED":  0,
		"CHECKPOINT_FETCH_STATUS_OK":           1,
		"CHECKPOINT_FETCH_STATUS_NOT_FOUND":    2,
		"CHECKPOINT_FETCH_STATUS_UNAUTHORIZED": 3,
		"CHECKPOINT_FETCH_STATUS_INTERNAL":     4,
	}
)

Enum value maps for CheckpointFetchStatus.

View Source 
var (
	CommandType_name = map[int32]string{
		0:  "COMMAND_TYPE_UNSPECIFIED",
		1:  "COMMAND_TYPE_SET",
		2:  "COMMAND_TYPE_DELETE",
		3:  "COMMAND_TYPE_CAS",
		4:  "COMMAND_TYPE_ADMIT",
		5:  "COMMAND_TYPE_TRANSITION",
		6:  "COMMAND_TYPE_SIGNAL",
		7:  "COMMAND_TYPE_MIGRATE_BEGIN",
		8:  "COMMAND_TYPE_MIGRATE_COMMIT",
		9:  "COMMAND_TYPE_OPERATOR_KEY_SEED",
		10: "COMMAND_TYPE_OPERATOR_KEY_CHANGE",
	}
	CommandType_value = map[string]int32{
		"COMMAND_TYPE_UNSPECIFIED":         0,
		"COMMAND_TYPE_SET":                 1,
		"COMMAND_TYPE_DELETE":              2,
		"COMMAND_TYPE_CAS":                 3,
		"COMMAND_TYPE_ADMIT":               4,
		"COMMAND_TYPE_TRANSITION":          5,
		"COMMAND_TYPE_SIGNAL":              6,
		"COMMAND_TYPE_MIGRATE_BEGIN":       7,
		"COMMAND_TYPE_MIGRATE_COMMIT":      8,
		"COMMAND_TYPE_OPERATOR_KEY_SEED":   9,
		"COMMAND_TYPE_OPERATOR_KEY_CHANGE": 10,
	}
)

Enum value maps for CommandType.

View Source 
var (
	MigrateOutcome_name = map[int32]string{
		0: "MIGRATE_OUTCOME_UNSPECIFIED",
		1: "MIGRATE_OUTCOME_COMPLETED",
		2: "MIGRATE_OUTCOME_ABORTED",
	}
	MigrateOutcome_value = map[string]int32{
		"MIGRATE_OUTCOME_UNSPECIFIED": 0,
		"MIGRATE_OUTCOME_COMPLETED":   1,
		"MIGRATE_OUTCOME_ABORTED":     2,
	}
)

Enum value maps for MigrateOutcome.

View Source 
var (
	OperatorKeyOp_name = map[int32]string{
		0: "OPERATOR_KEY_OP_UNSPECIFIED",
		1: "OPERATOR_KEY_OP_ADD",
		2: "OPERATOR_KEY_OP_REMOVE",
	}
	OperatorKeyOp_value = map[string]int32{
		"OPERATOR_KEY_OP_UNSPECIFIED": 0,
		"OPERATOR_KEY_OP_ADD":         1,
		"OPERATOR_KEY_OP_REMOVE":      2,
	}
)

Enum value maps for OperatorKeyOp.

View Source 
var (
	RPCErrorCode_name = map[int32]string{
		0: "RPC_ERROR_CODE_UNSPECIFIED",
		1: "RPC_ERROR_CODE_INVALID_REQUEST",
		2: "RPC_ERROR_CODE_NOT_FOUND",
		3: "RPC_ERROR_CODE_PERMISSION_DENIED",
		4: "RPC_ERROR_CODE_UNAVAILABLE",
		5: "RPC_ERROR_CODE_INTERNAL",
	}
	RPCErrorCode_value = map[string]int32{
		"RPC_ERROR_CODE_UNSPECIFIED":       0,
		"RPC_ERROR_CODE_INVALID_REQUEST":   1,
		"RPC_ERROR_CODE_NOT_FOUND":         2,
		"RPC_ERROR_CODE_PERMISSION_DENIED": 3,
		"RPC_ERROR_CODE_UNAVAILABLE":       4,
		"RPC_ERROR_CODE_INTERNAL":          5,
	}
)

Enum value maps for RPCErrorCode.

View Source 
var (
	StreamType_name = map[int32]string{
		0: "STREAM_TYPE_UNSPECIFIED",
		1: "STREAM_TYPE_RPC_REQUEST",
		2: "STREAM_TYPE_RPC_RESPONSE",
		3: "STREAM_TYPE_EVENT_STREAM",
	}
	StreamType_value = map[string]int32{
		"STREAM_TYPE_UNSPECIFIED":  0,
		"STREAM_TYPE_RPC_REQUEST":  1,
		"STREAM_TYPE_RPC_RESPONSE": 2,
		"STREAM_TYPE_EVENT_STREAM": 3,
	}
)

Enum value maps for StreamType.

View Source 
var (
	InstanceState_name = map[int32]string{
		0: "INSTANCE_STATE_UNSPECIFIED",
		1: "INSTANCE_STATE_ADMITTED",
		2: "INSTANCE_STATE_SCHEDULED",
		3: "INSTANCE_STATE_STARTING",
		4: "INSTANCE_STATE_RUNNING",
		5: "INSTANCE_STATE_DRAINING",
		6: "INSTANCE_STATE_STOPPING",
		7: "INSTANCE_STATE_TERMINATED",
		8: "INSTANCE_STATE_ARCHIVED",
	}
	InstanceState_value = map[string]int32{
		"INSTANCE_STATE_UNSPECIFIED": 0,
		"INSTANCE_STATE_ADMITTED":    1,
		"INSTANCE_STATE_SCHEDULED":   2,
		"INSTANCE_STATE_STARTING":    3,
		"INSTANCE_STATE_RUNNING":     4,
		"INSTANCE_STATE_DRAINING":    5,
		"INSTANCE_STATE_STOPPING":    6,
		"INSTANCE_STATE_TERMINATED":  7,
		"INSTANCE_STATE_ARCHIVED":    8,
	}
)

Enum value maps for InstanceState.

View Source 
var File_goblin_v1_cluster_event_proto protoreflect.FileDescriptor
View Source 
var File_goblin_v1_fsm_snapshot_proto protoreflect.FileDescriptor
View Source 
var File_goblin_v1_migration_proto protoreflect.FileDescriptor
View Source 
var File_goblin_v1_node_rpc_proto protoreflect.FileDescriptor
View Source 
var File_goblin_v1_raft_proto protoreflect.FileDescriptor
View Source 
var File_goblin_v1_rpc_proto protoreflect.FileDescriptor
View Source 
var File_goblin_v1_scheduler_proto protoreflect.FileDescriptor
View Source 
var File_goblin_v1_scheduler_rpc_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AgentInstance 

type AgentInstance struct {
	InstanceUuid []byte        `protobuf:"bytes,1,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"` // 16-byte UUIDv7, minted at propose time
	SpecUuid     []byte        `protobuf:"bytes,2,opt,name=spec_uuid,json=specUuid,proto3" json:"spec_uuid,omitempty"`
	NodeId       string        `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	State        InstanceState `protobuf:"varint,4,opt,name=state,proto3,enum=goblin.v1.InstanceState" json:"state,omitempty"`
	Health       *HealthStatus `protobuf:"bytes,5,opt,name=health,proto3" json:"health,omitempty"`
	Reason       string        `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"` // why a terminal state was entered
	// contains filtered or unexported fields
}

AgentInstance is the Raft-resident instance record: immutable identity plus scheduler-owned state. The mutable runtime locator (node_pid, start_epoch, pid_ns_inode) deliberately lives in gossip, not here (three-layer split, DDR-3/4/5).

func (*AgentInstance) Descriptor deprecated 

func (*AgentInstance) Descriptor() ([]byte, []int)

Deprecated: Use AgentInstance.ProtoReflect.Descriptor instead.

func (*AgentInstance) GetHealth 

func (x *AgentInstance) GetHealth() *HealthStatus

func (*AgentInstance) GetInstanceUuid 

func (x *AgentInstance) GetInstanceUuid() []byte

func (*AgentInstance) GetNodeId 

func (x *AgentInstance) GetNodeId() string

func (*AgentInstance) GetReason 

func (x *AgentInstance) GetReason() string

func (*AgentInstance) GetSpecUuid 

func (x *AgentInstance) GetSpecUuid() []byte

func (*AgentInstance) GetState 

func (x *AgentInstance) GetState() InstanceState

func (*AgentInstance) ProtoMessage 

func (*AgentInstance) ProtoMessage()

func (*AgentInstance) ProtoReflect 

func (x *AgentInstance) ProtoReflect() protoreflect.Message

func (*AgentInstance) Reset 

func (x *AgentInstance) Reset()

func (*AgentInstance) String 

func (x *AgentInstance) String() string

type AgentSpec 

type AgentSpec struct {
	SpecUuid    []byte            `protobuf:"bytes,1,opt,name=spec_uuid,json=specUuid,proto3" json:"spec_uuid,omitempty"` // 16-byte UUIDv7
	Name        string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                         // human-readable operator handle
	Type        string            `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`                         // installed agent type, e.g. "sleeper"
	Replicas    int32             `protobuf:"varint,4,opt,name=replicas,proto3" json:"replicas,omitempty"`
	Constraints map[string]string `` // node tag requirements
	/* 149-byte string literal not displayed */
	Resources *ResourceReq `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"`
	Strategy  string       `protobuf:"bytes,7,opt,name=strategy,proto3" json:"strategy,omitempty"` // "spread", "binpack", "affinity"
	// contains filtered or unexported fields
}

AgentSpec defines the desired state of a global agent. Identity is the spec_uuid (UUIDv7, minted by the leader at registration); name is the operator-facing handle and must be unique among live specs.

func (*AgentSpec) Descriptor deprecated 

func (*AgentSpec) Descriptor() ([]byte, []int)

Deprecated: Use AgentSpec.ProtoReflect.Descriptor instead.

func (*AgentSpec) GetConstraints 

func (x *AgentSpec) GetConstraints() map[string]string

func (*AgentSpec) GetName 

func (x *AgentSpec) GetName() string

func (*AgentSpec) GetReplicas 

func (x *AgentSpec) GetReplicas() int32

func (*AgentSpec) GetResources 

func (x *AgentSpec) GetResources() *ResourceReq

func (*AgentSpec) GetSpecUuid 

func (x *AgentSpec) GetSpecUuid() []byte

func (*AgentSpec) GetStrategy 

func (x *AgentSpec) GetStrategy() string

func (*AgentSpec) GetType 

func (x *AgentSpec) GetType() string

func (*AgentSpec) ProtoMessage 

func (*AgentSpec) ProtoMessage()

func (*AgentSpec) ProtoReflect 

func (x *AgentSpec) ProtoReflect() protoreflect.Message

func (*AgentSpec) Reset 

func (x *AgentSpec) Reset()

func (*AgentSpec) String 

func (x *AgentSpec) String() string

type ApplyAdmit 

type ApplyAdmit struct {
	SpecUuid     []byte `protobuf:"bytes,1,opt,name=spec_uuid,json=specUuid,proto3" json:"spec_uuid,omitempty"`
	InstanceUuid []byte `protobuf:"bytes,2,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"` // minted at propose time by the leader
	NodeId       string `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`                   // placement decided at propose time
	// contains filtered or unexported fields
}

ApplyAdmit admits one instance. The leader mints the UUIDv7 and decides placement at PROPOSE time and carries both here: Apply records, never generates - the FSM must stay deterministic across replicas. The instance enters INSTANCE_STATE_ADMITTED; a tombstoned or already-known UUID is rejected.

func (*ApplyAdmit) Descriptor deprecated 

func (*ApplyAdmit) Descriptor() ([]byte, []int)

Deprecated: Use ApplyAdmit.ProtoReflect.Descriptor instead.

func (*ApplyAdmit) GetInstanceUuid 

func (x *ApplyAdmit) GetInstanceUuid() []byte

func (*ApplyAdmit) GetNodeId 

func (x *ApplyAdmit) GetNodeId() string

func (*ApplyAdmit) GetSpecUuid 

func (x *ApplyAdmit) GetSpecUuid() []byte

func (*ApplyAdmit) ProtoMessage 

func (*ApplyAdmit) ProtoMessage()

func (*ApplyAdmit) ProtoReflect 

func (x *ApplyAdmit) ProtoReflect() protoreflect.Message

func (*ApplyAdmit) Reset 

func (x *ApplyAdmit) Reset()

func (*ApplyAdmit) String 

func (x *ApplyAdmit) String() string

type CheckpointFetchRequest 

type CheckpointFetchRequest struct {

	// Subject instance. Stable across migration - that is the whole
	// point - so it identifies the image without naming a location.
	InstanceUuid []byte `protobuf:"bytes,1,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"`
	// Which checkpoint of that instance. Increments per dump, so a
	// retried migration never collides with an earlier image.
	CheckpointEpoch uint64 `protobuf:"varint,2,opt,name=checkpoint_epoch,json=checkpointEpoch,proto3" json:"checkpoint_epoch,omitempty"`
	// Serialized gapi.v1.CapabilityToken authorizing the fetch. Carried
	// as opaque bytes because the signature covers the literal payload
	// bytes; re-encoding it here would invalidate the signature.
	CapabilityToken []byte `protobuf:"bytes,3,opt,name=capability_token,json=capabilityToken,proto3" json:"capability_token,omitempty"`
	// contains filtered or unexported fields
}

CheckpointFetchRequest asks a source node for one instance's image.

func (*CheckpointFetchRequest) Descriptor deprecated 

func (*CheckpointFetchRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckpointFetchRequest.ProtoReflect.Descriptor instead.

func (*CheckpointFetchRequest) GetCapabilityToken 

func (x *CheckpointFetchRequest) GetCapabilityToken() []byte

func (*CheckpointFetchRequest) GetCheckpointEpoch 

func (x *CheckpointFetchRequest) GetCheckpointEpoch() uint64

func (*CheckpointFetchRequest) GetInstanceUuid 

func (x *CheckpointFetchRequest) GetInstanceUuid() []byte

func (*CheckpointFetchRequest) ProtoMessage 

func (*CheckpointFetchRequest) ProtoMessage()

func (*CheckpointFetchRequest) ProtoReflect 

func (x *CheckpointFetchRequest) ProtoReflect() protoreflect.Message

func (*CheckpointFetchRequest) Reset 

func (x *CheckpointFetchRequest) Reset()

func (*CheckpointFetchRequest) String 

func (x *CheckpointFetchRequest) String() string

type CheckpointFetchResponse 

type CheckpointFetchResponse struct {
	Status CheckpointFetchStatus `protobuf:"varint,1,opt,name=status,proto3,enum=goblin.v1.CheckpointFetchStatus" json:"status,omitempty"`
	Files  []*CheckpointFile     `protobuf:"bytes,2,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

CheckpointFetchResponse is the header sent before any image bytes. On OK the source then writes each manifest file's contents in manifest order, with no framing between them - the declared sizes are the framing.

func (*CheckpointFetchResponse) Descriptor deprecated 

func (*CheckpointFetchResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckpointFetchResponse.ProtoReflect.Descriptor instead.

func (*CheckpointFetchResponse) GetFiles 

func (x *CheckpointFetchResponse) GetFiles() []*CheckpointFile

func (*CheckpointFetchResponse) GetStatus 

func (x *CheckpointFetchResponse) GetStatus() CheckpointFetchStatus

func (*CheckpointFetchResponse) ProtoMessage 

func (*CheckpointFetchResponse) ProtoMessage()

func (*CheckpointFetchResponse) ProtoReflect 

func (x *CheckpointFetchResponse) ProtoReflect() protoreflect.Message

func (*CheckpointFetchResponse) Reset 

func (x *CheckpointFetchResponse) Reset()

func (*CheckpointFetchResponse) String 

func (x *CheckpointFetchResponse) String() string

type CheckpointFetchStatus 

type CheckpointFetchStatus int32

CheckpointFetchStatus is why a fetch did or did not proceed. An enum rather than a message string: the destination branches on this, and branching on prose is how retry logic rots. 

const (
	// Rejected by the receiver: a response decoded from an unknown or
	// truncated writer must never read as success.
	CheckpointFetchStatus_CHECKPOINT_FETCH_STATUS_UNSPECIFIED CheckpointFetchStatus = 0
	CheckpointFetchStatus_CHECKPOINT_FETCH_STATUS_OK          CheckpointFetchStatus = 1
	// No image for this {instance_uuid, epoch}.
	CheckpointFetchStatus_CHECKPOINT_FETCH_STATUS_NOT_FOUND CheckpointFetchStatus = 2
	// Token missing, expired, or lacking the migrate right.
	CheckpointFetchStatus_CHECKPOINT_FETCH_STATUS_UNAUTHORIZED CheckpointFetchStatus = 3
	// The source could not read its own image directory.
	CheckpointFetchStatus_CHECKPOINT_FETCH_STATUS_INTERNAL CheckpointFetchStatus = 4
)

func (CheckpointFetchStatus) Descriptor 

func (CheckpointFetchStatus) Descriptor() protoreflect.EnumDescriptor

func (CheckpointFetchStatus) Enum 

func (x CheckpointFetchStatus) Enum() *CheckpointFetchStatus

func (CheckpointFetchStatus) EnumDescriptor deprecated 

func (CheckpointFetchStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use CheckpointFetchStatus.Descriptor instead.

func (CheckpointFetchStatus) Number 

func (x CheckpointFetchStatus) Number() protoreflect.EnumNumber

func (CheckpointFetchStatus) String 

func (x CheckpointFetchStatus) String() string

func (CheckpointFetchStatus) Type 

func (CheckpointFetchStatus) Type() protoreflect.EnumType

type CheckpointFile 

type CheckpointFile struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

CheckpointFile is one image file in the manifest. Sizes are declared up front so the destination knows exactly how many bytes to expect per file and can detect truncation rather than inferring completion from a closed stream.

func (*CheckpointFile) Descriptor deprecated 

func (*CheckpointFile) Descriptor() ([]byte, []int)

Deprecated: Use CheckpointFile.ProtoReflect.Descriptor instead.

func (*CheckpointFile) GetName 

func (x *CheckpointFile) GetName() string

func (*CheckpointFile) GetSize 

func (x *CheckpointFile) GetSize() uint64

func (*CheckpointFile) ProtoMessage 

func (*CheckpointFile) ProtoMessage()

func (*CheckpointFile) ProtoReflect 

func (x *CheckpointFile) ProtoReflect() protoreflect.Message

func (*CheckpointFile) Reset 

func (x *CheckpointFile) Reset()

func (*CheckpointFile) String 

func (x *CheckpointFile) String() string

type ClusterEvent 

type ClusterEvent struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Topic     string                 `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Namespace string                 `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Tags      []string               `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	Payload   *structpb.Struct       `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	NodeId    string                 `protobuf:"bytes,6,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

ClusterEvent is the gossip wire form of an eventbus Event (GOBLIN-DIV-039). The envelope is typed so buf breaking covers it; payload is a google.protobuf.Struct because the in-process contract is map[string]interface{} - per-topic payload schemas are a future eventbus API decision, not smuggled in here. Serf bounds user events at 512 bytes (name + payload); the encoder fails loudly rather than letting an oversized event truncate or vanish.

func (*ClusterEvent) Descriptor deprecated 

func (*ClusterEvent) Descriptor() ([]byte, []int)

Deprecated: Use ClusterEvent.ProtoReflect.Descriptor instead.

func (*ClusterEvent) GetId 

func (x *ClusterEvent) GetId() string

func (*ClusterEvent) GetNamespace 

func (x *ClusterEvent) GetNamespace() string

func (*ClusterEvent) GetNodeId 

func (x *ClusterEvent) GetNodeId() string

func (*ClusterEvent) GetPayload 

func (x *ClusterEvent) GetPayload() *structpb.Struct

func (*ClusterEvent) GetTags 

func (x *ClusterEvent) GetTags() []string

func (*ClusterEvent) GetTimestamp 

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

func (*ClusterEvent) GetTopic 

func (x *ClusterEvent) GetTopic() string

func (*ClusterEvent) ProtoMessage 

func (*ClusterEvent) ProtoMessage()

func (*ClusterEvent) ProtoReflect 

func (x *ClusterEvent) ProtoReflect() protoreflect.Message

func (*ClusterEvent) Reset 

func (x *ClusterEvent) Reset()

func (*ClusterEvent) String 

func (x *ClusterEvent) String() string

type CommandType 

type CommandType int32

CommandType defines the operation type for the FSM 

const (
	// UNSPECIFIED takes the zero value: a LogEntry decoded from data
	// written before this schema (when SET was 0) surfaces as
	// UNSPECIFIED and must be rejected by the FSM, never misapplied.
	CommandType_COMMAND_TYPE_UNSPECIFIED CommandType = 0
	CommandType_COMMAND_TYPE_SET         CommandType = 1
	CommandType_COMMAND_TYPE_DELETE      CommandType = 2
	CommandType_COMMAND_TYPE_CAS         CommandType = 3 // Compare-And-Swap
	CommandType_COMMAND_TYPE_ADMIT       CommandType = 4 // admit an instance (payload: admit)
	CommandType_COMMAND_TYPE_TRANSITION  CommandType = 5 // lifecycle transition (payload: transition)
	CommandType_COMMAND_TYPE_SIGNAL      CommandType = 6 // authorize + log a signal (payload: signal)
	// Migration is recorded in the log for audit and to arbitrate
	// concurrent attempts, but it is NOT a lifecycle transition: the
	// instance stays RUNNING throughout and only its locator moves.
	CommandType_COMMAND_TYPE_MIGRATE_BEGIN  CommandType = 7 // (payload: migrate_begin)
	CommandType_COMMAND_TYPE_MIGRATE_COMMIT CommandType = 8 // (payload: migrate_commit)
	// Operator key registry (GOBLIN-DIV-015 piece 1). SEED installs the
	// configured root-of-trust keys into an empty registry; CHANGE is a
	// signed add or remove authorized by an already-registered key.
	CommandType_COMMAND_TYPE_OPERATOR_KEY_SEED   CommandType = 9  // (payload: operator_key_seed)
	CommandType_COMMAND_TYPE_OPERATOR_KEY_CHANGE CommandType = 10 // (payload: operator_key_change)
)

func (CommandType) Descriptor 

func (CommandType) Descriptor() protoreflect.EnumDescriptor

func (CommandType) Enum 

func (x CommandType) Enum() *CommandType

func (CommandType) EnumDescriptor deprecated 

func (CommandType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CommandType.Descriptor instead.

func (CommandType) Number 

func (x CommandType) Number() protoreflect.EnumNumber

func (CommandType) String 

func (x CommandType) String() string

func (CommandType) Type 

func (CommandType) Type() protoreflect.EnumType

type DeleteGlobalAgentRequest 

type DeleteGlobalAgentRequest struct {
	AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

DeleteGlobalAgentRequest identifies the spec to delete. agent_id accepts either the spec UUID or the operator-facing name.

func (*DeleteGlobalAgentRequest) Descriptor deprecated 

func (*DeleteGlobalAgentRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteGlobalAgentRequest.ProtoReflect.Descriptor instead.

func (*DeleteGlobalAgentRequest) GetAgentId 

func (x *DeleteGlobalAgentRequest) GetAgentId() string

func (*DeleteGlobalAgentRequest) ProtoMessage 

func (*DeleteGlobalAgentRequest) ProtoMessage()

func (*DeleteGlobalAgentRequest) ProtoReflect 

func (x *DeleteGlobalAgentRequest) ProtoReflect() protoreflect.Message

func (*DeleteGlobalAgentRequest) Reset 

func (x *DeleteGlobalAgentRequest) Reset()

func (*DeleteGlobalAgentRequest) String 

func (x *DeleteGlobalAgentRequest) String() string

type DeleteGlobalAgentResponse 

type DeleteGlobalAgentResponse struct {
	SpecUuid []byte `protobuf:"bytes,1,opt,name=spec_uuid,json=specUuid,proto3" json:"spec_uuid,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DeleteGlobalAgentResponse reports the identity of the spec that was deleted rather than a formatted sentence.

func (*DeleteGlobalAgentResponse) Descriptor deprecated 

func (*DeleteGlobalAgentResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteGlobalAgentResponse.ProtoReflect.Descriptor instead.

func (*DeleteGlobalAgentResponse) GetName 

func (x *DeleteGlobalAgentResponse) GetName() string

func (*DeleteGlobalAgentResponse) GetSpecUuid 

func (x *DeleteGlobalAgentResponse) GetSpecUuid() []byte

func (*DeleteGlobalAgentResponse) ProtoMessage 

func (*DeleteGlobalAgentResponse) ProtoMessage()

func (*DeleteGlobalAgentResponse) ProtoReflect 

func (x *DeleteGlobalAgentResponse) ProtoReflect() protoreflect.Message

func (*DeleteGlobalAgentResponse) Reset 

func (x *DeleteGlobalAgentResponse) Reset()

func (*DeleteGlobalAgentResponse) String 

func (x *DeleteGlobalAgentResponse) String() string

type DrainNodeRequest 

type DrainNodeRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

DrainNodeRequest names the node to evacuate.

func (*DrainNodeRequest) Descriptor deprecated 

func (*DrainNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DrainNodeRequest.ProtoReflect.Descriptor instead.

func (*DrainNodeRequest) GetNodeId 

func (x *DrainNodeRequest) GetNodeId() string

func (*DrainNodeRequest) ProtoMessage 

func (*DrainNodeRequest) ProtoMessage()

func (*DrainNodeRequest) ProtoReflect 

func (x *DrainNodeRequest) ProtoReflect() protoreflect.Message

func (*DrainNodeRequest) Reset 

func (x *DrainNodeRequest) Reset()

func (*DrainNodeRequest) String 

func (x *DrainNodeRequest) String() string

type DrainNodeResponse 

type DrainNodeResponse struct {
	MigratedJobIds []string `protobuf:"bytes,1,rep,name=migrated_job_ids,json=migratedJobIds,proto3" json:"migrated_job_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*DrainNodeResponse) Descriptor deprecated 

func (*DrainNodeResponse) Descriptor() ([]byte, []int)

Deprecated: Use DrainNodeResponse.ProtoReflect.Descriptor instead.

func (*DrainNodeResponse) GetMigratedJobIds 

func (x *DrainNodeResponse) GetMigratedJobIds() []string

func (*DrainNodeResponse) ProtoMessage 

func (*DrainNodeResponse) ProtoMessage()

func (*DrainNodeResponse) ProtoReflect 

func (x *DrainNodeResponse) ProtoReflect() protoreflect.Message

func (*DrainNodeResponse) Reset 

func (x *DrainNodeResponse) Reset()

func (*DrainNodeResponse) String 

func (x *DrainNodeResponse) String() string

type FSMNamespaceState 

type FSMNamespaceState struct {
	Values   map[string][]byte `` /* 139-byte string literal not displayed */
	Versions map[string]uint64 `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

FSMNamespaceState is one namespace's key/value state plus the CAS version counters for the same keys. Kept as two parallel maps rather than one map of a Value+Version message so the wire shape matches the FSM's own in-memory layout (state map, versions map) with no per-entry wrapper message.

func (*FSMNamespaceState) Descriptor deprecated 

func (*FSMNamespaceState) Descriptor() ([]byte, []int)

Deprecated: Use FSMNamespaceState.ProtoReflect.Descriptor instead.

func (*FSMNamespaceState) GetValues 

func (x *FSMNamespaceState) GetValues() map[string][]byte

func (*FSMNamespaceState) GetVersions 

func (x *FSMNamespaceState) GetVersions() map[string]uint64

func (*FSMNamespaceState) ProtoMessage 

func (*FSMNamespaceState) ProtoMessage()

func (*FSMNamespaceState) ProtoReflect 

func (x *FSMNamespaceState) ProtoReflect() protoreflect.Message

func (*FSMNamespaceState) Reset 

func (x *FSMNamespaceState) Reset()

func (*FSMNamespaceState) String 

func (x *FSMNamespaceState) String() string

type FSMSnapshot 

type FSMSnapshot struct {

	// Namespace name -> that namespace's state.
	Namespaces map[string]*FSMNamespaceState `` /* 147-byte string literal not displayed */
	// Instance UUID (canonical string form) -> marshalled
	// goblin.v1.AgentInstance bytes. The FSM holds these as typed
	// AgentInstance messages; fsm.go marshals each one when it takes a
	// snapshot and unmarshals it again on restore. They are carried as
	// bytes rather than a nested AgentInstance field so this message does
	// not have to import the instance schema.
	Instances map[string][]byte `` /* 145-byte string literal not displayed */
	// Every instance UUID ever terminated. Append-only forever (operator
	// decision 2026-07-28): a tombstoned UUID is never reused.
	Tombstones []string `protobuf:"bytes,3,rep,name=tombstones,proto3" json:"tombstones,omitempty"`
	// Instance UUID (canonical string form) -> marshalled
	// goblin.v1.MigrationRecord bytes for in-flight migrations. Same
	// rationale as instances: typed messages in the FSM, marshalled into
	// the snapshot and unmarshalled on restore, kept as bytes so this
	// message does not have to import their schema.
	Migrations map[string][]byte `` /* 147-byte string literal not displayed */
	// Operator key id -> marshalled goblin.v1.OperatorKey bytes. Same
	// rationale as instances and migrations: typed messages in the FSM,
	// marshalled into the snapshot and unmarshalled on restore, kept as
	// bytes so this message does not have to import their schema.
	OperatorKeys map[string][]byte `` /* 171-byte string literal not displayed */
	// The registry's monotone serial. It rides the snapshot because it is
	// the replay guard for signed changes: a leader restored from a
	// snapshot that forgot the serial would accept a change already
	// applied.
	OperatorRegistrySerial uint64 `` /* 130-byte string literal not displayed */
	// Marshalled goblin.v1.OperatorKeySeed - the founding key set. Unsigned,
	// because a seed is authorized by the registry being empty rather than
	// by a signature; that is exactly why the restoring node must compare it
	// against its OWN configured keys instead of trusting it. Empty when the
	// registry is empty.
	OperatorKeySeed []byte `protobuf:"bytes,7,opt,name=operator_key_seed,json=operatorKeySeed,proto3" json:"operator_key_seed,omitempty"`
	// Marshalled goblin.v1.OperatorKeyChange records, in the order they were
	// applied. Only changes that actually mutated the registry appear: a
	// re-seed of an identical set and an ADD of an already-registered id are
	// both no-ops that do not bump the serial, so including them would make
	// the replay diverge from the apply path it is reproducing.
	OperatorKeyChain [][]byte `protobuf:"bytes,8,rep,name=operator_key_chain,json=operatorKeyChain,proto3" json:"operator_key_chain,omitempty"`
	// contains filtered or unexported fields
}

FSMSnapshot is the entire Raft FSM state as shipped to a joining node or written to the local snapshot store.

func (*FSMSnapshot) Descriptor deprecated 

func (*FSMSnapshot) Descriptor() ([]byte, []int)

Deprecated: Use FSMSnapshot.ProtoReflect.Descriptor instead.

func (*FSMSnapshot) GetInstances 

func (x *FSMSnapshot) GetInstances() map[string][]byte

func (*FSMSnapshot) GetMigrations 

func (x *FSMSnapshot) GetMigrations() map[string][]byte

func (*FSMSnapshot) GetNamespaces 

func (x *FSMSnapshot) GetNamespaces() map[string]*FSMNamespaceState

func (*FSMSnapshot) GetOperatorKeyChain 

func (x *FSMSnapshot) GetOperatorKeyChain() [][]byte

func (*FSMSnapshot) GetOperatorKeySeed 

func (x *FSMSnapshot) GetOperatorKeySeed() []byte

func (*FSMSnapshot) GetOperatorKeys 

func (x *FSMSnapshot) GetOperatorKeys() map[string][]byte

func (*FSMSnapshot) GetOperatorRegistrySerial 

func (x *FSMSnapshot) GetOperatorRegistrySerial() uint64

func (*FSMSnapshot) GetTombstones 

func (x *FSMSnapshot) GetTombstones() []string

func (*FSMSnapshot) ProtoMessage 

func (*FSMSnapshot) ProtoMessage()

func (*FSMSnapshot) ProtoReflect 

func (x *FSMSnapshot) ProtoReflect() protoreflect.Message

func (*FSMSnapshot) Reset 

func (x *FSMSnapshot) Reset()

func (*FSMSnapshot) String 

func (x *FSMSnapshot) String() string

type GetAgentRequest 

type GetAgentRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // spec UUID (canonical string) or name
	// contains filtered or unexported fields
}

func (*GetAgentRequest) Descriptor deprecated 

func (*GetAgentRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetAgentRequest.ProtoReflect.Descriptor instead.

func (*GetAgentRequest) GetId 

func (x *GetAgentRequest) GetId() string

func (*GetAgentRequest) ProtoMessage 

func (*GetAgentRequest) ProtoMessage()

func (*GetAgentRequest) ProtoReflect 

func (x *GetAgentRequest) ProtoReflect() protoreflect.Message

func (*GetAgentRequest) Reset 

func (x *GetAgentRequest) Reset()

func (*GetAgentRequest) String 

func (x *GetAgentRequest) String() string

type GetAgentResponse 

type GetAgentResponse struct {
	Spec *AgentSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAgentResponse) Descriptor deprecated 

func (*GetAgentResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetAgentResponse.ProtoReflect.Descriptor instead.

func (*GetAgentResponse) GetSpec 

func (x *GetAgentResponse) GetSpec() *AgentSpec

func (*GetAgentResponse) ProtoMessage 

func (*GetAgentResponse) ProtoMessage()

func (*GetAgentResponse) ProtoReflect 

func (x *GetAgentResponse) ProtoReflect() protoreflect.Message

func (*GetAgentResponse) Reset 

func (x *GetAgentResponse) Reset()

func (*GetAgentResponse) String 

func (x *GetAgentResponse) String() string

type GetEventsRequest 

type GetEventsRequest struct {
	Cursor uint64 `protobuf:"varint,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

GetEventsRequest asks for events with index greater than cursor.

func (*GetEventsRequest) Descriptor deprecated 

func (*GetEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetEventsRequest.ProtoReflect.Descriptor instead.

func (*GetEventsRequest) GetCursor 

func (x *GetEventsRequest) GetCursor() uint64

func (*GetEventsRequest) ProtoMessage 

func (*GetEventsRequest) ProtoMessage()

func (*GetEventsRequest) ProtoReflect 

func (x *GetEventsRequest) ProtoReflect() protoreflect.Message

func (*GetEventsRequest) Reset 

func (x *GetEventsRequest) Reset()

func (*GetEventsRequest) String 

func (x *GetEventsRequest) String() string

type GetEventsResponse 

type GetEventsResponse struct {
	Events []*LogEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventsResponse) Descriptor deprecated 

func (*GetEventsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetEventsResponse.ProtoReflect.Descriptor instead.

func (*GetEventsResponse) GetEvents 

func (x *GetEventsResponse) GetEvents() []*LogEvent

func (*GetEventsResponse) ProtoMessage 

func (*GetEventsResponse) ProtoMessage()

func (*GetEventsResponse) ProtoReflect 

func (x *GetEventsResponse) ProtoReflect() protoreflect.Message

func (*GetEventsResponse) Reset 

func (x *GetEventsResponse) Reset()

func (*GetEventsResponse) String 

func (x *GetEventsResponse) String() string

type GetGlobalAgentRequest 

type GetGlobalAgentRequest struct {
	AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

GetGlobalAgentRequest identifies one spec. agent_id accepts either the spec UUID or the operator-facing name.

func (*GetGlobalAgentRequest) Descriptor deprecated 

func (*GetGlobalAgentRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetGlobalAgentRequest.ProtoReflect.Descriptor instead.

func (*GetGlobalAgentRequest) GetAgentId 

func (x *GetGlobalAgentRequest) GetAgentId() string

func (*GetGlobalAgentRequest) ProtoMessage 

func (*GetGlobalAgentRequest) ProtoMessage()

func (*GetGlobalAgentRequest) ProtoReflect 

func (x *GetGlobalAgentRequest) ProtoReflect() protoreflect.Message

func (*GetGlobalAgentRequest) Reset 

func (x *GetGlobalAgentRequest) Reset()

func (*GetGlobalAgentRequest) String 

func (x *GetGlobalAgentRequest) String() string

type GetGlobalAgentResponse 

type GetGlobalAgentResponse struct {
	Spec *AgentSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGlobalAgentResponse) Descriptor deprecated 

func (*GetGlobalAgentResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetGlobalAgentResponse.ProtoReflect.Descriptor instead.

func (*GetGlobalAgentResponse) GetSpec 

func (x *GetGlobalAgentResponse) GetSpec() *AgentSpec

func (*GetGlobalAgentResponse) ProtoMessage 

func (*GetGlobalAgentResponse) ProtoMessage()

func (*GetGlobalAgentResponse) ProtoReflect 

func (x *GetGlobalAgentResponse) ProtoReflect() protoreflect.Message

func (*GetGlobalAgentResponse) Reset 

func (x *GetGlobalAgentResponse) Reset()

func (*GetGlobalAgentResponse) String 

func (x *GetGlobalAgentResponse) String() string

type HealthStatus 

type HealthStatus struct {
	Status   string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // "healthy", "degraded", "unhealthy"
	Message  string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Failures int64  `protobuf:"varint,3,opt,name=failures,proto3" json:"failures,omitempty"`
	// contains filtered or unexported fields
}

HealthStatus

func (*HealthStatus) Descriptor deprecated 

func (*HealthStatus) Descriptor() ([]byte, []int)

Deprecated: Use HealthStatus.ProtoReflect.Descriptor instead.

func (*HealthStatus) GetFailures 

func (x *HealthStatus) GetFailures() int64

func (*HealthStatus) GetMessage 

func (x *HealthStatus) GetMessage() string

func (*HealthStatus) GetStatus 

func (x *HealthStatus) GetStatus() string

func (*HealthStatus) ProtoMessage 

func (*HealthStatus) ProtoMessage()

func (*HealthStatus) ProtoReflect 

func (x *HealthStatus) ProtoReflect() protoreflect.Message

func (*HealthStatus) Reset 

func (x *HealthStatus) Reset()

func (*HealthStatus) String 

func (x *HealthStatus) String() string

type InstanceState 

type InstanceState int32

InstanceState is the instance lifecycle FSM (DDR-6). Transitions are validated by the Raft FSM; illegal transitions are rejected, and UUIDs of TERMINATED/ARCHIVED instances are tombstoned forever. 

const (
	// Zero value: data written before this schema surfaces as
	// UNSPECIFIED and must be rejected, never misapplied.
	InstanceState_INSTANCE_STATE_UNSPECIFIED InstanceState = 0
	InstanceState_INSTANCE_STATE_ADMITTED    InstanceState = 1 // UUID minted, committed through Raft
	InstanceState_INSTANCE_STATE_SCHEDULED   InstanceState = 2 // placement bound to a node
	InstanceState_INSTANCE_STATE_STARTING    InstanceState = 3 // dispatch in flight
	InstanceState_INSTANCE_STATE_RUNNING     InstanceState = 4
	InstanceState_INSTANCE_STATE_DRAINING    InstanceState = 5 // graceful scale-down in progress
	InstanceState_INSTANCE_STATE_STOPPING    InstanceState = 6
	InstanceState_INSTANCE_STATE_TERMINATED  InstanceState = 7 // terminal; reason says why
	InstanceState_INSTANCE_STATE_ARCHIVED    InstanceState = 8 // terminal, compacted record
)

func (InstanceState) Descriptor 

func (InstanceState) Descriptor() protoreflect.EnumDescriptor

func (InstanceState) Enum 

func (x InstanceState) Enum() *InstanceState

func (InstanceState) EnumDescriptor deprecated 

func (InstanceState) EnumDescriptor() ([]byte, []int)

Deprecated: Use InstanceState.Descriptor instead.

func (InstanceState) Number 

func (x InstanceState) Number() protoreflect.EnumNumber

func (InstanceState) String 

func (x InstanceState) String() string

func (InstanceState) Type 

func (InstanceState) Type() protoreflect.EnumType

type InstanceTransition 

type InstanceTransition struct {
	InstanceUuid []byte        `protobuf:"bytes,1,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"`
	To           InstanceState `protobuf:"varint,2,opt,name=to,proto3,enum=goblin.v1.InstanceState" json:"to,omitempty"`
	Reason       string        `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"` // required for terminal states
	// contains filtered or unexported fields
}

InstanceTransition moves an instance through the lifecycle FSM. Illegal transitions are rejected as the Apply response.

func (*InstanceTransition) Descriptor deprecated 

func (*InstanceTransition) Descriptor() ([]byte, []int)

Deprecated: Use InstanceTransition.ProtoReflect.Descriptor instead.

func (*InstanceTransition) GetInstanceUuid 

func (x *InstanceTransition) GetInstanceUuid() []byte

func (*InstanceTransition) GetReason 

func (x *InstanceTransition) GetReason() string

func (*InstanceTransition) GetTo 

func (x *InstanceTransition) GetTo() InstanceState

func (*InstanceTransition) ProtoMessage 

func (*InstanceTransition) ProtoMessage()

func (*InstanceTransition) ProtoReflect 

func (x *InstanceTransition) ProtoReflect() protoreflect.Message

func (*InstanceTransition) Reset 

func (x *InstanceTransition) Reset()

func (*InstanceTransition) String 

func (x *InstanceTransition) String() string

type Job 

type Job struct {
	Id            string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	AgentId       string            `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	AgentType     string            `protobuf:"bytes,3,opt,name=agent_type,json=agentType,proto3" json:"agent_type,omitempty"`
	AssignedNode  string            `protobuf:"bytes,4,opt,name=assigned_node,json=assignedNode,proto3" json:"assigned_node,omitempty"`
	Resources     *ResourceReq      `protobuf:"bytes,5,opt,name=resources,proto3" json:"resources,omitempty"`
	Constraints   map[string]string ``                                                                                                     /* 149-byte string literal not displayed */
	Requirements  map[string]string ``                                                                                                     /* 151-byte string literal not displayed */
	RestartPolicy string            `protobuf:"bytes,8,opt,name=restart_policy,json=restartPolicy,proto3" json:"restart_policy,omitempty"` // "always", "on-failure", "never"
	Env           map[string]string ``                                                                                                     /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

Job is the RPC-facing view of a job submission - a faithful, field-for-field translation of core/scheduler.Job. That type predates protobuf and stays a plain Go struct (its storage encoding is JSON in the KV store); this message is only the wire shape for SubmitJob.

func (*Job) Descriptor deprecated 

func (*Job) Descriptor() ([]byte, []int)

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetAgentId 

func (x *Job) GetAgentId() string

func (*Job) GetAgentType 

func (x *Job) GetAgentType() string

func (*Job) GetAssignedNode 

func (x *Job) GetAssignedNode() string

func (*Job) GetConstraints 

func (x *Job) GetConstraints() map[string]string

func (*Job) GetEnv 

func (x *Job) GetEnv() map[string]string

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetRequirements 

func (x *Job) GetRequirements() map[string]string

func (*Job) GetResources 

func (x *Job) GetResources() *ResourceReq

func (*Job) GetRestartPolicy 

func (x *Job) GetRestartPolicy() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobInfo 

type JobInfo struct {
	JobId        string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	AssignedNode string `protobuf:"bytes,2,opt,name=assigned_node,json=assignedNode,proto3" json:"assigned_node,omitempty"`
	AgentType    string `protobuf:"bytes,3,opt,name=agent_type,json=agentType,proto3" json:"agent_type,omitempty"`
	Status       string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

JobInfo is the RPC-facing view of a scheduled job; assembled from the job assignment and spec keys at request time rather than stored as its own record.

func (*JobInfo) Descriptor deprecated 

func (*JobInfo) Descriptor() ([]byte, []int)

Deprecated: Use JobInfo.ProtoReflect.Descriptor instead.

func (*JobInfo) GetAgentType 

func (x *JobInfo) GetAgentType() string

func (*JobInfo) GetAssignedNode 

func (x *JobInfo) GetAssignedNode() string

func (*JobInfo) GetJobId 

func (x *JobInfo) GetJobId() string

func (*JobInfo) GetStatus 

func (x *JobInfo) GetStatus() string

func (*JobInfo) ProtoMessage 

func (*JobInfo) ProtoMessage()

func (*JobInfo) ProtoReflect 

func (x *JobInfo) ProtoReflect() protoreflect.Message

func (*JobInfo) Reset 

func (x *JobInfo) Reset()

func (*JobInfo) String 

func (x *JobInfo) String() string

type ListAgentInstancesRequest 

type ListAgentInstancesRequest struct {
	SpecId string `protobuf:"bytes,1,opt,name=spec_id,json=specId,proto3" json:"spec_id,omitempty"`
	// contains filtered or unexported fields
}

ListAgentInstancesRequest filters instance listing; empty spec_id returns every instance. spec_id accepts either the canonical spec UUID or the operator-facing name.

func (*ListAgentInstancesRequest) Descriptor deprecated 

func (*ListAgentInstancesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentInstancesRequest.ProtoReflect.Descriptor instead.

func (*ListAgentInstancesRequest) GetSpecId 

func (x *ListAgentInstancesRequest) GetSpecId() string

func (*ListAgentInstancesRequest) ProtoMessage 

func (*ListAgentInstancesRequest) ProtoMessage()

func (*ListAgentInstancesRequest) ProtoReflect 

func (x *ListAgentInstancesRequest) ProtoReflect() protoreflect.Message

func (*ListAgentInstancesRequest) Reset 

func (x *ListAgentInstancesRequest) Reset()

func (*ListAgentInstancesRequest) String 

func (x *ListAgentInstancesRequest) String() string

type ListAgentInstancesResponse 

type ListAgentInstancesResponse struct {
	Instances []*AgentInstance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentInstancesResponse) Descriptor deprecated 

func (*ListAgentInstancesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentInstancesResponse.ProtoReflect.Descriptor instead.

func (*ListAgentInstancesResponse) GetInstances 

func (x *ListAgentInstancesResponse) GetInstances() []*AgentInstance

func (*ListAgentInstancesResponse) ProtoMessage 

func (*ListAgentInstancesResponse) ProtoMessage()

func (*ListAgentInstancesResponse) ProtoReflect 

func (x *ListAgentInstancesResponse) ProtoReflect() protoreflect.Message

func (*ListAgentInstancesResponse) Reset 

func (x *ListAgentInstancesResponse) Reset()

func (*ListAgentInstancesResponse) String 

func (x *ListAgentInstancesResponse) String() string

type ListAgentsRequest 

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

func (*ListAgentsRequest) Descriptor deprecated 

func (*ListAgentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentsRequest.ProtoReflect.Descriptor instead.

func (*ListAgentsRequest) ProtoMessage 

func (*ListAgentsRequest) ProtoMessage()

func (*ListAgentsRequest) ProtoReflect 

func (x *ListAgentsRequest) ProtoReflect() protoreflect.Message

func (*ListAgentsRequest) Reset 

func (x *ListAgentsRequest) Reset()

func (*ListAgentsRequest) String 

func (x *ListAgentsRequest) String() string

type ListAgentsResponse 

type ListAgentsResponse struct {
	Agents []*AgentSpec `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentsResponse) Descriptor deprecated 

func (*ListAgentsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentsResponse.ProtoReflect.Descriptor instead.

func (*ListAgentsResponse) GetAgents 

func (x *ListAgentsResponse) GetAgents() []*AgentSpec

func (*ListAgentsResponse) ProtoMessage 

func (*ListAgentsResponse) ProtoMessage()

func (*ListAgentsResponse) ProtoReflect 

func (x *ListAgentsResponse) ProtoReflect() protoreflect.Message

func (*ListAgentsResponse) Reset 

func (x *ListAgentsResponse) Reset()

func (*ListAgentsResponse) String 

func (x *ListAgentsResponse) String() string

type ListGlobalAgentsRequest 

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

ListGlobalAgentsRequest is empty so fields can be added later without a signature change (e.g. a name filter).

func (*ListGlobalAgentsRequest) Descriptor deprecated 

func (*ListGlobalAgentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListGlobalAgentsRequest.ProtoReflect.Descriptor instead.

func (*ListGlobalAgentsRequest) ProtoMessage 

func (*ListGlobalAgentsRequest) ProtoMessage()

func (*ListGlobalAgentsRequest) ProtoReflect 

func (x *ListGlobalAgentsRequest) ProtoReflect() protoreflect.Message

func (*ListGlobalAgentsRequest) Reset 

func (x *ListGlobalAgentsRequest) Reset()

func (*ListGlobalAgentsRequest) String 

func (x *ListGlobalAgentsRequest) String() string

type ListGlobalAgentsResponse 

type ListGlobalAgentsResponse struct {
	Agents []*AgentSpec `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	// contains filtered or unexported fields
}

func (*ListGlobalAgentsResponse) Descriptor deprecated 

func (*ListGlobalAgentsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListGlobalAgentsResponse.ProtoReflect.Descriptor instead.

func (*ListGlobalAgentsResponse) GetAgents 

func (x *ListGlobalAgentsResponse) GetAgents() []*AgentSpec

func (*ListGlobalAgentsResponse) ProtoMessage 

func (*ListGlobalAgentsResponse) ProtoMessage()

func (*ListGlobalAgentsResponse) ProtoReflect 

func (x *ListGlobalAgentsResponse) ProtoReflect() protoreflect.Message

func (*ListGlobalAgentsResponse) Reset 

func (x *ListGlobalAgentsResponse) Reset()

func (*ListGlobalAgentsResponse) String 

func (x *ListGlobalAgentsResponse) String() string

type ListJobsRequest 

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

ListJobsRequest is empty so fields can be added later without a signature change (e.g. a status filter).

func (*ListJobsRequest) Descriptor deprecated 

func (*ListJobsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect 

func (x *ListJobsRequest) ProtoReflect() protoreflect.Message

func (*ListJobsRequest) Reset 

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (x *ListJobsRequest) String() string

type ListJobsResponse 

type ListJobsResponse struct {
	Jobs []*JobInfo `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsResponse) Descriptor deprecated 

func (*ListJobsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

func (*ListJobsResponse) GetJobs 

func (x *ListJobsResponse) GetJobs() []*JobInfo

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect 

func (x *ListJobsResponse) ProtoReflect() protoreflect.Message

func (*ListJobsResponse) Reset 

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) String 

func (x *ListJobsResponse) String() string

type ListLocalAgentsRequest 

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

ListLocalAgentsRequest is empty so fields can be added later without a signature change.

func (*ListLocalAgentsRequest) Descriptor deprecated 

func (*ListLocalAgentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListLocalAgentsRequest.ProtoReflect.Descriptor instead.

func (*ListLocalAgentsRequest) ProtoMessage 

func (*ListLocalAgentsRequest) ProtoMessage()

func (*ListLocalAgentsRequest) ProtoReflect 

func (x *ListLocalAgentsRequest) ProtoReflect() protoreflect.Message

func (*ListLocalAgentsRequest) Reset 

func (x *ListLocalAgentsRequest) Reset()

func (*ListLocalAgentsRequest) String 

func (x *ListLocalAgentsRequest) String() string

type ListLocalAgentsResponse 

type ListLocalAgentsResponse struct {
	Agents []*LocalAgentInfo `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLocalAgentsResponse) Descriptor deprecated 

func (*ListLocalAgentsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListLocalAgentsResponse.ProtoReflect.Descriptor instead.

func (*ListLocalAgentsResponse) GetAgents 

func (x *ListLocalAgentsResponse) GetAgents() []*LocalAgentInfo

func (*ListLocalAgentsResponse) ProtoMessage 

func (*ListLocalAgentsResponse) ProtoMessage()

func (*ListLocalAgentsResponse) ProtoReflect 

func (x *ListLocalAgentsResponse) ProtoReflect() protoreflect.Message

func (*ListLocalAgentsResponse) Reset 

func (x *ListLocalAgentsResponse) Reset()

func (*ListLocalAgentsResponse) String 

func (x *ListLocalAgentsResponse) String() string

type LocalAgentInfo 

type LocalAgentInfo struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type     string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	State    string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	Language string `protobuf:"bytes,4,opt,name=language,proto3" json:"language,omitempty"`
	UptimeNs int64  `protobuf:"varint,5,opt,name=uptime_ns,json=uptimeNs,proto3" json:"uptime_ns,omitempty"`
	// contains filtered or unexported fields
}

LocalAgentInfo is the RPC-facing view of an agent managed by the local GAPI agent manager (not a scheduled global agent instance).

func (*LocalAgentInfo) Descriptor deprecated 

func (*LocalAgentInfo) Descriptor() ([]byte, []int)

Deprecated: Use LocalAgentInfo.ProtoReflect.Descriptor instead.

func (*LocalAgentInfo) GetId 

func (x *LocalAgentInfo) GetId() string

func (*LocalAgentInfo) GetLanguage 

func (x *LocalAgentInfo) GetLanguage() string

func (*LocalAgentInfo) GetState 

func (x *LocalAgentInfo) GetState() string

func (*LocalAgentInfo) GetType 

func (x *LocalAgentInfo) GetType() string

func (*LocalAgentInfo) GetUptimeNs 

func (x *LocalAgentInfo) GetUptimeNs() int64

func (*LocalAgentInfo) ProtoMessage 

func (*LocalAgentInfo) ProtoMessage()

func (*LocalAgentInfo) ProtoReflect 

func (x *LocalAgentInfo) ProtoReflect() protoreflect.Message

func (*LocalAgentInfo) Reset 

func (x *LocalAgentInfo) Reset()

func (*LocalAgentInfo) String 

func (x *LocalAgentInfo) String() string

type LogEntry 

type LogEntry struct {
	Type       CommandType `protobuf:"varint,1,opt,name=type,proto3,enum=goblin.v1.CommandType" json:"type,omitempty"`
	Namespace  string      `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Key        string      `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value      []byte      `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	CasVersion uint64      `protobuf:"varint,5,opt,name=cas_version,json=casVersion,proto3" json:"cas_version,omitempty"` // For optimistic concurrency checks
	// Types that are valid to be assigned to Payload:
	//
	//	*LogEntry_Admit
	//	*LogEntry_Transition
	//	*LogEntry_Signal
	//	*LogEntry_MigrateBegin
	//	*LogEntry_MigrateCommit
	//	*LogEntry_OperatorKeySeed
	//	*LogEntry_OperatorKeyChange
	Payload isLogEntry_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

LogEntry represents a command in the Raft log. KV commands use the flat namespace/key/value fields; instance-lifecycle commands carry their payload in the oneof.

func (*LogEntry) Descriptor deprecated 

func (*LogEntry) Descriptor() ([]byte, []int)

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetAdmit 

func (x *LogEntry) GetAdmit() *ApplyAdmit

func (*LogEntry) GetCasVersion 

func (x *LogEntry) GetCasVersion() uint64

func (*LogEntry) GetKey 

func (x *LogEntry) GetKey() string

func (*LogEntry) GetMigrateBegin 

func (x *LogEntry) GetMigrateBegin() *MigrateBegin

func (*LogEntry) GetMigrateCommit 

func (x *LogEntry) GetMigrateCommit() *MigrateCommit

func (*LogEntry) GetNamespace 

func (x *LogEntry) GetNamespace() string

func (*LogEntry) GetOperatorKeyChange 

func (x *LogEntry) GetOperatorKeyChange() *OperatorKeyChange

func (*LogEntry) GetOperatorKeySeed 

func (x *LogEntry) GetOperatorKeySeed() *OperatorKeySeed

func (*LogEntry) GetPayload 

func (x *LogEntry) GetPayload() isLogEntry_Payload

func (*LogEntry) GetSignal 

func (x *LogEntry) GetSignal() *SignalRequest

func (*LogEntry) GetTransition 

func (x *LogEntry) GetTransition() *InstanceTransition

func (*LogEntry) GetType 

func (x *LogEntry) GetType() CommandType

func (*LogEntry) GetValue 

func (x *LogEntry) GetValue() []byte

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

func (x *LogEntry) ProtoReflect() protoreflect.Message

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

type LogEntry_Admit 

type LogEntry_Admit struct {
	Admit *ApplyAdmit `protobuf:"bytes,6,opt,name=admit,proto3,oneof"`
}

type LogEntry_MigrateBegin 

type LogEntry_MigrateBegin struct {
	MigrateBegin *MigrateBegin `protobuf:"bytes,9,opt,name=migrate_begin,json=migrateBegin,proto3,oneof"`
}

type LogEntry_MigrateCommit 

type LogEntry_MigrateCommit struct {
	MigrateCommit *MigrateCommit `protobuf:"bytes,10,opt,name=migrate_commit,json=migrateCommit,proto3,oneof"`
}

type LogEntry_OperatorKeyChange 

type LogEntry_OperatorKeyChange struct {
	OperatorKeyChange *OperatorKeyChange `protobuf:"bytes,12,opt,name=operator_key_change,json=operatorKeyChange,proto3,oneof"`
}

type LogEntry_OperatorKeySeed 

type LogEntry_OperatorKeySeed struct {
	OperatorKeySeed *OperatorKeySeed `protobuf:"bytes,11,opt,name=operator_key_seed,json=operatorKeySeed,proto3,oneof"`
}

type LogEntry_Signal 

type LogEntry_Signal struct {
	Signal *SignalRequest `protobuf:"bytes,8,opt,name=signal,proto3,oneof"`
}

type LogEntry_Transition 

type LogEntry_Transition struct {
	Transition *InstanceTransition `protobuf:"bytes,7,opt,name=transition,proto3,oneof"`
}

type LogEvent 

type LogEvent struct {
	Index     uint64                 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Message   string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

LogEvent is one entry in the in-memory supervisor event log.

func (*LogEvent) Descriptor deprecated 

func (*LogEvent) Descriptor() ([]byte, []int)

Deprecated: Use LogEvent.ProtoReflect.Descriptor instead.

func (*LogEvent) GetIndex 

func (x *LogEvent) GetIndex() uint64

func (*LogEvent) GetMessage 

func (x *LogEvent) GetMessage() string

func (*LogEvent) GetTimestamp 

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

func (*LogEvent) ProtoMessage 

func (*LogEvent) ProtoMessage()

func (*LogEvent) ProtoReflect 

func (x *LogEvent) ProtoReflect() protoreflect.Message

func (*LogEvent) Reset 

func (x *LogEvent) Reset()

func (*LogEvent) String 

func (x *LogEvent) String() string

type MemberInfo 

type MemberInfo struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Addr   string            `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Status string            `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Tags   map[string]string `` /* 135-byte string literal not displayed */
	Leader bool              `protobuf:"varint,5,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

MemberInfo is the RPC-facing view of a Serf cluster member.

func (*MemberInfo) Descriptor deprecated 

func (*MemberInfo) Descriptor() ([]byte, []int)

Deprecated: Use MemberInfo.ProtoReflect.Descriptor instead.

func (*MemberInfo) GetAddr 

func (x *MemberInfo) GetAddr() string

func (*MemberInfo) GetLeader 

func (x *MemberInfo) GetLeader() bool

func (*MemberInfo) GetName 

func (x *MemberInfo) GetName() string

func (*MemberInfo) GetStatus 

func (x *MemberInfo) GetStatus() string

func (*MemberInfo) GetTags 

func (x *MemberInfo) GetTags() map[string]string

func (*MemberInfo) ProtoMessage 

func (*MemberInfo) ProtoMessage()

func (*MemberInfo) ProtoReflect 

func (x *MemberInfo) ProtoReflect() protoreflect.Message

func (*MemberInfo) Reset 

func (x *MemberInfo) Reset()

func (*MemberInfo) String 

func (x *MemberInfo) String() string

type MembersRequest 

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

MembersRequest is empty so fields can be added later without a signature change.

func (*MembersRequest) Descriptor deprecated 

func (*MembersRequest) Descriptor() ([]byte, []int)

Deprecated: Use MembersRequest.ProtoReflect.Descriptor instead.

func (*MembersRequest) ProtoMessage 

func (*MembersRequest) ProtoMessage()

func (*MembersRequest) ProtoReflect 

func (x *MembersRequest) ProtoReflect() protoreflect.Message

func (*MembersRequest) Reset 

func (x *MembersRequest) Reset()

func (*MembersRequest) String 

func (x *MembersRequest) String() string

type MembersResponse 

type MembersResponse struct {
	Members []*MemberInfo `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

func (*MembersResponse) Descriptor deprecated 

func (*MembersResponse) Descriptor() ([]byte, []int)

Deprecated: Use MembersResponse.ProtoReflect.Descriptor instead.

func (*MembersResponse) GetMembers 

func (x *MembersResponse) GetMembers() []*MemberInfo

func (*MembersResponse) ProtoMessage 

func (*MembersResponse) ProtoMessage()

func (*MembersResponse) ProtoReflect 

func (x *MembersResponse) ProtoReflect() protoreflect.Message

func (*MembersResponse) Reset 

func (x *MembersResponse) Reset()

func (*MembersResponse) String 

func (x *MembersResponse) String() string

type MigrateBegin 

type MigrateBegin struct {
	InstanceUuid []byte `protobuf:"bytes,1,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"`
	// Where the instance is going. The source is not named: it is
	// whatever node_id the instance record already holds, and taking it
	// from the request would let a stale proposer rewrite history.
	TargetNodeId string `protobuf:"bytes,2,opt,name=target_node_id,json=targetNodeId,proto3" json:"target_node_id,omitempty"`
	// Which checkpoint this migration will transfer. Increments per
	// dump, so a retried migration never reuses an earlier image.
	CheckpointEpoch uint64 `protobuf:"varint,3,opt,name=checkpoint_epoch,json=checkpointEpoch,proto3" json:"checkpoint_epoch,omitempty"`
	// Rights bitmap from the caller's capability token, checked at the
	// FSM before the migration is admitted (defense in depth, mirroring
	// SignalRequest).
	Rights uint64 `protobuf:"varint,4,opt,name=rights,proto3" json:"rights,omitempty"`
	// contains filtered or unexported fields
}

MigrateBegin records the intent to move one instance to another node (research section 4.4, DDR-3/DDR-4).

It does NOT change the instance's lifecycle state. Identity lives in Raft and location lives in gossip, so a migration is a locator event; the log entry exists for the audit trail (parity with SIGNAL under DDR-10) and so the FSM can refuse a second concurrent attempt on the same instance.

func (*MigrateBegin) Descriptor deprecated 

func (*MigrateBegin) Descriptor() ([]byte, []int)

Deprecated: Use MigrateBegin.ProtoReflect.Descriptor instead.

func (*MigrateBegin) GetCheckpointEpoch 

func (x *MigrateBegin) GetCheckpointEpoch() uint64

func (*MigrateBegin) GetInstanceUuid 

func (x *MigrateBegin) GetInstanceUuid() []byte

func (*MigrateBegin) GetRights 

func (x *MigrateBegin) GetRights() uint64

func (*MigrateBegin) GetTargetNodeId 

func (x *MigrateBegin) GetTargetNodeId() string

func (*MigrateBegin) ProtoMessage 

func (*MigrateBegin) ProtoMessage()

func (*MigrateBegin) ProtoReflect 

func (x *MigrateBegin) ProtoReflect() protoreflect.Message

func (*MigrateBegin) Reset 

func (x *MigrateBegin) Reset()

func (*MigrateBegin) String 

func (x *MigrateBegin) String() string

type MigrateCommit 

type MigrateCommit struct {
	InstanceUuid []byte `protobuf:"bytes,1,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"`
	// Must match the in-flight migration's epoch. A commit carrying a
	// stale epoch is a late message from a superseded attempt and is
	// rejected rather than applied to the current one.
	CheckpointEpoch uint64         `protobuf:"varint,2,opt,name=checkpoint_epoch,json=checkpointEpoch,proto3" json:"checkpoint_epoch,omitempty"`
	Outcome         MigrateOutcome `protobuf:"varint,3,opt,name=outcome,proto3,enum=goblin.v1.MigrateOutcome" json:"outcome,omitempty"`
	// contains filtered or unexported fields
}

MigrateCommit closes the migration opened by MigrateBegin.

On COMPLETED the instance record's node_id moves to the target. On ABORTED it is left untouched: the source restores from the same image, which is why a dump stops the process rather than leaving it running.

func (*MigrateCommit) Descriptor deprecated 

func (*MigrateCommit) Descriptor() ([]byte, []int)

Deprecated: Use MigrateCommit.ProtoReflect.Descriptor instead.

func (*MigrateCommit) GetCheckpointEpoch 

func (x *MigrateCommit) GetCheckpointEpoch() uint64

func (*MigrateCommit) GetInstanceUuid 

func (x *MigrateCommit) GetInstanceUuid() []byte

func (*MigrateCommit) GetOutcome 

func (x *MigrateCommit) GetOutcome() MigrateOutcome

func (*MigrateCommit) ProtoMessage 

func (*MigrateCommit) ProtoMessage()

func (*MigrateCommit) ProtoReflect 

func (x *MigrateCommit) ProtoReflect() protoreflect.Message

func (*MigrateCommit) Reset 

func (x *MigrateCommit) Reset()

func (*MigrateCommit) String 

func (x *MigrateCommit) String() string

type MigrateInstanceRequest 

type MigrateInstanceRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	ToNode     string `protobuf:"bytes,2,opt,name=to_node,json=toNode,proto3" json:"to_node,omitempty"`
	// contains filtered or unexported fields
}

MigrateInstanceRequest asks the leader to live-migrate one running instance to another node (GOBLIN-DIV-031). instance_id is the canonical UUID string, as goblinctl prints it - not the raw bytes spec_uuid/instance_uuid use elsewhere in this schema, since this is the field the CLI already passes as a string.

func (*MigrateInstanceRequest) Descriptor deprecated 

func (*MigrateInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use MigrateInstanceRequest.ProtoReflect.Descriptor instead.

func (*MigrateInstanceRequest) GetInstanceId 

func (x *MigrateInstanceRequest) GetInstanceId() string

func (*MigrateInstanceRequest) GetToNode 

func (x *MigrateInstanceRequest) GetToNode() string

func (*MigrateInstanceRequest) ProtoMessage 

func (*MigrateInstanceRequest) ProtoMessage()

func (*MigrateInstanceRequest) ProtoReflect 

func (x *MigrateInstanceRequest) ProtoReflect() protoreflect.Message

func (*MigrateInstanceRequest) Reset 

func (x *MigrateInstanceRequest) Reset()

func (*MigrateInstanceRequest) String 

func (x *MigrateInstanceRequest) String() string

type MigrateInstanceResponse 

type MigrateInstanceResponse struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	FromNode   string `protobuf:"bytes,2,opt,name=from_node,json=fromNode,proto3" json:"from_node,omitempty"`
	ToNode     string `protobuf:"bytes,3,opt,name=to_node,json=toNode,proto3" json:"to_node,omitempty"`
	// contains filtered or unexported fields
}

MigrateInstanceResponse reports the instance's move rather than a formatted sentence.

func (*MigrateInstanceResponse) Descriptor deprecated 

func (*MigrateInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use MigrateInstanceResponse.ProtoReflect.Descriptor instead.

func (*MigrateInstanceResponse) GetFromNode 

func (x *MigrateInstanceResponse) GetFromNode() string

func (*MigrateInstanceResponse) GetInstanceId 

func (x *MigrateInstanceResponse) GetInstanceId() string

func (*MigrateInstanceResponse) GetToNode 

func (x *MigrateInstanceResponse) GetToNode() string

func (*MigrateInstanceResponse) ProtoMessage 

func (*MigrateInstanceResponse) ProtoMessage()

func (*MigrateInstanceResponse) ProtoReflect 

func (x *MigrateInstanceResponse) ProtoReflect() protoreflect.Message

func (*MigrateInstanceResponse) Reset 

func (x *MigrateInstanceResponse) Reset()

func (*MigrateInstanceResponse) String 

func (x *MigrateInstanceResponse) String() string

type MigrateJobRequest 

type MigrateJobRequest struct {
	JobId  string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	ToNode string `protobuf:"bytes,2,opt,name=to_node,json=toNode,proto3" json:"to_node,omitempty"`
	// contains filtered or unexported fields
}

MigrateJobRequest reassigns a job to another node. Distinct from MigrateInstanceRequest: this stops work in one place and starts it in another, and the process does not survive the move.

func (*MigrateJobRequest) Descriptor deprecated 

func (*MigrateJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use MigrateJobRequest.ProtoReflect.Descriptor instead.

func (*MigrateJobRequest) GetJobId 

func (x *MigrateJobRequest) GetJobId() string

func (*MigrateJobRequest) GetToNode 

func (x *MigrateJobRequest) GetToNode() string

func (*MigrateJobRequest) ProtoMessage 

func (*MigrateJobRequest) ProtoMessage()

func (*MigrateJobRequest) ProtoReflect 

func (x *MigrateJobRequest) ProtoReflect() protoreflect.Message

func (*MigrateJobRequest) Reset 

func (x *MigrateJobRequest) Reset()

func (*MigrateJobRequest) String 

func (x *MigrateJobRequest) String() string

type MigrateJobResponse 

type MigrateJobResponse struct {
	JobId  string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	ToNode string `protobuf:"bytes,2,opt,name=to_node,json=toNode,proto3" json:"to_node,omitempty"`
	// contains filtered or unexported fields
}

MigrateJobResponse reports the applied placement rather than a formatted sentence.

func (*MigrateJobResponse) Descriptor deprecated 

func (*MigrateJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use MigrateJobResponse.ProtoReflect.Descriptor instead.

func (*MigrateJobResponse) GetJobId 

func (x *MigrateJobResponse) GetJobId() string

func (*MigrateJobResponse) GetToNode 

func (x *MigrateJobResponse) GetToNode() string

func (*MigrateJobResponse) ProtoMessage 

func (*MigrateJobResponse) ProtoMessage()

func (*MigrateJobResponse) ProtoReflect 

func (x *MigrateJobResponse) ProtoReflect() protoreflect.Message

func (*MigrateJobResponse) Reset 

func (x *MigrateJobResponse) Reset()

func (*MigrateJobResponse) String 

func (x *MigrateJobResponse) String() string

type MigrateOutcome 

type MigrateOutcome int32

MigrateOutcome closes a migration. UNSPECIFIED is rejected rather than treated as either result: a commit whose outcome did not decode must not silently move an instance or silently strand it. 

const (
	MigrateOutcome_MIGRATE_OUTCOME_UNSPECIFIED MigrateOutcome = 0
	MigrateOutcome_MIGRATE_OUTCOME_COMPLETED   MigrateOutcome = 1 // instance now runs on the target
	MigrateOutcome_MIGRATE_OUTCOME_ABORTED     MigrateOutcome = 2 // rolled back; instance stays put
)

func (MigrateOutcome) Descriptor 

func (MigrateOutcome) Descriptor() protoreflect.EnumDescriptor

func (MigrateOutcome) Enum 

func (x MigrateOutcome) Enum() *MigrateOutcome

func (MigrateOutcome) EnumDescriptor deprecated 

func (MigrateOutcome) EnumDescriptor() ([]byte, []int)

Deprecated: Use MigrateOutcome.Descriptor instead.

func (MigrateOutcome) Number 

func (x MigrateOutcome) Number() protoreflect.EnumNumber

func (MigrateOutcome) String 

func (x MigrateOutcome) String() string

func (MigrateOutcome) Type 

func (MigrateOutcome) Type() protoreflect.EnumType

type MigrationRecord 

type MigrationRecord struct {
	InstanceUuid    []byte `protobuf:"bytes,1,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"`
	SourceNodeId    string `protobuf:"bytes,2,opt,name=source_node_id,json=sourceNodeId,proto3" json:"source_node_id,omitempty"`
	TargetNodeId    string `protobuf:"bytes,3,opt,name=target_node_id,json=targetNodeId,proto3" json:"target_node_id,omitempty"`
	CheckpointEpoch uint64 `protobuf:"varint,4,opt,name=checkpoint_epoch,json=checkpointEpoch,proto3" json:"checkpoint_epoch,omitempty"`
	// contains filtered or unexported fields
}

MigrationRecord is one in-flight migration, carried in the FSM snapshot so that concurrency arbitration survives a restart or a replica catching up from a snapshot rather than the log.

func (*MigrationRecord) Descriptor deprecated 

func (*MigrationRecord) Descriptor() ([]byte, []int)

Deprecated: Use MigrationRecord.ProtoReflect.Descriptor instead.

func (*MigrationRecord) GetCheckpointEpoch 

func (x *MigrationRecord) GetCheckpointEpoch() uint64

func (*MigrationRecord) GetInstanceUuid 

func (x *MigrationRecord) GetInstanceUuid() []byte

func (*MigrationRecord) GetSourceNodeId 

func (x *MigrationRecord) GetSourceNodeId() string

func (*MigrationRecord) GetTargetNodeId 

func (x *MigrationRecord) GetTargetNodeId() string

func (*MigrationRecord) ProtoMessage 

func (*MigrationRecord) ProtoMessage()

func (*MigrationRecord) ProtoReflect 

func (x *MigrationRecord) ProtoReflect() protoreflect.Message

func (*MigrationRecord) Reset 

func (x *MigrationRecord) Reset()

func (*MigrationRecord) String 

func (x *MigrationRecord) String() string

type NodeCheckpointAgentInstanceRequest 

type NodeCheckpointAgentInstanceRequest struct {
	InstanceId   string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	InstanceUuid []byte `protobuf:"bytes,2,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"`
	Epoch        uint64 `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// contains filtered or unexported fields
}

NodeCheckpointAgentInstanceRequest asks a node to dump one instance it is running (GOBLIN-DIV-031). instance_id travels for diagnostics only - the checkpoint store is keyed by {instance_uuid, epoch}.

func (*NodeCheckpointAgentInstanceRequest) Descriptor deprecated 

func (*NodeCheckpointAgentInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use NodeCheckpointAgentInstanceRequest.ProtoReflect.Descriptor instead.

func (*NodeCheckpointAgentInstanceRequest) GetEpoch 

func (x *NodeCheckpointAgentInstanceRequest) GetEpoch() uint64

func (*NodeCheckpointAgentInstanceRequest) GetInstanceId 

func (x *NodeCheckpointAgentInstanceRequest) GetInstanceId() string

func (*NodeCheckpointAgentInstanceRequest) GetInstanceUuid 

func (x *NodeCheckpointAgentInstanceRequest) GetInstanceUuid() []byte

func (*NodeCheckpointAgentInstanceRequest) ProtoMessage 

func (*NodeCheckpointAgentInstanceRequest) ProtoMessage()

func (*NodeCheckpointAgentInstanceRequest) ProtoReflect 

func (x *NodeCheckpointAgentInstanceRequest) ProtoReflect() protoreflect.Message

func (*NodeCheckpointAgentInstanceRequest) Reset 

func (x *NodeCheckpointAgentInstanceRequest) Reset()

func (*NodeCheckpointAgentInstanceRequest) String 

func (x *NodeCheckpointAgentInstanceRequest) String() string

type NodeCheckpointAgentInstanceResponse 

type NodeCheckpointAgentInstanceResponse struct {
	ImageDir string `protobuf:"bytes,1,opt,name=image_dir,json=imageDir,proto3" json:"image_dir,omitempty"`
	// contains filtered or unexported fields
}

NodeCheckpointAgentInstanceResponse reports the local image directory the dump landed in rather than a formatted sentence.

func (*NodeCheckpointAgentInstanceResponse) Descriptor deprecated 

func (*NodeCheckpointAgentInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use NodeCheckpointAgentInstanceResponse.ProtoReflect.Descriptor instead.

func (*NodeCheckpointAgentInstanceResponse) GetImageDir 

func (x *NodeCheckpointAgentInstanceResponse) GetImageDir() string

func (*NodeCheckpointAgentInstanceResponse) ProtoMessage 

func (*NodeCheckpointAgentInstanceResponse) ProtoMessage()

func (*NodeCheckpointAgentInstanceResponse) ProtoReflect 

func (x *NodeCheckpointAgentInstanceResponse) ProtoReflect() protoreflect.Message

func (*NodeCheckpointAgentInstanceResponse) Reset 

func (x *NodeCheckpointAgentInstanceResponse) Reset()

func (*NodeCheckpointAgentInstanceResponse) String 

func (x *NodeCheckpointAgentInstanceResponse) String() string

type NodeMigrationReadyRequest 

type NodeMigrationReadyRequest struct {

	// instance_id is carried for logging only; readiness is a property of
	// the node, not of the instance being moved.
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

NodeMigrationReadyRequest asks a prospective DESTINATION whether it can accept a migration, before the source is stopped.

GOBLIN-DIV-048: the coordinator used to find out at the pull, which is step three - after the checkpoint has already killed the source process. A destination that had joined gossip but not yet applied any raft entry refused the pull, and the instance had to be rolled back from its image. Serf membership is not consensus membership, and the scheduler treated them as the same thing.

The probe is sound rather than a narrower race because the predicate is MONOTONIC: the operator key registry is seeded once and the FSM refuses to remove the last key, so a destination that reports ready cannot become unready before the pull.

func (*NodeMigrationReadyRequest) Descriptor deprecated 

func (*NodeMigrationReadyRequest) Descriptor() ([]byte, []int)

Deprecated: Use NodeMigrationReadyRequest.ProtoReflect.Descriptor instead.

func (*NodeMigrationReadyRequest) GetInstanceId 

func (x *NodeMigrationReadyRequest) GetInstanceId() string

func (*NodeMigrationReadyRequest) ProtoMessage 

func (*NodeMigrationReadyRequest) ProtoMessage()

func (*NodeMigrationReadyRequest) ProtoReflect 

func (x *NodeMigrationReadyRequest) ProtoReflect() protoreflect.Message

func (*NodeMigrationReadyRequest) Reset 

func (x *NodeMigrationReadyRequest) Reset()

func (*NodeMigrationReadyRequest) String 

func (x *NodeMigrationReadyRequest) String() string

type NodeMigrationReadyResponse 

type NodeMigrationReadyResponse struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// reason is empty when ready; otherwise it names what is missing.
	Reason         string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	RegistrySerial uint64 `protobuf:"varint,3,opt,name=registry_serial,json=registrySerial,proto3" json:"registry_serial,omitempty"`
	AppliedIndex   uint64 `protobuf:"varint,4,opt,name=applied_index,json=appliedIndex,proto3" json:"applied_index,omitempty"`
	CommitIndex    uint64 `protobuf:"varint,5,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	// contains filtered or unexported fields
}

NodeMigrationReadyResponse reports the destination's own view of itself. The fields are the ones GOBLIN-DIV-048 needed to tell "not caught up" from "genuinely absent", so a refusal explains itself instead of being reduced to a boolean.

func (*NodeMigrationReadyResponse) Descriptor deprecated 

func (*NodeMigrationReadyResponse) Descriptor() ([]byte, []int)

Deprecated: Use NodeMigrationReadyResponse.ProtoReflect.Descriptor instead.

func (*NodeMigrationReadyResponse) GetAppliedIndex 

func (x *NodeMigrationReadyResponse) GetAppliedIndex() uint64

func (*NodeMigrationReadyResponse) GetCommitIndex 

func (x *NodeMigrationReadyResponse) GetCommitIndex() uint64

func (*NodeMigrationReadyResponse) GetReady 

func (x *NodeMigrationReadyResponse) GetReady() bool

func (*NodeMigrationReadyResponse) GetReason 

func (x *NodeMigrationReadyResponse) GetReason() string

func (*NodeMigrationReadyResponse) GetRegistrySerial 

func (x *NodeMigrationReadyResponse) GetRegistrySerial() uint64

func (*NodeMigrationReadyResponse) ProtoMessage 

func (*NodeMigrationReadyResponse) ProtoMessage()

func (*NodeMigrationReadyResponse) ProtoReflect 

func (x *NodeMigrationReadyResponse) ProtoReflect() protoreflect.Message

func (*NodeMigrationReadyResponse) Reset 

func (x *NodeMigrationReadyResponse) Reset()

func (*NodeMigrationReadyResponse) String 

func (x *NodeMigrationReadyResponse) String() string

type NodePullCheckpointRequest 

type NodePullCheckpointRequest struct {
	InstanceId   string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	InstanceUuid []byte `protobuf:"bytes,2,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"`
	Epoch        uint64 `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
	SourceAddr   string `protobuf:"bytes,4,opt,name=source_addr,json=sourceAddr,proto3" json:"source_addr,omitempty"`
	Token        []byte `protobuf:"bytes,5,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

NodePullCheckpointRequest asks a node to fetch an image from a peer. This is sent to the DESTINATION, which does the dialing - the coordinator runs on the leader, which is frequently neither end of the transfer, and routing bytes through it would put a multi-gigabyte stream on the node running consensus.

func (*NodePullCheckpointRequest) Descriptor deprecated 

func (*NodePullCheckpointRequest) Descriptor() ([]byte, []int)

Deprecated: Use NodePullCheckpointRequest.ProtoReflect.Descriptor instead.

func (*NodePullCheckpointRequest) GetEpoch 

func (x *NodePullCheckpointRequest) GetEpoch() uint64

func (*NodePullCheckpointRequest) GetInstanceId 

func (x *NodePullCheckpointRequest) GetInstanceId() string

func (*NodePullCheckpointRequest) GetInstanceUuid 

func (x *NodePullCheckpointRequest) GetInstanceUuid() []byte

func (*NodePullCheckpointRequest) GetSourceAddr 

func (x *NodePullCheckpointRequest) GetSourceAddr() string

func (*NodePullCheckpointRequest) GetToken 

func (x *NodePullCheckpointRequest) GetToken() []byte

func (*NodePullCheckpointRequest) ProtoMessage 

func (*NodePullCheckpointRequest) ProtoMessage()

func (*NodePullCheckpointRequest) ProtoReflect 

func (x *NodePullCheckpointRequest) ProtoReflect() protoreflect.Message

func (*NodePullCheckpointRequest) Reset 

func (x *NodePullCheckpointRequest) Reset()

func (*NodePullCheckpointRequest) String 

func (x *NodePullCheckpointRequest) String() string

type NodePullCheckpointResponse 

type NodePullCheckpointResponse struct {
	ImageDir string `protobuf:"bytes,1,opt,name=image_dir,json=imageDir,proto3" json:"image_dir,omitempty"`
	// contains filtered or unexported fields
}

NodePullCheckpointResponse reports the local image directory the pull landed in rather than a formatted sentence.

func (*NodePullCheckpointResponse) Descriptor deprecated 

func (*NodePullCheckpointResponse) Descriptor() ([]byte, []int)

Deprecated: Use NodePullCheckpointResponse.ProtoReflect.Descriptor instead.

func (*NodePullCheckpointResponse) GetImageDir 

func (x *NodePullCheckpointResponse) GetImageDir() string

func (*NodePullCheckpointResponse) ProtoMessage 

func (*NodePullCheckpointResponse) ProtoMessage()

func (*NodePullCheckpointResponse) ProtoReflect 

func (x *NodePullCheckpointResponse) ProtoReflect() protoreflect.Message

func (*NodePullCheckpointResponse) Reset 

func (x *NodePullCheckpointResponse) Reset()

func (*NodePullCheckpointResponse) String 

func (x *NodePullCheckpointResponse) String() string

type NodeRestoreAgentInstanceRequest 

type NodeRestoreAgentInstanceRequest struct {
	InstanceId   string     `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	InstanceUuid []byte     `protobuf:"bytes,2,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"`
	Epoch        uint64     `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Spec         *AgentSpec `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

NodeRestoreAgentInstanceRequest asks a node to restore an instance from an image already present in its own store. spec is required: a fresh registration (the destination side of a migration) has no other way to learn the agent type to instantiate.

func (*NodeRestoreAgentInstanceRequest) Descriptor deprecated 

func (*NodeRestoreAgentInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use NodeRestoreAgentInstanceRequest.ProtoReflect.Descriptor instead.

func (*NodeRestoreAgentInstanceRequest) GetEpoch 

func (x *NodeRestoreAgentInstanceRequest) GetEpoch() uint64

func (*NodeRestoreAgentInstanceRequest) GetInstanceId 

func (x *NodeRestoreAgentInstanceRequest) GetInstanceId() string

func (*NodeRestoreAgentInstanceRequest) GetInstanceUuid 

func (x *NodeRestoreAgentInstanceRequest) GetInstanceUuid() []byte

func (*NodeRestoreAgentInstanceRequest) GetSpec 

func (x *NodeRestoreAgentInstanceRequest) GetSpec() *AgentSpec

func (*NodeRestoreAgentInstanceRequest) ProtoMessage 

func (*NodeRestoreAgentInstanceRequest) ProtoMessage()

func (*NodeRestoreAgentInstanceRequest) ProtoReflect 

func (x *NodeRestoreAgentInstanceRequest) ProtoReflect() protoreflect.Message

func (*NodeRestoreAgentInstanceRequest) Reset 

func (x *NodeRestoreAgentInstanceRequest) Reset()

func (*NodeRestoreAgentInstanceRequest) String 

func (x *NodeRestoreAgentInstanceRequest) String() string

type NodeRestoreAgentInstanceResponse 

type NodeRestoreAgentInstanceResponse struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

NodeRestoreAgentInstanceResponse reports the instance that was restored rather than a formatted sentence.

func (*NodeRestoreAgentInstanceResponse) Descriptor deprecated 

func (*NodeRestoreAgentInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use NodeRestoreAgentInstanceResponse.ProtoReflect.Descriptor instead.

func (*NodeRestoreAgentInstanceResponse) GetInstanceId 

func (x *NodeRestoreAgentInstanceResponse) GetInstanceId() string

func (*NodeRestoreAgentInstanceResponse) ProtoMessage 

func (*NodeRestoreAgentInstanceResponse) ProtoMessage()

func (*NodeRestoreAgentInstanceResponse) ProtoReflect 

func (x *NodeRestoreAgentInstanceResponse) ProtoReflect() protoreflect.Message

func (*NodeRestoreAgentInstanceResponse) Reset 

func (x *NodeRestoreAgentInstanceResponse) Reset()

func (*NodeRestoreAgentInstanceResponse) String 

func (x *NodeRestoreAgentInstanceResponse) String() string

type NodeSignalAgentInstanceRequest 

type NodeSignalAgentInstanceRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Signum     int32  `protobuf:"varint,2,opt,name=signum,proto3" json:"signum,omitempty"`
	// contains filtered or unexported fields
}

NodeSignalAgentInstanceRequest delivers an authorized signal to an instance on this node. instance_id is the canonical UUID string, as goblinctl prints it - not the raw bytes spec_uuid/instance_uuid use elsewhere in this schema, matching SchedulerRPC's SignalAgentInstanceRequest.

func (*NodeSignalAgentInstanceRequest) Descriptor deprecated 

func (*NodeSignalAgentInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use NodeSignalAgentInstanceRequest.ProtoReflect.Descriptor instead.

func (*NodeSignalAgentInstanceRequest) GetInstanceId 

func (x *NodeSignalAgentInstanceRequest) GetInstanceId() string

func (*NodeSignalAgentInstanceRequest) GetSignum 

func (x *NodeSignalAgentInstanceRequest) GetSignum() int32

func (*NodeSignalAgentInstanceRequest) ProtoMessage 

func (*NodeSignalAgentInstanceRequest) ProtoMessage()

func (*NodeSignalAgentInstanceRequest) ProtoReflect 

func (x *NodeSignalAgentInstanceRequest) ProtoReflect() protoreflect.Message

func (*NodeSignalAgentInstanceRequest) Reset 

func (x *NodeSignalAgentInstanceRequest) Reset()

func (*NodeSignalAgentInstanceRequest) String 

func (x *NodeSignalAgentInstanceRequest) String() string

type NodeSignalAgentInstanceResponse 

type NodeSignalAgentInstanceResponse struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Signum     int32  `protobuf:"varint,2,opt,name=signum,proto3" json:"signum,omitempty"`
	// contains filtered or unexported fields
}

NodeSignalAgentInstanceResponse reports the delivered signal rather than a formatted sentence.

func (*NodeSignalAgentInstanceResponse) Descriptor deprecated 

func (*NodeSignalAgentInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use NodeSignalAgentInstanceResponse.ProtoReflect.Descriptor instead.

func (*NodeSignalAgentInstanceResponse) GetInstanceId 

func (x *NodeSignalAgentInstanceResponse) GetInstanceId() string

func (*NodeSignalAgentInstanceResponse) GetSignum 

func (x *NodeSignalAgentInstanceResponse) GetSignum() int32

func (*NodeSignalAgentInstanceResponse) ProtoMessage 

func (*NodeSignalAgentInstanceResponse) ProtoMessage()

func (*NodeSignalAgentInstanceResponse) ProtoReflect 

func (x *NodeSignalAgentInstanceResponse) ProtoReflect() protoreflect.Message

func (*NodeSignalAgentInstanceResponse) Reset 

func (x *NodeSignalAgentInstanceResponse) Reset()

func (*NodeSignalAgentInstanceResponse) String 

func (x *NodeSignalAgentInstanceResponse) String() string

type NodeStartAgentInstanceRequest 

type NodeStartAgentInstanceRequest struct {
	InstanceId string     `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Spec       *AgentSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

NodeStartAgentInstanceRequest instantiates and starts a spec's agent type under instance_id. spec is required: the node has no other way to learn which agent type to instantiate.

func (*NodeStartAgentInstanceRequest) Descriptor deprecated 

func (*NodeStartAgentInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use NodeStartAgentInstanceRequest.ProtoReflect.Descriptor instead.

func (*NodeStartAgentInstanceRequest) GetInstanceId 

func (x *NodeStartAgentInstanceRequest) GetInstanceId() string

func (*NodeStartAgentInstanceRequest) GetSpec 

func (x *NodeStartAgentInstanceRequest) GetSpec() *AgentSpec

func (*NodeStartAgentInstanceRequest) ProtoMessage 

func (*NodeStartAgentInstanceRequest) ProtoMessage()

func (*NodeStartAgentInstanceRequest) ProtoReflect 

func (x *NodeStartAgentInstanceRequest) ProtoReflect() protoreflect.Message

func (*NodeStartAgentInstanceRequest) Reset 

func (x *NodeStartAgentInstanceRequest) Reset()

func (*NodeStartAgentInstanceRequest) String 

func (x *NodeStartAgentInstanceRequest) String() string

type NodeStartAgentInstanceResponse 

type NodeStartAgentInstanceResponse struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

NodeStartAgentInstanceResponse reports the instance that was started rather than a formatted sentence.

func (*NodeStartAgentInstanceResponse) Descriptor deprecated 

func (*NodeStartAgentInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use NodeStartAgentInstanceResponse.ProtoReflect.Descriptor instead.

func (*NodeStartAgentInstanceResponse) GetInstanceId 

func (x *NodeStartAgentInstanceResponse) GetInstanceId() string

func (*NodeStartAgentInstanceResponse) ProtoMessage 

func (*NodeStartAgentInstanceResponse) ProtoMessage()

func (*NodeStartAgentInstanceResponse) ProtoReflect 

func (x *NodeStartAgentInstanceResponse) ProtoReflect() protoreflect.Message

func (*NodeStartAgentInstanceResponse) Reset 

func (x *NodeStartAgentInstanceResponse) Reset()

func (*NodeStartAgentInstanceResponse) String 

func (x *NodeStartAgentInstanceResponse) String() string

type NodeStopAgentInstanceRequest 

type NodeStopAgentInstanceRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

NodeStopAgentInstanceRequest stops and deregisters an instance.

func (*NodeStopAgentInstanceRequest) Descriptor deprecated 

func (*NodeStopAgentInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use NodeStopAgentInstanceRequest.ProtoReflect.Descriptor instead.

func (*NodeStopAgentInstanceRequest) GetInstanceId 

func (x *NodeStopAgentInstanceRequest) GetInstanceId() string

func (*NodeStopAgentInstanceRequest) ProtoMessage 

func (*NodeStopAgentInstanceRequest) ProtoMessage()

func (*NodeStopAgentInstanceRequest) ProtoReflect 

func (x *NodeStopAgentInstanceRequest) ProtoReflect() protoreflect.Message

func (*NodeStopAgentInstanceRequest) Reset 

func (x *NodeStopAgentInstanceRequest) Reset()

func (*NodeStopAgentInstanceRequest) String 

func (x *NodeStopAgentInstanceRequest) String() string

type NodeStopAgentInstanceResponse 

type NodeStopAgentInstanceResponse struct {
	InstanceId     string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	AlreadyStopped bool   `protobuf:"varint,2,opt,name=already_stopped,json=alreadyStopped,proto3" json:"already_stopped,omitempty"`
	// contains filtered or unexported fields
}

NodeStopAgentInstanceResponse reports the instance that was stopped. already_stopped distinguishes a real stop from the no-op case where the instance was already gone - both succeed, but a caller may care which happened.

func (*NodeStopAgentInstanceResponse) Descriptor deprecated 

func (*NodeStopAgentInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use NodeStopAgentInstanceResponse.ProtoReflect.Descriptor instead.

func (*NodeStopAgentInstanceResponse) GetAlreadyStopped 

func (x *NodeStopAgentInstanceResponse) GetAlreadyStopped() bool

func (*NodeStopAgentInstanceResponse) GetInstanceId 

func (x *NodeStopAgentInstanceResponse) GetInstanceId() string

func (*NodeStopAgentInstanceResponse) ProtoMessage 

func (*NodeStopAgentInstanceResponse) ProtoMessage()

func (*NodeStopAgentInstanceResponse) ProtoReflect 

func (x *NodeStopAgentInstanceResponse) ProtoReflect() protoreflect.Message

func (*NodeStopAgentInstanceResponse) Reset 

func (x *NodeStopAgentInstanceResponse) Reset()

func (*NodeStopAgentInstanceResponse) String 

func (x *NodeStopAgentInstanceResponse) String() string

type OperatorKey 

type OperatorKey struct {
	KeyId     string `protobuf:"bytes,1,opt,name=key_id,json=keyId,proto3" json:"key_id,omitempty"`             // hex(sha256(public_key))
	PublicKey []byte `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` // raw 32-byte Ed25519 public key
	Comment   string `protobuf:"bytes,3,opt,name=comment,proto3" json:"comment,omitempty"`                      // operator-facing label; not authenticated
	// contains filtered or unexported fields
}

OperatorKey is one authorized operator identity.

key_id is DERIVED, never asserted: it must equal the lowercase hex SHA-256 of public_key, and the FSM refuses a record where it does not. Deriving the id from the key removes the class of bug where the id names one key and the bytes are another.

func (*OperatorKey) Descriptor deprecated 

func (*OperatorKey) Descriptor() ([]byte, []int)

Deprecated: Use OperatorKey.ProtoReflect.Descriptor instead.

func (*OperatorKey) GetComment 

func (x *OperatorKey) GetComment() string

func (*OperatorKey) GetKeyId 

func (x *OperatorKey) GetKeyId() string

func (*OperatorKey) GetPublicKey 

func (x *OperatorKey) GetPublicKey() []byte

func (*OperatorKey) ProtoMessage 

func (*OperatorKey) ProtoMessage()

func (*OperatorKey) ProtoReflect 

func (x *OperatorKey) ProtoReflect() protoreflect.Message

func (*OperatorKey) Reset 

func (x *OperatorKey) Reset()

func (*OperatorKey) String 

func (x *OperatorKey) String() string

type OperatorKeyChange 

type OperatorKeyChange struct {
	Payload   []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`     // serialized OperatorKeyChangePayload
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // Ed25519 over payload bytes
	// contains filtered or unexported fields
}

OperatorKeyChange wraps the signed payload. As with CapabilityToken, the signature covers the literal payload bytes - protobuf serialization is not canonical, so the FSM verifies the bytes that arrived in the log and never re-serializes before checking.

func (*OperatorKeyChange) Descriptor deprecated 

func (*OperatorKeyChange) Descriptor() ([]byte, []int)

Deprecated: Use OperatorKeyChange.ProtoReflect.Descriptor instead.

func (*OperatorKeyChange) GetPayload 

func (x *OperatorKeyChange) GetPayload() []byte

func (*OperatorKeyChange) GetSignature 

func (x *OperatorKeyChange) GetSignature() []byte

func (*OperatorKeyChange) ProtoMessage 

func (*OperatorKeyChange) ProtoMessage()

func (*OperatorKeyChange) ProtoReflect 

func (x *OperatorKeyChange) ProtoReflect() protoreflect.Message

func (*OperatorKeyChange) Reset 

func (x *OperatorKeyChange) Reset()

func (*OperatorKeyChange) String 

func (x *OperatorKeyChange) String() string

type OperatorKeyChangePayload 

type OperatorKeyChangePayload struct {
	Op OperatorKeyOp `protobuf:"varint,1,opt,name=op,proto3,enum=goblin.v1.OperatorKeyOp" json:"op,omitempty"`
	// For ADD, the full record. For REMOVE, only key_id is read; any
	// public_key present is ignored rather than checked, since the
	// registry already holds the authoritative bytes.
	Key              *OperatorKey `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	PrevSerial       uint64       `protobuf:"varint,3,opt,name=prev_serial,json=prevSerial,proto3" json:"prev_serial,omitempty"`
	AuthorizingKeyId string       `protobuf:"bytes,4,opt,name=authorizing_key_id,json=authorizingKeyId,proto3" json:"authorizing_key_id,omitempty"`
	// contains filtered or unexported fields
}

OperatorKeyChangePayload is the signed content of a registry change.

prev_serial is the replay guard and it is deliberately a counter, not an expiry: the FSM must decide identically on every replica, and a wall-clock comparison inside Apply is not deterministic. A signed change is valid at exactly one registry serial.

func (*OperatorKeyChangePayload) Descriptor deprecated 

func (*OperatorKeyChangePayload) Descriptor() ([]byte, []int)

Deprecated: Use OperatorKeyChangePayload.ProtoReflect.Descriptor instead.

func (*OperatorKeyChangePayload) GetAuthorizingKeyId 

func (x *OperatorKeyChangePayload) GetAuthorizingKeyId() string

func (*OperatorKeyChangePayload) GetKey 

func (x *OperatorKeyChangePayload) GetKey() *OperatorKey

func (*OperatorKeyChangePayload) GetOp 

func (x *OperatorKeyChangePayload) GetOp() OperatorKeyOp

func (*OperatorKeyChangePayload) GetPrevSerial 

func (x *OperatorKeyChangePayload) GetPrevSerial() uint64

func (*OperatorKeyChangePayload) ProtoMessage 

func (*OperatorKeyChangePayload) ProtoMessage()

func (*OperatorKeyChangePayload) ProtoReflect 

func (x *OperatorKeyChangePayload) ProtoReflect() protoreflect.Message

func (*OperatorKeyChangePayload) Reset 

func (x *OperatorKeyChangePayload) Reset()

func (*OperatorKeyChangePayload) String 

func (x *OperatorKeyChangePayload) String() string

type OperatorKeyOp 

type OperatorKeyOp int32

OperatorKeyOp names the mutation an OperatorKeyChangePayload requests. UNSPECIFIED is rejected rather than defaulted: a change whose op did not decode must not silently become an add. 

const (
	OperatorKeyOp_OPERATOR_KEY_OP_UNSPECIFIED OperatorKeyOp = 0
	OperatorKeyOp_OPERATOR_KEY_OP_ADD         OperatorKeyOp = 1
	OperatorKeyOp_OPERATOR_KEY_OP_REMOVE      OperatorKeyOp = 2
)

func (OperatorKeyOp) Descriptor 

func (OperatorKeyOp) Descriptor() protoreflect.EnumDescriptor

func (OperatorKeyOp) Enum 

func (x OperatorKeyOp) Enum() *OperatorKeyOp

func (OperatorKeyOp) EnumDescriptor deprecated 

func (OperatorKeyOp) EnumDescriptor() ([]byte, []int)

Deprecated: Use OperatorKeyOp.Descriptor instead.

func (OperatorKeyOp) Number 

func (x OperatorKeyOp) Number() protoreflect.EnumNumber

func (OperatorKeyOp) String 

func (x OperatorKeyOp) String() string

func (OperatorKeyOp) Type 

func (OperatorKeyOp) Type() protoreflect.EnumType

type OperatorKeySeed 

type OperatorKeySeed struct {
	Keys []*OperatorKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

OperatorKeySeed installs the configured root-of-trust keys.

It carries no signature because there is nothing yet to sign against: it is authorized by the registry being empty, which is replicated FSM state and therefore a deterministic check. Re-seeding an identical set is a no-op so a node restart does not fail; seeding a DIFFERENT set into a non-empty registry is refused, which is how config drift between nodes surfaces instead of silently widening the trust root.

func (*OperatorKeySeed) Descriptor deprecated 

func (*OperatorKeySeed) Descriptor() ([]byte, []int)

Deprecated: Use OperatorKeySeed.ProtoReflect.Descriptor instead.

func (*OperatorKeySeed) GetKeys 

func (x *OperatorKeySeed) GetKeys() []*OperatorKey

func (*OperatorKeySeed) ProtoMessage 

func (*OperatorKeySeed) ProtoMessage()

func (*OperatorKeySeed) ProtoReflect 

func (x *OperatorKeySeed) ProtoReflect() protoreflect.Message

func (*OperatorKeySeed) Reset 

func (x *OperatorKeySeed) Reset()

func (*OperatorKeySeed) String 

func (x *OperatorKeySeed) String() string

type PublishEventRequest 

type PublishEventRequest struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

PublishEventRequest forwards to membership (Serf) UserEvent. payload stays opaque bytes here; typing the event envelope itself is a separate piece of work (Serf events), not this one.

func (*PublishEventRequest) Descriptor deprecated 

func (*PublishEventRequest) Descriptor() ([]byte, []int)

Deprecated: Use PublishEventRequest.ProtoReflect.Descriptor instead.

func (*PublishEventRequest) GetPayload 

func (x *PublishEventRequest) GetPayload() []byte

func (*PublishEventRequest) GetTopic 

func (x *PublishEventRequest) GetTopic() string

func (*PublishEventRequest) ProtoMessage 

func (*PublishEventRequest) ProtoMessage()

func (*PublishEventRequest) ProtoReflect 

func (x *PublishEventRequest) ProtoReflect() protoreflect.Message

func (*PublishEventRequest) Reset 

func (x *PublishEventRequest) Reset()

func (*PublishEventRequest) String 

func (x *PublishEventRequest) String() string

type PublishEventResponse 

type PublishEventResponse struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

PublishEventResponse confirms the topic that was published rather than a formatted sentence.

func (*PublishEventResponse) Descriptor deprecated 

func (*PublishEventResponse) Descriptor() ([]byte, []int)

Deprecated: Use PublishEventResponse.ProtoReflect.Descriptor instead.

func (*PublishEventResponse) GetTopic 

func (x *PublishEventResponse) GetTopic() string

func (*PublishEventResponse) ProtoMessage 

func (*PublishEventResponse) ProtoMessage()

func (*PublishEventResponse) ProtoReflect 

func (x *PublishEventResponse) ProtoReflect() protoreflect.Message

func (*PublishEventResponse) Reset 

func (x *PublishEventResponse) Reset()

func (*PublishEventResponse) String 

func (x *PublishEventResponse) String() string

type RPCError 

type RPCError struct {
	Code    RPCErrorCode `protobuf:"varint,1,opt,name=code,proto3,enum=goblin.v1.RPCErrorCode" json:"code,omitempty"`
	Message string       `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

RPCError is the typed failure carried by RPCResponse.

func (*RPCError) Descriptor deprecated 

func (*RPCError) Descriptor() ([]byte, []int)

Deprecated: Use RPCError.ProtoReflect.Descriptor instead.

func (*RPCError) GetCode 

func (x *RPCError) GetCode() RPCErrorCode

func (*RPCError) GetMessage 

func (x *RPCError) GetMessage() string

func (*RPCError) ProtoMessage 

func (*RPCError) ProtoMessage()

func (*RPCError) ProtoReflect 

func (x *RPCError) ProtoReflect() protoreflect.Message

func (*RPCError) Reset 

func (x *RPCError) Reset()

func (*RPCError) String 

func (x *RPCError) String() string

type RPCErrorCode 

type RPCErrorCode int32

RPCErrorCode classifies a failure so callers branch on the code. Message text is for humans and is never matched on. 

const (
	RPCErrorCode_RPC_ERROR_CODE_UNSPECIFIED       RPCErrorCode = 0
	RPCErrorCode_RPC_ERROR_CODE_INVALID_REQUEST   RPCErrorCode = 1
	RPCErrorCode_RPC_ERROR_CODE_NOT_FOUND         RPCErrorCode = 2
	RPCErrorCode_RPC_ERROR_CODE_PERMISSION_DENIED RPCErrorCode = 3
	RPCErrorCode_RPC_ERROR_CODE_UNAVAILABLE       RPCErrorCode = 4
	RPCErrorCode_RPC_ERROR_CODE_INTERNAL          RPCErrorCode = 5
)

func (RPCErrorCode) Descriptor 

func (RPCErrorCode) Descriptor() protoreflect.EnumDescriptor

func (RPCErrorCode) Enum 

func (x RPCErrorCode) Enum() *RPCErrorCode

func (RPCErrorCode) EnumDescriptor deprecated 

func (RPCErrorCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use RPCErrorCode.Descriptor instead.

func (RPCErrorCode) Number 

func (x RPCErrorCode) Number() protoreflect.EnumNumber

func (RPCErrorCode) String 

func (x RPCErrorCode) String() string

func (RPCErrorCode) Type 

func (RPCErrorCode) Type() protoreflect.EnumType

type RPCRequest 

type RPCRequest struct {
	RequestId uint32 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Method    string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`   // e.g. "SchedulerRPC.ListJobs"
	Payload   []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` // Protobuf-encoded request
	// contains filtered or unexported fields
}

RPC Request message

func (*RPCRequest) Descriptor deprecated 

func (*RPCRequest) Descriptor() ([]byte, []int)

Deprecated: Use RPCRequest.ProtoReflect.Descriptor instead.

func (*RPCRequest) GetMethod 

func (x *RPCRequest) GetMethod() string

func (*RPCRequest) GetPayload 

func (x *RPCRequest) GetPayload() []byte

func (*RPCRequest) GetRequestId 

func (x *RPCRequest) GetRequestId() uint32

func (*RPCRequest) ProtoMessage 

func (*RPCRequest) ProtoMessage()

func (*RPCRequest) ProtoReflect 

func (x *RPCRequest) ProtoReflect() protoreflect.Message

func (*RPCRequest) Reset 

func (x *RPCRequest) Reset()

func (*RPCRequest) String 

func (x *RPCRequest) String() string

type RPCResponse 

type RPCResponse struct {
	RequestId   uint32    `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Success     bool      `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Payload     []byte    `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` // protobuf-encoded response
	ErrorDetail *RPCError `protobuf:"bytes,5,opt,name=error_detail,json=errorDetail,proto3" json:"error_detail,omitempty"`
	// contains filtered or unexported fields
}

RPCResponse carries the reply. success is the discriminator; when it is false, error_detail is populated and payload is empty.

func (*RPCResponse) Descriptor deprecated 

func (*RPCResponse) Descriptor() ([]byte, []int)

Deprecated: Use RPCResponse.ProtoReflect.Descriptor instead.

func (*RPCResponse) GetErrorDetail 

func (x *RPCResponse) GetErrorDetail() *RPCError

func (*RPCResponse) GetPayload 

func (x *RPCResponse) GetPayload() []byte

func (*RPCResponse) GetRequestId 

func (x *RPCResponse) GetRequestId() uint32

func (*RPCResponse) GetSuccess 

func (x *RPCResponse) GetSuccess() bool

func (*RPCResponse) ProtoMessage 

func (*RPCResponse) ProtoMessage()

func (*RPCResponse) ProtoReflect 

func (x *RPCResponse) ProtoReflect() protoreflect.Message

func (*RPCResponse) Reset 

func (x *RPCResponse) Reset()

func (*RPCResponse) String 

func (x *RPCResponse) String() string

type RegisterAgentRequest 

type RegisterAgentRequest struct {
	Spec *AgentSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterAgentRequest) Descriptor deprecated 

func (*RegisterAgentRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterAgentRequest.ProtoReflect.Descriptor instead.

func (*RegisterAgentRequest) GetSpec 

func (x *RegisterAgentRequest) GetSpec() *AgentSpec

func (*RegisterAgentRequest) ProtoMessage 

func (*RegisterAgentRequest) ProtoMessage()

func (*RegisterAgentRequest) ProtoReflect 

func (x *RegisterAgentRequest) ProtoReflect() protoreflect.Message

func (*RegisterAgentRequest) Reset 

func (x *RegisterAgentRequest) Reset()

func (*RegisterAgentRequest) String 

func (x *RegisterAgentRequest) String() string

type RegisterAgentResponse 

type RegisterAgentResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterAgentResponse) Descriptor deprecated 

func (*RegisterAgentResponse) Descriptor() ([]byte, []int)

Deprecated: Use RegisterAgentResponse.ProtoReflect.Descriptor instead.

func (*RegisterAgentResponse) GetMessage 

func (x *RegisterAgentResponse) GetMessage() string

func (*RegisterAgentResponse) GetSuccess 

func (x *RegisterAgentResponse) GetSuccess() bool

func (*RegisterAgentResponse) ProtoMessage 

func (*RegisterAgentResponse) ProtoMessage()

func (*RegisterAgentResponse) ProtoReflect 

func (x *RegisterAgentResponse) ProtoReflect() protoreflect.Message

func (*RegisterAgentResponse) Reset 

func (x *RegisterAgentResponse) Reset()

func (*RegisterAgentResponse) String 

func (x *RegisterAgentResponse) String() string

type RegisterGlobalAgentRequest 

type RegisterGlobalAgentRequest struct {
	Spec *AgentSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

RegisterGlobalAgentRequest registers or updates a global agent spec. spec.spec_uuid is server-owned: RegisterAgent mints it from spec.name when unset. A caller-supplied spec_uuid is rejected, not overwritten (see goblin-typed-rpc-design.md, "Server-owned fields must be rejected, not overwritten").

func (*RegisterGlobalAgentRequest) Descriptor deprecated 

func (*RegisterGlobalAgentRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterGlobalAgentRequest.ProtoReflect.Descriptor instead.

func (*RegisterGlobalAgentRequest) GetSpec 

func (x *RegisterGlobalAgentRequest) GetSpec() *AgentSpec

func (*RegisterGlobalAgentRequest) ProtoMessage 

func (*RegisterGlobalAgentRequest) ProtoMessage()

func (*RegisterGlobalAgentRequest) ProtoReflect 

func (x *RegisterGlobalAgentRequest) ProtoReflect() protoreflect.Message

func (*RegisterGlobalAgentRequest) Reset 

func (x *RegisterGlobalAgentRequest) Reset()

func (*RegisterGlobalAgentRequest) String 

func (x *RegisterGlobalAgentRequest) String() string

type RegisterGlobalAgentResponse 

type RegisterGlobalAgentResponse struct {
	SpecUuid []byte `protobuf:"bytes,1,opt,name=spec_uuid,json=specUuid,proto3" json:"spec_uuid,omitempty"` // spec UUID minted (or confirmed) at registration
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

RegisterGlobalAgentResponse reports the identity assigned to the spec rather than a formatted sentence.

func (*RegisterGlobalAgentResponse) Descriptor deprecated 

func (*RegisterGlobalAgentResponse) Descriptor() ([]byte, []int)

Deprecated: Use RegisterGlobalAgentResponse.ProtoReflect.Descriptor instead.

func (*RegisterGlobalAgentResponse) GetName 

func (x *RegisterGlobalAgentResponse) GetName() string

func (*RegisterGlobalAgentResponse) GetSpecUuid 

func (x *RegisterGlobalAgentResponse) GetSpecUuid() []byte

func (*RegisterGlobalAgentResponse) ProtoMessage 

func (*RegisterGlobalAgentResponse) ProtoMessage()

func (*RegisterGlobalAgentResponse) ProtoReflect 

func (x *RegisterGlobalAgentResponse) ProtoReflect() protoreflect.Message

func (*RegisterGlobalAgentResponse) Reset 

func (x *RegisterGlobalAgentResponse) Reset()

func (*RegisterGlobalAgentResponse) String 

func (x *RegisterGlobalAgentResponse) String() string

type ResourceReq 

type ResourceReq struct {
	Cpu    float64 `protobuf:"fixed64,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory int64   `protobuf:"varint,2,opt,name=memory,proto3" json:"memory,omitempty"` // in bytes
	// contains filtered or unexported fields
}

ResourceReq defines resource requirements

func (*ResourceReq) Descriptor deprecated 

func (*ResourceReq) Descriptor() ([]byte, []int)

Deprecated: Use ResourceReq.ProtoReflect.Descriptor instead.

func (*ResourceReq) GetCpu 

func (x *ResourceReq) GetCpu() float64

func (*ResourceReq) GetMemory 

func (x *ResourceReq) GetMemory() int64

func (*ResourceReq) ProtoMessage 

func (*ResourceReq) ProtoMessage()

func (*ResourceReq) ProtoReflect 

func (x *ResourceReq) ProtoReflect() protoreflect.Message

func (*ResourceReq) Reset 

func (x *ResourceReq) Reset()

func (*ResourceReq) String 

func (x *ResourceReq) String() string

type RevocationGeneration 

type RevocationGeneration struct {
	Index int64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// Exactly bloom_bits/8 bytes. Length-checked on receipt; a filter of
	// any other size is refused as data rather than merged.
	Filter []byte `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

RevocationGeneration is one live generation of a node's revocation filter: the absolute window it covers, and its bytes.

index is floor(unix_seconds / rotation_period), which every node computes identically for the same instant without coordinating. It is what makes periodic exchange safe: the receiver merges each generation into its own generation with the SAME index, so an entry keeps the lifetime it was given when it was revoked instead of being renewed on every tick (GOBLIN-DIV-057).

Signed rather than unsigned, matching the Unix seconds it derives from, so no sign conversion sits on the path that carries it.

func (*RevocationGeneration) Descriptor deprecated 

func (*RevocationGeneration) Descriptor() ([]byte, []int)

Deprecated: Use RevocationGeneration.ProtoReflect.Descriptor instead.

func (*RevocationGeneration) GetFilter 

func (x *RevocationGeneration) GetFilter() []byte

func (*RevocationGeneration) GetIndex 

func (x *RevocationGeneration) GetIndex() int64

func (*RevocationGeneration) ProtoMessage 

func (*RevocationGeneration) ProtoMessage()

func (*RevocationGeneration) ProtoReflect 

func (x *RevocationGeneration) ProtoReflect() protoreflect.Message

func (*RevocationGeneration) Reset 

func (x *RevocationGeneration) Reset()

func (*RevocationGeneration) String 

func (x *RevocationGeneration) String() string

type ScaleAgentRequest 

type ScaleAgentRequest struct {
	AgentId  string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Replicas int32  `protobuf:"varint,2,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

ScaleAgentRequest changes the desired replica count for one spec. agent_id accepts either the spec UUID or the operator-facing name, matching what the CLI already passes.

func (*ScaleAgentRequest) Descriptor deprecated 

func (*ScaleAgentRequest) Descriptor() ([]byte, []int)

Deprecated: Use ScaleAgentRequest.ProtoReflect.Descriptor instead.

func (*ScaleAgentRequest) GetAgentId 

func (x *ScaleAgentRequest) GetAgentId() string

func (*ScaleAgentRequest) GetReplicas 

func (x *ScaleAgentRequest) GetReplicas() int32

func (*ScaleAgentRequest) ProtoMessage 

func (*ScaleAgentRequest) ProtoMessage()

func (*ScaleAgentRequest) ProtoReflect 

func (x *ScaleAgentRequest) ProtoReflect() protoreflect.Message

func (*ScaleAgentRequest) Reset 

func (x *ScaleAgentRequest) Reset()

func (*ScaleAgentRequest) String 

func (x *ScaleAgentRequest) String() string

type ScaleAgentResponse 

type ScaleAgentResponse struct {
	SpecUuid []byte `protobuf:"bytes,1,opt,name=spec_uuid,json=specUuid,proto3" json:"spec_uuid,omitempty"` // 16-byte UUIDv7 of the scaled spec
	Replicas int32  `protobuf:"varint,2,opt,name=replicas,proto3" json:"replicas,omitempty"`                // replica count now recorded
	// contains filtered or unexported fields
}

ScaleAgentResponse reports applied state rather than a formatted sentence. The previous response was a string built with fmt.Sprintf, which a caller could only display, never assert on.

func (*ScaleAgentResponse) Descriptor deprecated 

func (*ScaleAgentResponse) Descriptor() ([]byte, []int)

Deprecated: Use ScaleAgentResponse.ProtoReflect.Descriptor instead.

func (*ScaleAgentResponse) GetReplicas 

func (x *ScaleAgentResponse) GetReplicas() int32

func (*ScaleAgentResponse) GetSpecUuid 

func (x *ScaleAgentResponse) GetSpecUuid() []byte

func (*ScaleAgentResponse) ProtoMessage 

func (*ScaleAgentResponse) ProtoMessage()

func (*ScaleAgentResponse) ProtoReflect 

func (x *ScaleAgentResponse) ProtoReflect() protoreflect.Message

func (*ScaleAgentResponse) Reset 

func (x *ScaleAgentResponse) Reset()

func (*ScaleAgentResponse) String 

func (x *ScaleAgentResponse) String() string

type SignalAgentInstanceRequest 

type SignalAgentInstanceRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Signum     int32  `protobuf:"varint,2,opt,name=signum,proto3" json:"signum,omitempty"`
	// contains filtered or unexported fields
}

SignalAgentInstanceRequest asks the leader to signal an instance (GOBLIN-DIV-017, DDR-10). instance_id is the canonical UUID string, matching MigrateInstanceRequest.

func (*SignalAgentInstanceRequest) Descriptor deprecated 

func (*SignalAgentInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use SignalAgentInstanceRequest.ProtoReflect.Descriptor instead.

func (*SignalAgentInstanceRequest) GetInstanceId 

func (x *SignalAgentInstanceRequest) GetInstanceId() string

func (*SignalAgentInstanceRequest) GetSignum 

func (x *SignalAgentInstanceRequest) GetSignum() int32

func (*SignalAgentInstanceRequest) ProtoMessage 

func (*SignalAgentInstanceRequest) ProtoMessage()

func (*SignalAgentInstanceRequest) ProtoReflect 

func (x *SignalAgentInstanceRequest) ProtoReflect() protoreflect.Message

func (*SignalAgentInstanceRequest) Reset 

func (x *SignalAgentInstanceRequest) Reset()

func (*SignalAgentInstanceRequest) String 

func (x *SignalAgentInstanceRequest) String() string

type SignalAgentInstanceResponse 

type SignalAgentInstanceResponse struct {
	Signum     int32  `protobuf:"varint,1,opt,name=signum,proto3" json:"signum,omitempty"`
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	NodeId     string `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

SignalAgentInstanceResponse reports the authorized delivery rather than a formatted sentence.

func (*SignalAgentInstanceResponse) Descriptor deprecated 

func (*SignalAgentInstanceResponse) Descriptor() ([]byte, []int)

Deprecated: Use SignalAgentInstanceResponse.ProtoReflect.Descriptor instead.

func (*SignalAgentInstanceResponse) GetInstanceId 

func (x *SignalAgentInstanceResponse) GetInstanceId() string

func (*SignalAgentInstanceResponse) GetNodeId 

func (x *SignalAgentInstanceResponse) GetNodeId() string

func (*SignalAgentInstanceResponse) GetSignum 

func (x *SignalAgentInstanceResponse) GetSignum() int32

func (*SignalAgentInstanceResponse) ProtoMessage 

func (*SignalAgentInstanceResponse) ProtoMessage()

func (*SignalAgentInstanceResponse) ProtoReflect 

func (x *SignalAgentInstanceResponse) ProtoReflect() protoreflect.Message

func (*SignalAgentInstanceResponse) Reset 

func (x *SignalAgentInstanceResponse) Reset()

func (*SignalAgentInstanceResponse) String 

func (x *SignalAgentInstanceResponse) String() string

type SignalRequest 

type SignalRequest struct {
	InstanceUuid []byte `protobuf:"bytes,1,opt,name=instance_uuid,json=instanceUuid,proto3" json:"instance_uuid,omitempty"`
	Signum       int32  `protobuf:"varint,2,opt,name=signum,proto3" json:"signum,omitempty"`
	TokenId      []byte `protobuf:"bytes,3,opt,name=token_id,json=tokenId,proto3" json:"token_id,omitempty"` // authorizing capability token id
	Rights       uint64 `protobuf:"varint,4,opt,name=rights,proto3" json:"rights,omitempty"`                 // rights asserted; checked against the bitmap
	// contains filtered or unexported fields
}

SignalRequest commits a signal through the log so it is authorized at the FSM (rights bitmap) and audited. Delivery happens on the target node through the start_epoch + pidfd guard.

func (*SignalRequest) Descriptor deprecated 

func (*SignalRequest) Descriptor() ([]byte, []int)

Deprecated: Use SignalRequest.ProtoReflect.Descriptor instead.

func (*SignalRequest) GetInstanceUuid 

func (x *SignalRequest) GetInstanceUuid() []byte

func (*SignalRequest) GetRights 

func (x *SignalRequest) GetRights() uint64

func (*SignalRequest) GetSignum 

func (x *SignalRequest) GetSignum() int32

func (*SignalRequest) GetTokenId 

func (x *SignalRequest) GetTokenId() []byte

func (*SignalRequest) ProtoMessage 

func (*SignalRequest) ProtoMessage()

func (*SignalRequest) ProtoReflect 

func (x *SignalRequest) ProtoReflect() protoreflect.Message

func (*SignalRequest) Reset 

func (x *SignalRequest) Reset()

func (*SignalRequest) String 

func (x *SignalRequest) String() string

type StreamType 

type StreamType int32

Stream type enum 

const (
	StreamType_STREAM_TYPE_UNSPECIFIED  StreamType = 0
	StreamType_STREAM_TYPE_RPC_REQUEST  StreamType = 1
	StreamType_STREAM_TYPE_RPC_RESPONSE StreamType = 2
	StreamType_STREAM_TYPE_EVENT_STREAM StreamType = 3
)

func (StreamType) Descriptor 

func (StreamType) Descriptor() protoreflect.EnumDescriptor

func (StreamType) Enum 

func (x StreamType) Enum() *StreamType

func (StreamType) EnumDescriptor deprecated 

func (StreamType) EnumDescriptor() ([]byte, []int)

Deprecated: Use StreamType.Descriptor instead.

func (StreamType) Number 

func (x StreamType) Number() protoreflect.EnumNumber

func (StreamType) String 

func (x StreamType) String() string

func (StreamType) Type 

func (StreamType) Type() protoreflect.EnumType

type SubmitJobRequest 

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

func (*SubmitJobRequest) Descriptor deprecated 

func (*SubmitJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubmitJobRequest.ProtoReflect.Descriptor instead.

func (*SubmitJobRequest) GetJob 

func (x *SubmitJobRequest) GetJob() *Job

func (*SubmitJobRequest) ProtoMessage 

func (*SubmitJobRequest) ProtoMessage()

func (*SubmitJobRequest) ProtoReflect 

func (x *SubmitJobRequest) ProtoReflect() protoreflect.Message

func (*SubmitJobRequest) Reset 

func (x *SubmitJobRequest) Reset()

func (*SubmitJobRequest) String 

func (x *SubmitJobRequest) String() string

type SubmitJobResponse 

type SubmitJobResponse struct {
	JobId        string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	AssignedNode string `protobuf:"bytes,2,opt,name=assigned_node,json=assignedNode,proto3" json:"assigned_node,omitempty"`
	// contains filtered or unexported fields
}

SubmitJobResponse reports where the job landed rather than a formatted sentence.

func (*SubmitJobResponse) Descriptor deprecated 

func (*SubmitJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use SubmitJobResponse.ProtoReflect.Descriptor instead.

func (*SubmitJobResponse) GetAssignedNode 

func (x *SubmitJobResponse) GetAssignedNode() string

func (*SubmitJobResponse) GetJobId 

func (x *SubmitJobResponse) GetJobId() string

func (*SubmitJobResponse) ProtoMessage 

func (*SubmitJobResponse) ProtoMessage()

func (*SubmitJobResponse) ProtoReflect 

func (x *SubmitJobResponse) ProtoReflect() protoreflect.Message

func (*SubmitJobResponse) Reset 

func (x *SubmitJobResponse) Reset()

func (*SubmitJobResponse) String 

func (x *SubmitJobResponse) String() string

type SyncRevocationsRequest 

type SyncRevocationsRequest struct {
	Generations []*RevocationGeneration `protobuf:"bytes,1,rep,name=generations,proto3" json:"generations,omitempty"`
	// contains filtered or unexported fields
}

SyncRevocationsRequest carries EVERY live generation the caller holds, which is what repairs a revocation the best-effort delta broadcast dropped.

Not just the current generation: the filter keeps two so an entry outlives the longest token TTL wherever in the period it landed, and sending only the current one would repair a strictly narrower window than the filter itself maintains - a revocation made late in a window would go invisible to peers the moment that window rolled, while the token it revoked was still valid.

func (*SyncRevocationsRequest) Descriptor deprecated 

func (*SyncRevocationsRequest) Descriptor() ([]byte, []int)

Deprecated: Use SyncRevocationsRequest.ProtoReflect.Descriptor instead.

func (*SyncRevocationsRequest) GetGenerations 

func (x *SyncRevocationsRequest) GetGenerations() []*RevocationGeneration

func (*SyncRevocationsRequest) ProtoMessage 

func (*SyncRevocationsRequest) ProtoMessage()

func (*SyncRevocationsRequest) ProtoReflect 

func (x *SyncRevocationsRequest) ProtoReflect() protoreflect.Message

func (*SyncRevocationsRequest) Reset 

func (x *SyncRevocationsRequest) Reset()

func (*SyncRevocationsRequest) String 

func (x *SyncRevocationsRequest) String() string

type SyncRevocationsResponse 

type SyncRevocationsResponse struct {
	Generations []*RevocationGeneration `protobuf:"bytes,1,rep,name=generations,proto3" json:"generations,omitempty"`
	// contains filtered or unexported fields
}

SyncRevocationsResponse carries the responder's own live generations, so one round trip repairs BOTH directions. Merging is idempotent and the filter is a set, so no leader and no ordering are needed.

func (*SyncRevocationsResponse) Descriptor deprecated 

func (*SyncRevocationsResponse) Descriptor() ([]byte, []int)

Deprecated: Use SyncRevocationsResponse.ProtoReflect.Descriptor instead.

func (*SyncRevocationsResponse) GetGenerations 

func (x *SyncRevocationsResponse) GetGenerations() []*RevocationGeneration

func (*SyncRevocationsResponse) ProtoMessage 

func (*SyncRevocationsResponse) ProtoMessage()

func (*SyncRevocationsResponse) ProtoReflect 

func (x *SyncRevocationsResponse) ProtoReflect() protoreflect.Message

func (*SyncRevocationsResponse) Reset 

func (x *SyncRevocationsResponse) Reset()

func (*SyncRevocationsResponse) String 

func (x *SyncRevocationsResponse) String() string

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.