Documentation ¶
Index ¶
- Variables
- type AuctionRequest
- func (*AuctionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AuctionRequest) GetAgentType() []string
- func (x *AuctionRequest) GetArchitecture() string
- func (x *AuctionRequest) GetOperatingSystem() string
- func (x *AuctionRequest) GetTags() []string
- func (*AuctionRequest) ProtoMessage()
- func (x *AuctionRequest) ProtoReflect() protoreflect.Message
- func (x *AuctionRequest) Reset()
- func (x *AuctionRequest) String() string
- type AuctionResponse
- func (*AuctionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AuctionResponse) GetBidderId() string
- func (x *AuctionResponse) GetStartedAt() *timestamppb.Timestamp
- func (x *AuctionResponse) GetStatus() map[string]int32
- func (x *AuctionResponse) GetTags() map[string]string
- func (x *AuctionResponse) GetTargetXkey() string
- func (x *AuctionResponse) GetVersion() string
- func (*AuctionResponse) ProtoMessage()
- func (x *AuctionResponse) ProtoReflect() protoreflect.Message
- func (x *AuctionResponse) Reset()
- func (x *AuctionResponse) String() string
- type EncEnvironment
- func (*EncEnvironment) Descriptor() ([]byte, []int)deprecated
- func (x *EncEnvironment) GetBase64EncryptedEnv() string
- func (x *EncEnvironment) GetEncryptedBy() string
- func (*EncEnvironment) ProtoMessage()
- func (x *EncEnvironment) ProtoReflect() protoreflect.Message
- func (x *EncEnvironment) Reset()
- func (x *EncEnvironment) String() string
- type Envelope
- type Error
- type GetNodeInfo
- type GetRunRequest
- func (*GetRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRunRequest) GetNamespace() string
- func (x *GetRunRequest) GetWorkloadId() string
- func (*GetRunRequest) ProtoMessage()
- func (x *GetRunRequest) ProtoReflect() protoreflect.Message
- func (x *GetRunRequest) Reset()
- func (x *GetRunRequest) String() string
- type Halt
- type HostServicesConfig
- func (*HostServicesConfig) Descriptor() ([]byte, []int)deprecated
- func (x *HostServicesConfig) GetNatsUrl() string
- func (x *HostServicesConfig) GetNatsUserJwt() string
- func (x *HostServicesConfig) GetNatsUserSeed() string
- func (*HostServicesConfig) ProtoMessage()
- func (x *HostServicesConfig) ProtoReflect() protoreflect.Message
- func (x *HostServicesConfig) Reset()
- func (x *HostServicesConfig) String() string
- type KillDirectStartProcess
- type LameDuckResponse
- type NoEnvRunRequest
- func (*NoEnvRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NoEnvRunRequest) GetClearEnv() map[string]string
- func (x *NoEnvRunRequest) GetRunRequest() *StartWorkload
- func (*NoEnvRunRequest) ProtoMessage()
- func (x *NoEnvRunRequest) ProtoReflect() protoreflect.Message
- func (x *NoEnvRunRequest) Reset()
- func (x *NoEnvRunRequest) String() string
- type NodeInfo
- func (*NodeInfo) Descriptor() ([]byte, []int)deprecated
- func (x *NodeInfo) GetId() string
- func (x *NodeInfo) GetTags() map[string]string
- func (x *NodeInfo) GetTargetXkey() string
- func (x *NodeInfo) GetUptime() string
- func (x *NodeInfo) GetVersion() string
- func (x *NodeInfo) GetWorkloads() []*WorkloadSummary
- func (*NodeInfo) ProtoMessage()
- func (x *NodeInfo) ProtoReflect() protoreflect.Message
- func (x *NodeInfo) Reset()
- func (x *NodeInfo) String() string
- type PingAgent
- type PingAgentResponse
- func (*PingAgentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PingAgentResponse) GetNodeId() string
- func (x *PingAgentResponse) GetRunningWorkloads() []*RunningWorkload
- func (x *PingAgentResponse) GetStartedAt() *timestamppb.Timestamp
- func (x *PingAgentResponse) GetTags() map[string]string
- func (x *PingAgentResponse) GetTargetXkey() string
- func (x *PingAgentResponse) GetVersion() string
- func (*PingAgentResponse) ProtoMessage()
- func (x *PingAgentResponse) ProtoReflect() protoreflect.Message
- func (x *PingAgentResponse) Reset()
- func (x *PingAgentResponse) String() string
- type PingNode
- type PingNodeResponse
- func (*PingNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PingNodeResponse) GetNodeId() string
- func (x *PingNodeResponse) GetRunningAgents() map[string]int32
- func (x *PingNodeResponse) GetStartedAt() *timestamppb.Timestamp
- func (x *PingNodeResponse) GetTags() map[string]string
- func (x *PingNodeResponse) GetTargetXkey() string
- func (x *PingNodeResponse) GetVersion() string
- func (*PingNodeResponse) ProtoMessage()
- func (x *PingNodeResponse) ProtoReflect() protoreflect.Message
- func (x *PingNodeResponse) Reset()
- func (x *PingNodeResponse) String() string
- type PingWorkload
- func (*PingWorkload) Descriptor() ([]byte, []int)deprecated
- func (x *PingWorkload) GetNamespace() string
- func (x *PingWorkload) GetState() string
- func (x *PingWorkload) GetType() string
- func (x *PingWorkload) GetWorkloadId() string
- func (*PingWorkload) ProtoMessage()
- func (x *PingWorkload) ProtoReflect() protoreflect.Message
- func (x *PingWorkload) Reset()
- func (x *PingWorkload) String() string
- type PingWorkloadResponse
- func (*PingWorkloadResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PingWorkloadResponse) GetWorkload() *WorkloadSummary
- func (*PingWorkloadResponse) ProtoMessage()
- func (x *PingWorkloadResponse) ProtoReflect() protoreflect.Message
- func (x *PingWorkloadResponse) Reset()
- func (x *PingWorkloadResponse) String() string
- type QueryWorkload
- type QueryWorkloads
- type RunningWorkload
- func (*RunningWorkload) Descriptor() ([]byte, []int)deprecated
- func (x *RunningWorkload) GetId() string
- func (x *RunningWorkload) GetName() string
- func (x *RunningWorkload) GetNamespace() string
- func (*RunningWorkload) ProtoMessage()
- func (x *RunningWorkload) ProtoReflect() protoreflect.Message
- func (x *RunningWorkload) Reset()
- func (x *RunningWorkload) String() string
- type SetLameDuck
- type SpawnDirectStartProcess
- type StartWorkload
- func (*StartWorkload) Descriptor() ([]byte, []int)deprecated
- func (x *StartWorkload) GetArgv() []string
- func (x *StartWorkload) GetDescription() string
- func (x *StartWorkload) GetEnvironment() *EncEnvironment
- func (x *StartWorkload) GetHash() string
- func (x *StartWorkload) GetHostServiceConfig() *HostServicesConfig
- func (x *StartWorkload) GetJsdomain() string
- func (x *StartWorkload) GetNamespace() string
- func (x *StartWorkload) GetRetriedAt() string
- func (x *StartWorkload) GetRetryCount() int32
- func (x *StartWorkload) GetTriggerSubject() string
- func (x *StartWorkload) GetUri() string
- func (x *StartWorkload) GetWorkloadId() string
- func (x *StartWorkload) GetWorkloadName() string
- func (x *StartWorkload) GetWorkloadRuntype() string
- func (x *StartWorkload) GetWorkloadType() string
- func (*StartWorkload) ProtoMessage()
- func (x *StartWorkload) ProtoReflect() protoreflect.Message
- func (x *StartWorkload) Reset()
- func (x *StartWorkload) String() string
- type StopWorkload
- func (*StopWorkload) Descriptor() ([]byte, []int)deprecated
- func (x *StopWorkload) GetNamespace() string
- func (x *StopWorkload) GetWorkloadId() string
- func (*StopWorkload) ProtoMessage()
- func (x *StopWorkload) ProtoReflect() protoreflect.Message
- func (x *StopWorkload) Reset()
- func (x *StopWorkload) String() string
- type WorkloadList
- type WorkloadStarted
- func (*WorkloadStarted) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadStarted) GetId() string
- func (x *WorkloadStarted) GetIssuer() string
- func (x *WorkloadStarted) GetName() string
- func (x *WorkloadStarted) GetStarted() bool
- func (*WorkloadStarted) ProtoMessage()
- func (x *WorkloadStarted) ProtoReflect() protoreflect.Message
- func (x *WorkloadStarted) Reset()
- func (x *WorkloadStarted) String() string
- type WorkloadStopped
- func (*WorkloadStopped) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadStopped) GetId() string
- func (x *WorkloadStopped) GetIssuer() string
- func (x *WorkloadStopped) GetStopped() bool
- func (*WorkloadStopped) ProtoMessage()
- func (x *WorkloadStopped) ProtoReflect() protoreflect.Message
- func (x *WorkloadStopped) Reset()
- func (x *WorkloadStopped) String() string
- type WorkloadSummary
- func (*WorkloadSummary) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadSummary) GetId() string
- func (x *WorkloadSummary) GetName() string
- func (x *WorkloadSummary) GetNamespace() string
- func (x *WorkloadSummary) GetRuntime() string
- func (x *WorkloadSummary) GetStartedAt() *timestamppb.Timestamp
- func (x *WorkloadSummary) GetState() string
- func (x *WorkloadSummary) GetWorkloadRuntype() string
- func (x *WorkloadSummary) GetWorkloadType() string
- func (*WorkloadSummary) ProtoMessage()
- func (x *WorkloadSummary) ProtoReflect() protoreflect.Message
- func (x *WorkloadSummary) Reset()
- func (x *WorkloadSummary) String() string
Constants ¶
This section is empty.
Variables ¶
var File_agents_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AuctionRequest ¶
type AuctionRequest struct { Architecture string `protobuf:"bytes,1,opt,name=architecture,proto3" json:"architecture,omitempty"` OperatingSystem string `protobuf:"bytes,2,opt,name=operating_system,json=operatingSystem,proto3" json:"operating_system,omitempty"` Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"` AgentType []string `protobuf:"bytes,4,rep,name=agent_type,json=agentType,proto3" json:"agent_type,omitempty"` // contains filtered or unexported fields }
func (*AuctionRequest) Descriptor
deprecated
func (*AuctionRequest) Descriptor() ([]byte, []int)
Deprecated: Use AuctionRequest.ProtoReflect.Descriptor instead.
func (*AuctionRequest) GetAgentType ¶
func (x *AuctionRequest) GetAgentType() []string
func (*AuctionRequest) GetArchitecture ¶
func (x *AuctionRequest) GetArchitecture() string
func (*AuctionRequest) GetOperatingSystem ¶
func (x *AuctionRequest) GetOperatingSystem() string
func (*AuctionRequest) GetTags ¶
func (x *AuctionRequest) GetTags() []string
func (*AuctionRequest) ProtoMessage ¶
func (*AuctionRequest) ProtoMessage()
func (*AuctionRequest) ProtoReflect ¶
func (x *AuctionRequest) ProtoReflect() protoreflect.Message
func (*AuctionRequest) Reset ¶
func (x *AuctionRequest) Reset()
func (*AuctionRequest) String ¶
func (x *AuctionRequest) String() string
type AuctionResponse ¶
type AuctionResponse struct { BidderId string `protobuf:"bytes,1,opt,name=bidder_id,json=bidderId,proto3" json:"bidder_id,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` TargetXkey string `protobuf:"bytes,3,opt,name=target_xkey,json=targetXkey,proto3" json:"target_xkey,omitempty"` StartedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ Status map[string]int32 `` /* 154-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AuctionResponse) Descriptor
deprecated
func (*AuctionResponse) Descriptor() ([]byte, []int)
Deprecated: Use AuctionResponse.ProtoReflect.Descriptor instead.
func (*AuctionResponse) GetBidderId ¶
func (x *AuctionResponse) GetBidderId() string
func (*AuctionResponse) GetStartedAt ¶
func (x *AuctionResponse) GetStartedAt() *timestamppb.Timestamp
func (*AuctionResponse) GetStatus ¶
func (x *AuctionResponse) GetStatus() map[string]int32
func (*AuctionResponse) GetTags ¶
func (x *AuctionResponse) GetTags() map[string]string
func (*AuctionResponse) GetTargetXkey ¶
func (x *AuctionResponse) GetTargetXkey() string
func (*AuctionResponse) GetVersion ¶
func (x *AuctionResponse) GetVersion() string
func (*AuctionResponse) ProtoMessage ¶
func (*AuctionResponse) ProtoMessage()
func (*AuctionResponse) ProtoReflect ¶
func (x *AuctionResponse) ProtoReflect() protoreflect.Message
func (*AuctionResponse) Reset ¶
func (x *AuctionResponse) Reset()
func (*AuctionResponse) String ¶
func (x *AuctionResponse) String() string
type EncEnvironment ¶
type EncEnvironment struct { EncryptedBy string `protobuf:"bytes,1,opt,name=encrypted_by,json=encryptedBy,proto3" json:"encrypted_by,omitempty"` Base64EncryptedEnv string `protobuf:"bytes,2,opt,name=base64_encrypted_env,json=base64EncryptedEnv,proto3" json:"base64_encrypted_env,omitempty"` // contains filtered or unexported fields }
func (*EncEnvironment) Descriptor
deprecated
func (*EncEnvironment) Descriptor() ([]byte, []int)
Deprecated: Use EncEnvironment.ProtoReflect.Descriptor instead.
func (*EncEnvironment) GetBase64EncryptedEnv ¶
func (x *EncEnvironment) GetBase64EncryptedEnv() string
func (*EncEnvironment) GetEncryptedBy ¶
func (x *EncEnvironment) GetEncryptedBy() string
func (*EncEnvironment) ProtoMessage ¶
func (*EncEnvironment) ProtoMessage()
func (*EncEnvironment) ProtoReflect ¶
func (x *EncEnvironment) ProtoReflect() protoreflect.Message
func (*EncEnvironment) Reset ¶
func (x *EncEnvironment) Reset()
func (*EncEnvironment) String ¶
func (x *EncEnvironment) String() string
type Envelope ¶
type Envelope struct { Payload *anypb.Any `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*Envelope) Descriptor
deprecated
func (*Envelope) GetPayload ¶
func (*Envelope) ProtoMessage ¶
func (*Envelope) ProtoMessage()
func (*Envelope) ProtoReflect ¶
func (x *Envelope) ProtoReflect() protoreflect.Message
type Error ¶
type Error struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Code int32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"` // contains filtered or unexported fields }
func (*Error) Descriptor
deprecated
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
type GetNodeInfo ¶
type GetNodeInfo struct {
// contains filtered or unexported fields
}
func (*GetNodeInfo) Descriptor
deprecated
func (*GetNodeInfo) Descriptor() ([]byte, []int)
Deprecated: Use GetNodeInfo.ProtoReflect.Descriptor instead.
func (*GetNodeInfo) ProtoMessage ¶
func (*GetNodeInfo) ProtoMessage()
func (*GetNodeInfo) ProtoReflect ¶
func (x *GetNodeInfo) ProtoReflect() protoreflect.Message
func (*GetNodeInfo) Reset ¶
func (x *GetNodeInfo) Reset()
func (*GetNodeInfo) String ¶
func (x *GetNodeInfo) String() string
type GetRunRequest ¶
type GetRunRequest struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` WorkloadId string `protobuf:"bytes,2,opt,name=workload_id,json=workloadId,proto3" json:"workload_id,omitempty"` // contains filtered or unexported fields }
func (*GetRunRequest) Descriptor
deprecated
func (*GetRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRunRequest.ProtoReflect.Descriptor instead.
func (*GetRunRequest) GetNamespace ¶
func (x *GetRunRequest) GetNamespace() string
func (*GetRunRequest) GetWorkloadId ¶
func (x *GetRunRequest) GetWorkloadId() string
func (*GetRunRequest) ProtoMessage ¶
func (*GetRunRequest) ProtoMessage()
func (*GetRunRequest) ProtoReflect ¶
func (x *GetRunRequest) ProtoReflect() protoreflect.Message
func (*GetRunRequest) Reset ¶
func (x *GetRunRequest) Reset()
func (*GetRunRequest) String ¶
func (x *GetRunRequest) String() string
type Halt ¶
type Halt struct {
// contains filtered or unexported fields
}
Request made by the actor system and/or control API asking the agent to stop. Note that the direct start agent will ignore this
func (*Halt) Descriptor
deprecated
func (*Halt) ProtoMessage ¶
func (*Halt) ProtoMessage()
func (*Halt) ProtoReflect ¶
func (x *Halt) ProtoReflect() protoreflect.Message
type HostServicesConfig ¶
type HostServicesConfig struct { NatsUrl string `protobuf:"bytes,1,opt,name=nats_url,json=natsUrl,proto3" json:"nats_url,omitempty"` NatsUserSeed string `protobuf:"bytes,2,opt,name=nats_user_seed,json=natsUserSeed,proto3" json:"nats_user_seed,omitempty"` NatsUserJwt string `protobuf:"bytes,3,opt,name=nats_user_jwt,json=natsUserJwt,proto3" json:"nats_user_jwt,omitempty"` // contains filtered or unexported fields }
func (*HostServicesConfig) Descriptor
deprecated
func (*HostServicesConfig) Descriptor() ([]byte, []int)
Deprecated: Use HostServicesConfig.ProtoReflect.Descriptor instead.
func (*HostServicesConfig) GetNatsUrl ¶
func (x *HostServicesConfig) GetNatsUrl() string
func (*HostServicesConfig) GetNatsUserJwt ¶
func (x *HostServicesConfig) GetNatsUserJwt() string
func (*HostServicesConfig) GetNatsUserSeed ¶
func (x *HostServicesConfig) GetNatsUserSeed() string
func (*HostServicesConfig) ProtoMessage ¶
func (*HostServicesConfig) ProtoMessage()
func (*HostServicesConfig) ProtoReflect ¶
func (x *HostServicesConfig) ProtoReflect() protoreflect.Message
func (*HostServicesConfig) Reset ¶
func (x *HostServicesConfig) Reset()
func (*HostServicesConfig) String ¶
func (x *HostServicesConfig) String() string
type KillDirectStartProcess ¶
type KillDirectStartProcess struct {
// contains filtered or unexported fields
}
func (*KillDirectStartProcess) Descriptor
deprecated
func (*KillDirectStartProcess) Descriptor() ([]byte, []int)
Deprecated: Use KillDirectStartProcess.ProtoReflect.Descriptor instead.
func (*KillDirectStartProcess) ProtoMessage ¶
func (*KillDirectStartProcess) ProtoMessage()
func (*KillDirectStartProcess) ProtoReflect ¶
func (x *KillDirectStartProcess) ProtoReflect() protoreflect.Message
func (*KillDirectStartProcess) Reset ¶
func (x *KillDirectStartProcess) Reset()
func (*KillDirectStartProcess) String ¶
func (x *KillDirectStartProcess) String() string
type LameDuckResponse ¶
type LameDuckResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*LameDuckResponse) Descriptor
deprecated
func (*LameDuckResponse) Descriptor() ([]byte, []int)
Deprecated: Use LameDuckResponse.ProtoReflect.Descriptor instead.
func (*LameDuckResponse) GetSuccess ¶
func (x *LameDuckResponse) GetSuccess() bool
func (*LameDuckResponse) ProtoMessage ¶
func (*LameDuckResponse) ProtoMessage()
func (*LameDuckResponse) ProtoReflect ¶
func (x *LameDuckResponse) ProtoReflect() protoreflect.Message
func (*LameDuckResponse) Reset ¶
func (x *LameDuckResponse) Reset()
func (*LameDuckResponse) String ¶
func (x *LameDuckResponse) String() string
type NoEnvRunRequest ¶
type NoEnvRunRequest struct { ClearEnv map[string]string `` /* 173-byte string literal not displayed */ RunRequest *StartWorkload `protobuf:"bytes,2,opt,name=run_request,json=runRequest,proto3" json:"run_request,omitempty"` // contains filtered or unexported fields }
func (*NoEnvRunRequest) Descriptor
deprecated
func (*NoEnvRunRequest) Descriptor() ([]byte, []int)
Deprecated: Use NoEnvRunRequest.ProtoReflect.Descriptor instead.
func (*NoEnvRunRequest) GetClearEnv ¶
func (x *NoEnvRunRequest) GetClearEnv() map[string]string
func (*NoEnvRunRequest) GetRunRequest ¶
func (x *NoEnvRunRequest) GetRunRequest() *StartWorkload
func (*NoEnvRunRequest) ProtoMessage ¶
func (*NoEnvRunRequest) ProtoMessage()
func (*NoEnvRunRequest) ProtoReflect ¶
func (x *NoEnvRunRequest) ProtoReflect() protoreflect.Message
func (*NoEnvRunRequest) Reset ¶
func (x *NoEnvRunRequest) Reset()
func (*NoEnvRunRequest) String ¶
func (x *NoEnvRunRequest) String() string
type NodeInfo ¶
type NodeInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ TargetXkey string `protobuf:"bytes,3,opt,name=target_xkey,json=targetXkey,proto3" json:"target_xkey,omitempty"` Uptime string `protobuf:"bytes,4,opt,name=uptime,proto3" json:"uptime,omitempty"` Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` Workloads []*WorkloadSummary `protobuf:"bytes,6,rep,name=workloads,proto3" json:"workloads,omitempty"` // contains filtered or unexported fields }
func (*NodeInfo) Descriptor
deprecated
func (*NodeInfo) GetTargetXkey ¶
func (*NodeInfo) GetVersion ¶
func (*NodeInfo) GetWorkloads ¶
func (x *NodeInfo) GetWorkloads() []*WorkloadSummary
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) ProtoReflect ¶
func (x *NodeInfo) ProtoReflect() protoreflect.Message
type PingAgent ¶
type PingAgent struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
func (*PingAgent) Descriptor
deprecated
func (*PingAgent) GetNamespace ¶
func (*PingAgent) ProtoMessage ¶
func (*PingAgent) ProtoMessage()
func (*PingAgent) ProtoReflect ¶
func (x *PingAgent) ProtoReflect() protoreflect.Message
type PingAgentResponse ¶
type PingAgentResponse struct { NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` TargetXkey string `protobuf:"bytes,2,opt,name=target_xkey,json=targetXkey,proto3" json:"target_xkey,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ StartedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` RunningWorkloads []*RunningWorkload `protobuf:"bytes,6,rep,name=running_workloads,json=runningWorkloads,proto3" json:"running_workloads,omitempty"` // contains filtered or unexported fields }
func (*PingAgentResponse) Descriptor
deprecated
func (*PingAgentResponse) Descriptor() ([]byte, []int)
Deprecated: Use PingAgentResponse.ProtoReflect.Descriptor instead.
func (*PingAgentResponse) GetNodeId ¶
func (x *PingAgentResponse) GetNodeId() string
func (*PingAgentResponse) GetRunningWorkloads ¶
func (x *PingAgentResponse) GetRunningWorkloads() []*RunningWorkload
func (*PingAgentResponse) GetStartedAt ¶
func (x *PingAgentResponse) GetStartedAt() *timestamppb.Timestamp
func (*PingAgentResponse) GetTags ¶
func (x *PingAgentResponse) GetTags() map[string]string
func (*PingAgentResponse) GetTargetXkey ¶
func (x *PingAgentResponse) GetTargetXkey() string
func (*PingAgentResponse) GetVersion ¶
func (x *PingAgentResponse) GetVersion() string
func (*PingAgentResponse) ProtoMessage ¶
func (*PingAgentResponse) ProtoMessage()
func (*PingAgentResponse) ProtoReflect ¶
func (x *PingAgentResponse) ProtoReflect() protoreflect.Message
func (*PingAgentResponse) Reset ¶
func (x *PingAgentResponse) Reset()
func (*PingAgentResponse) String ¶
func (x *PingAgentResponse) String() string
type PingNode ¶
type PingNode struct {
// contains filtered or unexported fields
}
func (*PingNode) Descriptor
deprecated
func (*PingNode) ProtoMessage ¶
func (*PingNode) ProtoMessage()
func (*PingNode) ProtoReflect ¶
func (x *PingNode) ProtoReflect() protoreflect.Message
type PingNodeResponse ¶
type PingNodeResponse struct { NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` TargetXkey string `protobuf:"bytes,3,opt,name=target_xkey,json=targetXkey,proto3" json:"target_xkey,omitempty"` StartedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ RunningAgents map[string]int32 `` /* 189-byte string literal not displayed */ // contains filtered or unexported fields }
func (*PingNodeResponse) Descriptor
deprecated
func (*PingNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use PingNodeResponse.ProtoReflect.Descriptor instead.
func (*PingNodeResponse) GetNodeId ¶
func (x *PingNodeResponse) GetNodeId() string
func (*PingNodeResponse) GetRunningAgents ¶
func (x *PingNodeResponse) GetRunningAgents() map[string]int32
func (*PingNodeResponse) GetStartedAt ¶
func (x *PingNodeResponse) GetStartedAt() *timestamppb.Timestamp
func (*PingNodeResponse) GetTags ¶
func (x *PingNodeResponse) GetTags() map[string]string
func (*PingNodeResponse) GetTargetXkey ¶
func (x *PingNodeResponse) GetTargetXkey() string
func (*PingNodeResponse) GetVersion ¶
func (x *PingNodeResponse) GetVersion() string
func (*PingNodeResponse) ProtoMessage ¶
func (*PingNodeResponse) ProtoMessage()
func (*PingNodeResponse) ProtoReflect ¶
func (x *PingNodeResponse) ProtoReflect() protoreflect.Message
func (*PingNodeResponse) Reset ¶
func (x *PingNodeResponse) Reset()
func (*PingNodeResponse) String ¶
func (x *PingNodeResponse) String() string
type PingWorkload ¶
type PingWorkload struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` WorkloadId string `protobuf:"bytes,3,opt,name=workload_id,json=workloadId,proto3" json:"workload_id,omitempty"` State string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
func (*PingWorkload) Descriptor
deprecated
func (*PingWorkload) Descriptor() ([]byte, []int)
Deprecated: Use PingWorkload.ProtoReflect.Descriptor instead.
func (*PingWorkload) GetNamespace ¶
func (x *PingWorkload) GetNamespace() string
func (*PingWorkload) GetState ¶
func (x *PingWorkload) GetState() string
func (*PingWorkload) GetType ¶
func (x *PingWorkload) GetType() string
func (*PingWorkload) GetWorkloadId ¶
func (x *PingWorkload) GetWorkloadId() string
func (*PingWorkload) ProtoMessage ¶
func (*PingWorkload) ProtoMessage()
func (*PingWorkload) ProtoReflect ¶
func (x *PingWorkload) ProtoReflect() protoreflect.Message
func (*PingWorkload) Reset ¶
func (x *PingWorkload) Reset()
func (*PingWorkload) String ¶
func (x *PingWorkload) String() string
type PingWorkloadResponse ¶
type PingWorkloadResponse struct { Workload *WorkloadSummary `protobuf:"bytes,1,opt,name=workload,proto3" json:"workload,omitempty"` // contains filtered or unexported fields }
func (*PingWorkloadResponse) Descriptor
deprecated
func (*PingWorkloadResponse) Descriptor() ([]byte, []int)
Deprecated: Use PingWorkloadResponse.ProtoReflect.Descriptor instead.
func (*PingWorkloadResponse) GetWorkload ¶
func (x *PingWorkloadResponse) GetWorkload() *WorkloadSummary
func (*PingWorkloadResponse) ProtoMessage ¶
func (*PingWorkloadResponse) ProtoMessage()
func (*PingWorkloadResponse) ProtoReflect ¶
func (x *PingWorkloadResponse) ProtoReflect() protoreflect.Message
func (*PingWorkloadResponse) Reset ¶
func (x *PingWorkloadResponse) Reset()
func (*PingWorkloadResponse) String ¶
func (x *PingWorkloadResponse) String() string
type QueryWorkload ¶
type QueryWorkload struct {
// contains filtered or unexported fields
}
func (*QueryWorkload) Descriptor
deprecated
func (*QueryWorkload) Descriptor() ([]byte, []int)
Deprecated: Use QueryWorkload.ProtoReflect.Descriptor instead.
func (*QueryWorkload) ProtoMessage ¶
func (*QueryWorkload) ProtoMessage()
func (*QueryWorkload) ProtoReflect ¶
func (x *QueryWorkload) ProtoReflect() protoreflect.Message
func (*QueryWorkload) Reset ¶
func (x *QueryWorkload) Reset()
func (*QueryWorkload) String ¶
func (x *QueryWorkload) String() string
type QueryWorkloads ¶
type QueryWorkloads struct {
// contains filtered or unexported fields
}
Asks the target agent for a list of all if its known, running workloads
func (*QueryWorkloads) Descriptor
deprecated
func (*QueryWorkloads) Descriptor() ([]byte, []int)
Deprecated: Use QueryWorkloads.ProtoReflect.Descriptor instead.
func (*QueryWorkloads) ProtoMessage ¶
func (*QueryWorkloads) ProtoMessage()
func (*QueryWorkloads) ProtoReflect ¶
func (x *QueryWorkloads) ProtoReflect() protoreflect.Message
func (*QueryWorkloads) Reset ¶
func (x *QueryWorkloads) Reset()
func (*QueryWorkloads) String ¶
func (x *QueryWorkloads) String() string
type RunningWorkload ¶
type RunningWorkload struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*RunningWorkload) Descriptor
deprecated
func (*RunningWorkload) Descriptor() ([]byte, []int)
Deprecated: Use RunningWorkload.ProtoReflect.Descriptor instead.
func (*RunningWorkload) GetId ¶
func (x *RunningWorkload) GetId() string
func (*RunningWorkload) GetName ¶
func (x *RunningWorkload) GetName() string
func (*RunningWorkload) GetNamespace ¶
func (x *RunningWorkload) GetNamespace() string
func (*RunningWorkload) ProtoMessage ¶
func (*RunningWorkload) ProtoMessage()
func (*RunningWorkload) ProtoReflect ¶
func (x *RunningWorkload) ProtoReflect() protoreflect.Message
func (*RunningWorkload) Reset ¶
func (x *RunningWorkload) Reset()
func (*RunningWorkload) String ¶
func (x *RunningWorkload) String() string
type SetLameDuck ¶
type SetLameDuck struct {
// contains filtered or unexported fields
}
func (*SetLameDuck) Descriptor
deprecated
func (*SetLameDuck) Descriptor() ([]byte, []int)
Deprecated: Use SetLameDuck.ProtoReflect.Descriptor instead.
func (*SetLameDuck) ProtoMessage ¶
func (*SetLameDuck) ProtoMessage()
func (*SetLameDuck) ProtoReflect ¶
func (x *SetLameDuck) ProtoReflect() protoreflect.Message
func (*SetLameDuck) Reset ¶
func (x *SetLameDuck) Reset()
func (*SetLameDuck) String ¶
func (x *SetLameDuck) String() string
type SpawnDirectStartProcess ¶
type SpawnDirectStartProcess struct {
// contains filtered or unexported fields
}
func (*SpawnDirectStartProcess) Descriptor
deprecated
func (*SpawnDirectStartProcess) Descriptor() ([]byte, []int)
Deprecated: Use SpawnDirectStartProcess.ProtoReflect.Descriptor instead.
func (*SpawnDirectStartProcess) ProtoMessage ¶
func (*SpawnDirectStartProcess) ProtoMessage()
func (*SpawnDirectStartProcess) ProtoReflect ¶
func (x *SpawnDirectStartProcess) ProtoReflect() protoreflect.Message
func (*SpawnDirectStartProcess) Reset ¶
func (x *SpawnDirectStartProcess) Reset()
func (*SpawnDirectStartProcess) String ¶
func (x *SpawnDirectStartProcess) String() string
type StartWorkload ¶
type StartWorkload struct { Argv []string `protobuf:"bytes,1,rep,name=argv,proto3" json:"argv,omitempty"` Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` Environment *EncEnvironment `protobuf:"bytes,3,opt,name=environment,proto3" json:"environment,omitempty"` Hash string `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"` HostServiceConfig *HostServicesConfig `protobuf:"bytes,5,opt,name=host_service_config,json=hostServiceConfig,proto3" json:"host_service_config,omitempty"` Jsdomain string `protobuf:"bytes,6,opt,name=jsdomain,proto3" json:"jsdomain,omitempty"` RetriedAt string `protobuf:"bytes,7,opt,name=retried_at,json=retriedAt,proto3" json:"retried_at,omitempty"` RetryCount int32 `protobuf:"varint,8,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"` TriggerSubject string `protobuf:"bytes,9,opt,name=trigger_subject,json=triggerSubject,proto3" json:"trigger_subject,omitempty"` Uri string `protobuf:"bytes,10,opt,name=uri,proto3" json:"uri,omitempty"` WorkloadId string `protobuf:"bytes,11,opt,name=workload_id,json=workloadId,proto3" json:"workload_id,omitempty"` WorkloadName string `protobuf:"bytes,12,opt,name=workload_name,json=workloadName,proto3" json:"workload_name,omitempty"` WorkloadType string `protobuf:"bytes,13,opt,name=workload_type,json=workloadType,proto3" json:"workload_type,omitempty"` Namespace string `protobuf:"bytes,14,opt,name=namespace,proto3" json:"namespace,omitempty"` WorkloadRuntype string `protobuf:"bytes,15,opt,name=workload_runtype,json=workloadRuntype,proto3" json:"workload_runtype,omitempty"` // contains filtered or unexported fields }
Sent by the control API actor to an agent actor to request a workload be started
func (*StartWorkload) Descriptor
deprecated
func (*StartWorkload) Descriptor() ([]byte, []int)
Deprecated: Use StartWorkload.ProtoReflect.Descriptor instead.
func (*StartWorkload) GetArgv ¶
func (x *StartWorkload) GetArgv() []string
func (*StartWorkload) GetDescription ¶
func (x *StartWorkload) GetDescription() string
func (*StartWorkload) GetEnvironment ¶
func (x *StartWorkload) GetEnvironment() *EncEnvironment
func (*StartWorkload) GetHash ¶
func (x *StartWorkload) GetHash() string
func (*StartWorkload) GetHostServiceConfig ¶
func (x *StartWorkload) GetHostServiceConfig() *HostServicesConfig
func (*StartWorkload) GetJsdomain ¶
func (x *StartWorkload) GetJsdomain() string
func (*StartWorkload) GetNamespace ¶
func (x *StartWorkload) GetNamespace() string
func (*StartWorkload) GetRetriedAt ¶
func (x *StartWorkload) GetRetriedAt() string
func (*StartWorkload) GetRetryCount ¶
func (x *StartWorkload) GetRetryCount() int32
func (*StartWorkload) GetTriggerSubject ¶
func (x *StartWorkload) GetTriggerSubject() string
func (*StartWorkload) GetUri ¶
func (x *StartWorkload) GetUri() string
func (*StartWorkload) GetWorkloadId ¶
func (x *StartWorkload) GetWorkloadId() string
func (*StartWorkload) GetWorkloadName ¶
func (x *StartWorkload) GetWorkloadName() string
func (*StartWorkload) GetWorkloadRuntype ¶
func (x *StartWorkload) GetWorkloadRuntype() string
func (*StartWorkload) GetWorkloadType ¶
func (x *StartWorkload) GetWorkloadType() string
func (*StartWorkload) ProtoMessage ¶
func (*StartWorkload) ProtoMessage()
func (*StartWorkload) ProtoReflect ¶
func (x *StartWorkload) ProtoReflect() protoreflect.Message
func (*StartWorkload) Reset ¶
func (x *StartWorkload) Reset()
func (*StartWorkload) String ¶
func (x *StartWorkload) String() string
type StopWorkload ¶
type StopWorkload struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` WorkloadId string `protobuf:"bytes,2,opt,name=workload_id,json=workloadId,proto3" json:"workload_id,omitempty"` // contains filtered or unexported fields }
Request sent by the control API actor to an agent actor asking to stop a workload
func (*StopWorkload) Descriptor
deprecated
func (*StopWorkload) Descriptor() ([]byte, []int)
Deprecated: Use StopWorkload.ProtoReflect.Descriptor instead.
func (*StopWorkload) GetNamespace ¶
func (x *StopWorkload) GetNamespace() string
func (*StopWorkload) GetWorkloadId ¶
func (x *StopWorkload) GetWorkloadId() string
func (*StopWorkload) ProtoMessage ¶
func (*StopWorkload) ProtoMessage()
func (*StopWorkload) ProtoReflect ¶
func (x *StopWorkload) ProtoReflect() protoreflect.Message
func (*StopWorkload) Reset ¶
func (x *StopWorkload) Reset()
func (*StopWorkload) String ¶
func (x *StopWorkload) String() string
type WorkloadList ¶
type WorkloadList struct { Workloads []*WorkloadSummary `protobuf:"bytes,1,rep,name=workloads,proto3" json:"workloads,omitempty"` // contains filtered or unexported fields }
func (*WorkloadList) Descriptor
deprecated
func (*WorkloadList) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadList.ProtoReflect.Descriptor instead.
func (*WorkloadList) GetWorkloads ¶
func (x *WorkloadList) GetWorkloads() []*WorkloadSummary
func (*WorkloadList) ProtoMessage ¶
func (*WorkloadList) ProtoMessage()
func (*WorkloadList) ProtoReflect ¶
func (x *WorkloadList) ProtoReflect() protoreflect.Message
func (*WorkloadList) Reset ¶
func (x *WorkloadList) Reset()
func (*WorkloadList) String ¶
func (x *WorkloadList) String() string
type WorkloadStarted ¶
type WorkloadStarted struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Issuer string `protobuf:"bytes,2,opt,name=issuer,proto3" json:"issuer,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Started bool `protobuf:"varint,4,opt,name=started,proto3" json:"started,omitempty"` // contains filtered or unexported fields }
Reply from the agent actor containing the results of the attempt to start a workload
func (*WorkloadStarted) Descriptor
deprecated
func (*WorkloadStarted) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadStarted.ProtoReflect.Descriptor instead.
func (*WorkloadStarted) GetId ¶
func (x *WorkloadStarted) GetId() string
func (*WorkloadStarted) GetIssuer ¶
func (x *WorkloadStarted) GetIssuer() string
func (*WorkloadStarted) GetName ¶
func (x *WorkloadStarted) GetName() string
func (*WorkloadStarted) GetStarted ¶
func (x *WorkloadStarted) GetStarted() bool
func (*WorkloadStarted) ProtoMessage ¶
func (*WorkloadStarted) ProtoMessage()
func (*WorkloadStarted) ProtoReflect ¶
func (x *WorkloadStarted) ProtoReflect() protoreflect.Message
func (*WorkloadStarted) Reset ¶
func (x *WorkloadStarted) Reset()
func (*WorkloadStarted) String ¶
func (x *WorkloadStarted) String() string
type WorkloadStopped ¶
type WorkloadStopped struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Issuer string `protobuf:"bytes,2,opt,name=issuer,proto3" json:"issuer,omitempty"` Stopped bool `protobuf:"varint,3,opt,name=stopped,proto3" json:"stopped,omitempty"` // contains filtered or unexported fields }
Response from the agent actor indicating the results of the workload stop attempt
func (*WorkloadStopped) Descriptor
deprecated
func (*WorkloadStopped) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadStopped.ProtoReflect.Descriptor instead.
func (*WorkloadStopped) GetId ¶
func (x *WorkloadStopped) GetId() string
func (*WorkloadStopped) GetIssuer ¶
func (x *WorkloadStopped) GetIssuer() string
func (*WorkloadStopped) GetStopped ¶
func (x *WorkloadStopped) GetStopped() bool
func (*WorkloadStopped) ProtoMessage ¶
func (*WorkloadStopped) ProtoMessage()
func (*WorkloadStopped) ProtoReflect ¶
func (x *WorkloadStopped) ProtoReflect() protoreflect.Message
func (*WorkloadStopped) Reset ¶
func (x *WorkloadStopped) Reset()
func (*WorkloadStopped) String ¶
func (x *WorkloadStopped) String() string
type WorkloadSummary ¶
type WorkloadSummary struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Runtime string `protobuf:"bytes,3,opt,name=runtime,proto3" json:"runtime,omitempty"` StartedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` WorkloadType string `protobuf:"bytes,5,opt,name=workload_type,json=workloadType,proto3" json:"workload_type,omitempty"` WorkloadRuntype string `protobuf:"bytes,6,opt,name=workload_runtype,json=workloadRuntype,proto3" json:"workload_runtype,omitempty"` Namespace string `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"` State string `protobuf:"bytes,8,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
func (*WorkloadSummary) Descriptor
deprecated
func (*WorkloadSummary) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadSummary.ProtoReflect.Descriptor instead.
func (*WorkloadSummary) GetId ¶
func (x *WorkloadSummary) GetId() string
func (*WorkloadSummary) GetName ¶
func (x *WorkloadSummary) GetName() string
func (*WorkloadSummary) GetNamespace ¶
func (x *WorkloadSummary) GetNamespace() string
func (*WorkloadSummary) GetRuntime ¶
func (x *WorkloadSummary) GetRuntime() string
func (*WorkloadSummary) GetStartedAt ¶
func (x *WorkloadSummary) GetStartedAt() *timestamppb.Timestamp
func (*WorkloadSummary) GetState ¶
func (x *WorkloadSummary) GetState() string
func (*WorkloadSummary) GetWorkloadRuntype ¶
func (x *WorkloadSummary) GetWorkloadRuntype() string
func (*WorkloadSummary) GetWorkloadType ¶
func (x *WorkloadSummary) GetWorkloadType() string
func (*WorkloadSummary) ProtoMessage ¶
func (*WorkloadSummary) ProtoMessage()
func (*WorkloadSummary) ProtoReflect ¶
func (x *WorkloadSummary) ProtoReflect() protoreflect.Message
func (*WorkloadSummary) Reset ¶
func (x *WorkloadSummary) Reset()
func (*WorkloadSummary) String ¶
func (x *WorkloadSummary) String() string