Documentation
¶
Index ¶
- Variables
- type AgentState
- type AgentStatus
- func (*AgentStatus) Descriptor() ([]byte, []int)deprecated
- func (x *AgentStatus) GetCapabilities() []string
- func (x *AgentStatus) GetCpuUsage() float64
- func (x *AgentStatus) GetDependencies() []string
- func (x *AgentStatus) GetId() string
- func (x *AgentStatus) GetLanguage() string
- func (x *AgentStatus) GetMemoryUsage() uint64
- func (x *AgentStatus) GetName() string
- func (x *AgentStatus) GetState() AgentState
- func (x *AgentStatus) GetType() string
- func (x *AgentStatus) GetUptimeNs() int64
- func (x *AgentStatus) GetVersion() string
- func (*AgentStatus) ProtoMessage()
- func (x *AgentStatus) ProtoReflect() protoreflect.Message
- func (x *AgentStatus) Reset()
- func (x *AgentStatus) String() string
- type AgentStatusRequest
- type AgentStatusResponse
- func (*AgentStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AgentStatusResponse) GetAgents() []*AgentStatus
- func (*AgentStatusResponse) ProtoMessage()
- func (x *AgentStatusResponse) ProtoReflect() protoreflect.Message
- func (x *AgentStatusResponse) Reset()
- func (x *AgentStatusResponse) String() string
- type BusEvent
- type CapabilityToken
- func (*CapabilityToken) Descriptor() ([]byte, []int)deprecated
- func (x *CapabilityToken) GetPayload() []byte
- func (x *CapabilityToken) GetSignature() []byte
- func (*CapabilityToken) ProtoMessage()
- func (x *CapabilityToken) ProtoReflect() protoreflect.Message
- func (x *CapabilityToken) Reset()
- func (x *CapabilityToken) String() string
- type CapabilityTokenPayload
- func (*CapabilityTokenPayload) Descriptor() ([]byte, []int)deprecated
- func (x *CapabilityTokenPayload) GetExpiresAtMs() int64
- func (x *CapabilityTokenPayload) GetIssuedAtMs() int64
- func (x *CapabilityTokenPayload) GetIssuerNodeId() string
- func (x *CapabilityTokenPayload) GetKeyId() string
- func (x *CapabilityTokenPayload) GetRights() uint64
- func (x *CapabilityTokenPayload) GetSubjectUuid() []byte
- func (x *CapabilityTokenPayload) GetTokenId() []byte
- func (*CapabilityTokenPayload) ProtoMessage()
- func (x *CapabilityTokenPayload) ProtoReflect() protoreflect.Message
- func (x *CapabilityTokenPayload) Reset()
- func (x *CapabilityTokenPayload) String() string
- type Envelope
- func (*Envelope) Descriptor() ([]byte, []int)deprecated
- func (x *Envelope) GetId() string
- func (x *Envelope) GetNamespace() string
- func (x *Envelope) GetPayload() *anypb.Any
- func (x *Envelope) GetSource() string
- func (x *Envelope) GetTags() []string
- func (x *Envelope) GetTopic() string
- func (x *Envelope) GetType() string
- func (*Envelope) ProtoMessage()
- func (x *Envelope) ProtoReflect() protoreflect.Message
- func (x *Envelope) Reset()
- func (x *Envelope) String() string
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetId() string
- func (x *Event) GetPayload() *anypb.Any
- func (x *Event) GetSource() string
- func (x *Event) GetType() string
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type LifecycleControl
- func (*LifecycleControl) Descriptor() ([]byte, []int)deprecated
- func (x *LifecycleControl) GetAction() LifecycleControl_Action
- func (x *LifecycleControl) GetAgentId() string
- func (x *LifecycleControl) GetEnv() map[string]string
- func (x *LifecycleControl) GetRestartPolicy() string
- func (*LifecycleControl) ProtoMessage()
- func (x *LifecycleControl) ProtoReflect() protoreflect.Message
- func (x *LifecycleControl) Reset()
- func (x *LifecycleControl) String() string
- type LifecycleControl_Action
- func (LifecycleControl_Action) Descriptor() protoreflect.EnumDescriptor
- func (x LifecycleControl_Action) Enum() *LifecycleControl_Action
- func (LifecycleControl_Action) EnumDescriptor() ([]byte, []int)deprecated
- func (x LifecycleControl_Action) Number() protoreflect.EnumNumber
- func (x LifecycleControl_Action) String() string
- func (LifecycleControl_Action) Type() protoreflect.EnumType
- type LifecycleEvent
- func (*LifecycleEvent) Descriptor() ([]byte, []int)deprecated
- func (x *LifecycleEvent) GetAction() string
- func (x *LifecycleEvent) GetAgentId() string
- func (x *LifecycleEvent) GetVersion() string
- func (*LifecycleEvent) ProtoMessage()
- func (x *LifecycleEvent) ProtoReflect() protoreflect.Message
- func (x *LifecycleEvent) Reset()
- func (x *LifecycleEvent) String() string
- type LifecycleStatus
- func (*LifecycleStatus) Descriptor() ([]byte, []int)deprecated
- func (x *LifecycleStatus) GetAgentId() string
- func (x *LifecycleStatus) GetHostname() string
- func (x *LifecycleStatus) GetMessage() string
- func (x *LifecycleStatus) GetRunId() string
- func (x *LifecycleStatus) GetSchemaHash() string
- func (x *LifecycleStatus) GetState() string
- func (x *LifecycleStatus) GetTime() *timestamppb.Timestamp
- func (*LifecycleStatus) ProtoMessage()
- func (x *LifecycleStatus) ProtoReflect() protoreflect.Message
- func (x *LifecycleStatus) Reset()
- func (x *LifecycleStatus) String() string
- type LifecycleTransition
- func (*LifecycleTransition) Descriptor() ([]byte, []int)deprecated
- func (x *LifecycleTransition) GetAgentId() string
- func (x *LifecycleTransition) GetFrom() string
- func (x *LifecycleTransition) GetHostname() string
- func (x *LifecycleTransition) GetTime() *timestamppb.Timestamp
- func (x *LifecycleTransition) GetTo() string
- func (*LifecycleTransition) ProtoMessage()
- func (x *LifecycleTransition) ProtoReflect() protoreflect.Message
- func (x *LifecycleTransition) Reset()
- func (x *LifecycleTransition) String() string
- type LogMessage
- func (*LogMessage) Descriptor() ([]byte, []int)deprecated
- func (x *LogMessage) GetAgentId() string
- func (x *LogMessage) GetLevel() string
- func (x *LogMessage) GetMessage() string
- func (x *LogMessage) GetTimestamp() int64
- func (*LogMessage) ProtoMessage()
- func (x *LogMessage) ProtoReflect() protoreflect.Message
- func (x *LogMessage) Reset()
- func (x *LogMessage) String() string
- type PingStatus
Constants ¶
This section is empty.
Variables ¶
var ( AgentState_name = map[int32]string{ 0: "AGENT_STATE_UNSPECIFIED", 1: "AGENT_STATE_INITIALIZING", 2: "AGENT_STATE_INITIALIZED", 3: "AGENT_STATE_STARTING", 4: "AGENT_STATE_STARTED", 5: "AGENT_STATE_RUNNING", 6: "AGENT_STATE_STOPPING", 7: "AGENT_STATE_STOPPED", 8: "AGENT_STATE_FAILED", 9: "AGENT_STATE_RELOADING", } AgentState_value = map[string]int32{ "AGENT_STATE_UNSPECIFIED": 0, "AGENT_STATE_INITIALIZING": 1, "AGENT_STATE_INITIALIZED": 2, "AGENT_STATE_STARTING": 3, "AGENT_STATE_STARTED": 4, "AGENT_STATE_RUNNING": 5, "AGENT_STATE_STOPPING": 6, "AGENT_STATE_STOPPED": 7, "AGENT_STATE_FAILED": 8, "AGENT_STATE_RELOADING": 9, } )
Enum value maps for AgentState.
var ( LifecycleControl_Action_name = map[int32]string{ 0: "ACTION_UNSPECIFIED", 1: "ACTION_INITIALIZE", 2: "ACTION_START", 3: "ACTION_STOP", 4: "ACTION_RESTART", 5: "ACTION_RELOAD", } LifecycleControl_Action_value = map[string]int32{ "ACTION_UNSPECIFIED": 0, "ACTION_INITIALIZE": 1, "ACTION_START": 2, "ACTION_STOP": 3, "ACTION_RESTART": 4, "ACTION_RELOAD": 5, } )
Enum value maps for LifecycleControl_Action.
var File_gapi_v1_agent_status_proto protoreflect.FileDescriptor
var File_gapi_v1_capability_token_proto protoreflect.FileDescriptor
var File_gapi_v1_envelope_proto protoreflect.FileDescriptor
var File_gapi_v1_event_proto protoreflect.FileDescriptor
var File_gapi_v1_lifecycle_control_proto protoreflect.FileDescriptor
var File_gapi_v1_lifecycle_status_proto protoreflect.FileDescriptor
var File_gapi_v1_lifecycle_transition_proto protoreflect.FileDescriptor
var File_gapi_v1_log_message_proto protoreflect.FileDescriptor
var File_gapi_v1_ping_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AgentState ¶
type AgentState int32
const ( AgentState_AGENT_STATE_UNSPECIFIED AgentState = 0 AgentState_AGENT_STATE_INITIALIZING AgentState = 1 AgentState_AGENT_STATE_INITIALIZED AgentState = 2 AgentState_AGENT_STATE_STARTING AgentState = 3 AgentState_AGENT_STATE_STARTED AgentState = 4 AgentState_AGENT_STATE_RUNNING AgentState = 5 AgentState_AGENT_STATE_STOPPING AgentState = 6 AgentState_AGENT_STATE_STOPPED AgentState = 7 AgentState_AGENT_STATE_FAILED AgentState = 8 AgentState_AGENT_STATE_RELOADING AgentState = 9 )
func (AgentState) Descriptor ¶
func (AgentState) Descriptor() protoreflect.EnumDescriptor
func (AgentState) Enum ¶
func (x AgentState) Enum() *AgentState
func (AgentState) EnumDescriptor
deprecated
func (AgentState) EnumDescriptor() ([]byte, []int)
Deprecated: Use AgentState.Descriptor instead.
func (AgentState) Number ¶
func (x AgentState) Number() protoreflect.EnumNumber
func (AgentState) String ¶
func (x AgentState) String() string
func (AgentState) Type ¶
func (AgentState) Type() protoreflect.EnumType
type AgentStatus ¶
type AgentStatus 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 AgentState `protobuf:"varint,3,opt,name=state,proto3,enum=gapi.v1.AgentState" json:"state,omitempty"`
Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
Language string `protobuf:"bytes,5,opt,name=language,proto3" json:"language,omitempty"`
Version string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
Capabilities []string `protobuf:"bytes,7,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
Dependencies []string `protobuf:"bytes,8,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
CpuUsage float64 `protobuf:"fixed64,9,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`
MemoryUsage uint64 `protobuf:"varint,10,opt,name=memory_usage,json=memoryUsage,proto3" json:"memory_usage,omitempty"`
UptimeNs int64 `protobuf:"varint,11,opt,name=uptime_ns,json=uptimeNs,proto3" json:"uptime_ns,omitempty"`
// contains filtered or unexported fields
}
func (*AgentStatus) Descriptor
deprecated
func (*AgentStatus) Descriptor() ([]byte, []int)
Deprecated: Use AgentStatus.ProtoReflect.Descriptor instead.
func (*AgentStatus) GetCapabilities ¶
func (x *AgentStatus) GetCapabilities() []string
func (*AgentStatus) GetCpuUsage ¶
func (x *AgentStatus) GetCpuUsage() float64
func (*AgentStatus) GetDependencies ¶
func (x *AgentStatus) GetDependencies() []string
func (*AgentStatus) GetId ¶
func (x *AgentStatus) GetId() string
func (*AgentStatus) GetLanguage ¶
func (x *AgentStatus) GetLanguage() string
func (*AgentStatus) GetMemoryUsage ¶
func (x *AgentStatus) GetMemoryUsage() uint64
func (*AgentStatus) GetName ¶
func (x *AgentStatus) GetName() string
func (*AgentStatus) GetState ¶
func (x *AgentStatus) GetState() AgentState
func (*AgentStatus) GetType ¶
func (x *AgentStatus) GetType() string
func (*AgentStatus) GetUptimeNs ¶
func (x *AgentStatus) GetUptimeNs() int64
func (*AgentStatus) GetVersion ¶
func (x *AgentStatus) GetVersion() string
func (*AgentStatus) ProtoMessage ¶
func (*AgentStatus) ProtoMessage()
func (*AgentStatus) ProtoReflect ¶
func (x *AgentStatus) ProtoReflect() protoreflect.Message
func (*AgentStatus) Reset ¶
func (x *AgentStatus) Reset()
func (*AgentStatus) String ¶
func (x *AgentStatus) String() string
type AgentStatusRequest ¶
type AgentStatusRequest struct {
// contains filtered or unexported fields
}
func (*AgentStatusRequest) Descriptor
deprecated
func (*AgentStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use AgentStatusRequest.ProtoReflect.Descriptor instead.
func (*AgentStatusRequest) ProtoMessage ¶
func (*AgentStatusRequest) ProtoMessage()
func (*AgentStatusRequest) ProtoReflect ¶
func (x *AgentStatusRequest) ProtoReflect() protoreflect.Message
func (*AgentStatusRequest) Reset ¶
func (x *AgentStatusRequest) Reset()
func (*AgentStatusRequest) String ¶
func (x *AgentStatusRequest) String() string
type AgentStatusResponse ¶
type AgentStatusResponse struct {
Agents []*AgentStatus `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
// contains filtered or unexported fields
}
func (*AgentStatusResponse) Descriptor
deprecated
func (*AgentStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use AgentStatusResponse.ProtoReflect.Descriptor instead.
func (*AgentStatusResponse) GetAgents ¶
func (x *AgentStatusResponse) GetAgents() []*AgentStatus
func (*AgentStatusResponse) ProtoMessage ¶
func (*AgentStatusResponse) ProtoMessage()
func (*AgentStatusResponse) ProtoReflect ¶
func (x *AgentStatusResponse) ProtoReflect() protoreflect.Message
func (*AgentStatusResponse) Reset ¶
func (x *AgentStatusResponse) Reset()
func (*AgentStatusResponse) String ¶
func (x *AgentStatusResponse) String() string
type BusEvent ¶
type BusEvent struct {
Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
Payload string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
// contains filtered or unexported fields
}
Payload for internal event bus messages.
func (*BusEvent) Descriptor
deprecated
func (*BusEvent) GetPayload ¶
func (*BusEvent) ProtoMessage ¶
func (*BusEvent) ProtoMessage()
func (*BusEvent) ProtoReflect ¶
func (x *BusEvent) ProtoReflect() protoreflect.Message
type CapabilityToken ¶
type CapabilityToken struct {
Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // serialized CapabilityTokenPayload
Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // Ed25519 over payload bytes
// contains filtered or unexported fields
}
CapabilityToken is a bearer token authorizing an action against one subject: an agent instance, or a named orchestration resource such as a spec, node, job, or topic. The signature covers the literal payload bytes, not a message: protobuf serialization is not canonical, so verifiers check Ed25519(payload) and only then unmarshal the payload.
func (*CapabilityToken) Descriptor
deprecated
func (*CapabilityToken) Descriptor() ([]byte, []int)
Deprecated: Use CapabilityToken.ProtoReflect.Descriptor instead.
func (*CapabilityToken) GetPayload ¶
func (x *CapabilityToken) GetPayload() []byte
func (*CapabilityToken) GetSignature ¶
func (x *CapabilityToken) GetSignature() []byte
func (*CapabilityToken) ProtoMessage ¶
func (*CapabilityToken) ProtoMessage()
func (*CapabilityToken) ProtoReflect ¶
func (x *CapabilityToken) ProtoReflect() protoreflect.Message
func (*CapabilityToken) Reset ¶
func (x *CapabilityToken) Reset()
func (*CapabilityToken) String ¶
func (x *CapabilityToken) String() string
type CapabilityTokenPayload ¶
type CapabilityTokenPayload struct {
TokenId []byte `protobuf:"bytes,1,opt,name=token_id,json=tokenId,proto3" json:"token_id,omitempty"` // UUIDv7
// The subject this token authorizes against. Usually an agent
// instance, but orchestration tokens scope to a named resource -
// spec, node, job, or topic (GOBLIN-DIV-027). Renamed from
// instance_uuid; the field number does not move, so the wire is
// unaffected and persisted data stays readable (GOBLIN-DIV-028).
SubjectUuid []byte `protobuf:"bytes,2,opt,name=subject_uuid,json=subjectUuid,proto3" json:"subject_uuid,omitempty"`
Rights uint64 `protobuf:"varint,3,opt,name=rights,proto3" json:"rights,omitempty"` // rights bitmap (see crypto package constants)
IssuedAtMs int64 `protobuf:"varint,4,opt,name=issued_at_ms,json=issuedAtMs,proto3" json:"issued_at_ms,omitempty"` // unix milliseconds
ExpiresAtMs int64 `protobuf:"varint,5,opt,name=expires_at_ms,json=expiresAtMs,proto3" json:"expires_at_ms,omitempty"` // unix milliseconds
IssuerNodeId string `protobuf:"bytes,6,opt,name=issuer_node_id,json=issuerNodeId,proto3" json:"issuer_node_id,omitempty"`
KeyId string `protobuf:"bytes,7,opt,name=key_id,json=keyId,proto3" json:"key_id,omitempty"` // identifies the issuer signing key
// contains filtered or unexported fields
}
CapabilityTokenPayload is the signed content of a capability token. TTL policy (issuer-side): 120s default, clamped to 60-300s.
func (*CapabilityTokenPayload) Descriptor
deprecated
func (*CapabilityTokenPayload) Descriptor() ([]byte, []int)
Deprecated: Use CapabilityTokenPayload.ProtoReflect.Descriptor instead.
func (*CapabilityTokenPayload) GetExpiresAtMs ¶
func (x *CapabilityTokenPayload) GetExpiresAtMs() int64
func (*CapabilityTokenPayload) GetIssuedAtMs ¶
func (x *CapabilityTokenPayload) GetIssuedAtMs() int64
func (*CapabilityTokenPayload) GetIssuerNodeId ¶
func (x *CapabilityTokenPayload) GetIssuerNodeId() string
func (*CapabilityTokenPayload) GetKeyId ¶
func (x *CapabilityTokenPayload) GetKeyId() string
func (*CapabilityTokenPayload) GetRights ¶
func (x *CapabilityTokenPayload) GetRights() uint64
func (*CapabilityTokenPayload) GetSubjectUuid ¶
func (x *CapabilityTokenPayload) GetSubjectUuid() []byte
func (*CapabilityTokenPayload) GetTokenId ¶
func (x *CapabilityTokenPayload) GetTokenId() []byte
func (*CapabilityTokenPayload) ProtoMessage ¶
func (*CapabilityTokenPayload) ProtoMessage()
func (*CapabilityTokenPayload) ProtoReflect ¶
func (x *CapabilityTokenPayload) ProtoReflect() protoreflect.Message
func (*CapabilityTokenPayload) Reset ¶
func (x *CapabilityTokenPayload) Reset()
func (*CapabilityTokenPayload) String ¶
func (x *CapabilityTokenPayload) String() string
type Envelope ¶
type Envelope 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"`
Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
Namespace string `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`
Payload *anypb.Any `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
Tags []string `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`
// contains filtered or unexported fields
}
func (*Envelope) Descriptor
deprecated
func (*Envelope) GetNamespace ¶
func (*Envelope) GetPayload ¶
func (*Envelope) ProtoMessage ¶
func (*Envelope) ProtoMessage()
func (*Envelope) ProtoReflect ¶
func (x *Envelope) ProtoReflect() protoreflect.Message
type Event ¶
type Event 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"` // e.g., "lifecycle", "eventbus", "status"
Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` // e.g., "goblin.agent"
Payload *anypb.Any `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"` // Event-specific payload (see below)
// contains filtered or unexported fields
}
Envelope for all structured events. This is the top-level type passed through logs, IPC, or audit systems.
func (*Event) Descriptor
deprecated
func (*Event) GetPayload ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type LifecycleControl ¶
type LifecycleControl struct {
AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
// Enum for supported lifecycle actions
Action LifecycleControl_Action `protobuf:"varint,2,opt,name=action,proto3,enum=gapi.v1.LifecycleControl_Action" json:"action,omitempty"`
// Environment variables for the agent (only used for START/RESTART)
Env map[string]string `` /* 133-byte string literal not displayed */
// Restart policy (e.g. "always", "on-failure", "never")
RestartPolicy string `protobuf:"bytes,4,opt,name=restart_policy,json=restartPolicy,proto3" json:"restart_policy,omitempty"`
// contains filtered or unexported fields
}
func (*LifecycleControl) Descriptor
deprecated
func (*LifecycleControl) Descriptor() ([]byte, []int)
Deprecated: Use LifecycleControl.ProtoReflect.Descriptor instead.
func (*LifecycleControl) GetAction ¶
func (x *LifecycleControl) GetAction() LifecycleControl_Action
func (*LifecycleControl) GetAgentId ¶
func (x *LifecycleControl) GetAgentId() string
func (*LifecycleControl) GetEnv ¶
func (x *LifecycleControl) GetEnv() map[string]string
func (*LifecycleControl) GetRestartPolicy ¶
func (x *LifecycleControl) GetRestartPolicy() string
func (*LifecycleControl) ProtoMessage ¶
func (*LifecycleControl) ProtoMessage()
func (*LifecycleControl) ProtoReflect ¶
func (x *LifecycleControl) ProtoReflect() protoreflect.Message
func (*LifecycleControl) Reset ¶
func (x *LifecycleControl) Reset()
func (*LifecycleControl) String ¶
func (x *LifecycleControl) String() string
type LifecycleControl_Action ¶
type LifecycleControl_Action int32
const ( LifecycleControl_ACTION_UNSPECIFIED LifecycleControl_Action = 0 LifecycleControl_ACTION_INITIALIZE LifecycleControl_Action = 1 LifecycleControl_ACTION_START LifecycleControl_Action = 2 LifecycleControl_ACTION_STOP LifecycleControl_Action = 3 LifecycleControl_ACTION_RESTART LifecycleControl_Action = 4 LifecycleControl_ACTION_RELOAD LifecycleControl_Action = 5 )
func (LifecycleControl_Action) Descriptor ¶
func (LifecycleControl_Action) Descriptor() protoreflect.EnumDescriptor
func (LifecycleControl_Action) Enum ¶
func (x LifecycleControl_Action) Enum() *LifecycleControl_Action
func (LifecycleControl_Action) EnumDescriptor
deprecated
func (LifecycleControl_Action) EnumDescriptor() ([]byte, []int)
Deprecated: Use LifecycleControl_Action.Descriptor instead.
func (LifecycleControl_Action) Number ¶
func (x LifecycleControl_Action) Number() protoreflect.EnumNumber
func (LifecycleControl_Action) String ¶
func (x LifecycleControl_Action) String() string
func (LifecycleControl_Action) Type ¶
func (LifecycleControl_Action) Type() protoreflect.EnumType
type LifecycleEvent ¶
type LifecycleEvent struct {
Action string `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"` // e.g., "start", "stop", "restart"
AgentId string `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
Payload for lifecycle transitions.
func (*LifecycleEvent) Descriptor
deprecated
func (*LifecycleEvent) Descriptor() ([]byte, []int)
Deprecated: Use LifecycleEvent.ProtoReflect.Descriptor instead.
func (*LifecycleEvent) GetAction ¶
func (x *LifecycleEvent) GetAction() string
func (*LifecycleEvent) GetAgentId ¶
func (x *LifecycleEvent) GetAgentId() string
func (*LifecycleEvent) GetVersion ¶
func (x *LifecycleEvent) GetVersion() string
func (*LifecycleEvent) ProtoMessage ¶
func (*LifecycleEvent) ProtoMessage()
func (*LifecycleEvent) ProtoReflect ¶
func (x *LifecycleEvent) ProtoReflect() protoreflect.Message
func (*LifecycleEvent) Reset ¶
func (x *LifecycleEvent) Reset()
func (*LifecycleEvent) String ¶
func (x *LifecycleEvent) String() string
type LifecycleStatus ¶
type LifecycleStatus struct {
AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
State string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
Hostname string `protobuf:"bytes,5,opt,name=hostname,proto3" json:"hostname,omitempty"`
SchemaHash string `protobuf:"bytes,6,opt,name=schema_hash,json=schemaHash,proto3" json:"schema_hash,omitempty"`
// run_id identifies a specific run/incarnation of the agent process so restart
// detection can match structurally instead of parsing it out of `message`.
RunId string `protobuf:"bytes,7,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
// contains filtered or unexported fields
}
func (*LifecycleStatus) Descriptor
deprecated
func (*LifecycleStatus) Descriptor() ([]byte, []int)
Deprecated: Use LifecycleStatus.ProtoReflect.Descriptor instead.
func (*LifecycleStatus) GetAgentId ¶
func (x *LifecycleStatus) GetAgentId() string
func (*LifecycleStatus) GetHostname ¶
func (x *LifecycleStatus) GetHostname() string
func (*LifecycleStatus) GetMessage ¶
func (x *LifecycleStatus) GetMessage() string
func (*LifecycleStatus) GetRunId ¶
func (x *LifecycleStatus) GetRunId() string
func (*LifecycleStatus) GetSchemaHash ¶
func (x *LifecycleStatus) GetSchemaHash() string
func (*LifecycleStatus) GetState ¶
func (x *LifecycleStatus) GetState() string
func (*LifecycleStatus) GetTime ¶
func (x *LifecycleStatus) GetTime() *timestamppb.Timestamp
func (*LifecycleStatus) ProtoMessage ¶
func (*LifecycleStatus) ProtoMessage()
func (*LifecycleStatus) ProtoReflect ¶
func (x *LifecycleStatus) ProtoReflect() protoreflect.Message
func (*LifecycleStatus) Reset ¶
func (x *LifecycleStatus) Reset()
func (*LifecycleStatus) String ¶
func (x *LifecycleStatus) String() string
type LifecycleTransition ¶
type LifecycleTransition struct {
AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
To string `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
Hostname string `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
Time *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`
// contains filtered or unexported fields
}
func (*LifecycleTransition) Descriptor
deprecated
func (*LifecycleTransition) Descriptor() ([]byte, []int)
Deprecated: Use LifecycleTransition.ProtoReflect.Descriptor instead.
func (*LifecycleTransition) GetAgentId ¶
func (x *LifecycleTransition) GetAgentId() string
func (*LifecycleTransition) GetFrom ¶
func (x *LifecycleTransition) GetFrom() string
func (*LifecycleTransition) GetHostname ¶
func (x *LifecycleTransition) GetHostname() string
func (*LifecycleTransition) GetTime ¶
func (x *LifecycleTransition) GetTime() *timestamppb.Timestamp
func (*LifecycleTransition) GetTo ¶
func (x *LifecycleTransition) GetTo() string
func (*LifecycleTransition) ProtoMessage ¶
func (*LifecycleTransition) ProtoMessage()
func (*LifecycleTransition) ProtoReflect ¶
func (x *LifecycleTransition) ProtoReflect() protoreflect.Message
func (*LifecycleTransition) Reset ¶
func (x *LifecycleTransition) Reset()
func (*LifecycleTransition) String ¶
func (x *LifecycleTransition) String() string
type LogMessage ¶
type LogMessage struct {
AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
Level string `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"` // DEBUG, INFO, WARN, ERROR
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Unix timestamp in milliseconds
// contains filtered or unexported fields
}
func (*LogMessage) Descriptor
deprecated
func (*LogMessage) Descriptor() ([]byte, []int)
Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.
func (*LogMessage) GetAgentId ¶
func (x *LogMessage) GetAgentId() string
func (*LogMessage) GetLevel ¶
func (x *LogMessage) GetLevel() string
func (*LogMessage) GetMessage ¶
func (x *LogMessage) GetMessage() string
func (*LogMessage) GetTimestamp ¶
func (x *LogMessage) GetTimestamp() int64
func (*LogMessage) ProtoMessage ¶
func (*LogMessage) ProtoMessage()
func (*LogMessage) ProtoReflect ¶
func (x *LogMessage) ProtoReflect() protoreflect.Message
func (*LogMessage) Reset ¶
func (x *LogMessage) Reset()
func (*LogMessage) String ¶
func (x *LogMessage) String() string
type PingStatus ¶
type PingStatus struct {
Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*PingStatus) Descriptor
deprecated
func (*PingStatus) Descriptor() ([]byte, []int)
Deprecated: Use PingStatus.ProtoReflect.Descriptor instead.
func (*PingStatus) GetStatus ¶
func (x *PingStatus) GetStatus() string
func (*PingStatus) ProtoMessage ¶
func (*PingStatus) ProtoMessage()
func (*PingStatus) ProtoReflect ¶
func (x *PingStatus) ProtoReflect() protoreflect.Message
func (*PingStatus) Reset ¶
func (x *PingStatus) Reset()
func (*PingStatus) String ¶
func (x *PingStatus) String() string