Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)
- func RegisterControlPlaneServiceServer(s grpc.ServiceRegistrar, srv ControlPlaneServiceServer)
- func RegisterHealthServer(s grpc.ServiceRegistrar, srv HealthServer)
- type AgentServiceClient
- type AgentServiceServer
- type AgentService_StreamLogsClient
- type AgentService_StreamLogsServer
- type CPBuildType
- func (CPBuildType) Descriptor() protoreflect.EnumDescriptor
- func (x CPBuildType) Enum() *CPBuildType
- func (CPBuildType) EnumDescriptor() ([]byte, []int)deprecated
- func (x CPBuildType) Number() protoreflect.EnumNumber
- func (x CPBuildType) String() string
- func (CPBuildType) Type() protoreflect.EnumType
- type CPDeployRequest
- func (*CPDeployRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CPDeployRequest) GetAppId() string
- func (x *CPDeployRequest) GetAppName() string
- func (x *CPDeployRequest) GetArtifact() string
- func (x *CPDeployRequest) GetBuildType() CPBuildType
- func (x *CPDeployRequest) GetConfig() *CPDeploymentConfig
- func (x *CPDeployRequest) GetDeploymentId() string
- func (x *CPDeployRequest) GetServiceName() string
- func (x *CPDeployRequest) GetVersion() int32
- func (*CPDeployRequest) ProtoMessage()
- func (x *CPDeployRequest) ProtoReflect() protoreflect.Message
- func (x *CPDeployRequest) Reset()
- func (x *CPDeployRequest) String() string
- type CPDeploymentConfig
- func (*CPDeploymentConfig) Descriptor() ([]byte, []int)deprecated
- func (x *CPDeploymentConfig) GetDependsOn() []string
- func (x *CPDeploymentConfig) GetEnvVars() map[string]string
- func (x *CPDeploymentConfig) GetHealthCheck() *CPHealthCheckConfig
- func (x *CPDeploymentConfig) GetPort() int32
- func (x *CPDeploymentConfig) GetReplicas() int32
- func (x *CPDeploymentConfig) GetResources() *CPResourceSpec
- func (*CPDeploymentConfig) ProtoMessage()
- func (x *CPDeploymentConfig) ProtoReflect() protoreflect.Message
- func (x *CPDeploymentConfig) Reset()
- func (x *CPDeploymentConfig) String() string
- type CPHealthCheckConfig
- func (*CPHealthCheckConfig) Descriptor() ([]byte, []int)deprecated
- func (x *CPHealthCheckConfig) GetHealthyThreshold() int32
- func (x *CPHealthCheckConfig) GetIntervalSeconds() int32
- func (x *CPHealthCheckConfig) GetPath() string
- func (x *CPHealthCheckConfig) GetPort() int32
- func (x *CPHealthCheckConfig) GetTimeoutSeconds() int32
- func (x *CPHealthCheckConfig) GetUnhealthyThreshold() int32
- func (*CPHealthCheckConfig) ProtoMessage()
- func (x *CPHealthCheckConfig) ProtoReflect() protoreflect.Message
- func (x *CPHealthCheckConfig) Reset()
- func (x *CPHealthCheckConfig) String() string
- type CPLogEntry
- func (*CPLogEntry) Descriptor() ([]byte, []int)deprecated
- func (x *CPLogEntry) GetDeploymentId() string
- func (x *CPLogEntry) GetLevel() CPLogLevel
- func (x *CPLogEntry) GetMessage() string
- func (x *CPLogEntry) GetMetadata() map[string]string
- func (x *CPLogEntry) GetServiceName() string
- func (x *CPLogEntry) GetStreamId() string
- func (x *CPLogEntry) GetTimestamp() *timestamppb.Timestamp
- func (*CPLogEntry) ProtoMessage()
- func (x *CPLogEntry) ProtoReflect() protoreflect.Message
- func (x *CPLogEntry) Reset()
- func (x *CPLogEntry) String() string
- type CPLogLevel
- type CPLogStreamRequest
- func (*CPLogStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CPLogStreamRequest) GetDeploymentId() string
- func (x *CPLogStreamRequest) GetFollow() bool
- func (x *CPLogStreamRequest) GetLevelFilter() CPLogLevel
- func (x *CPLogStreamRequest) GetServiceFilter() string
- func (x *CPLogStreamRequest) GetStreamId() string
- func (x *CPLogStreamRequest) GetTailLines() int32
- func (*CPLogStreamRequest) ProtoMessage()
- func (x *CPLogStreamRequest) ProtoReflect() protoreflect.Message
- func (x *CPLogStreamRequest) Reset()
- func (x *CPLogStreamRequest) String() string
- type CPResourceSpec
- func (*CPResourceSpec) Descriptor() ([]byte, []int)deprecated
- func (x *CPResourceSpec) GetCpu() string
- func (x *CPResourceSpec) GetMemory() string
- func (*CPResourceSpec) ProtoMessage()
- func (x *CPResourceSpec) ProtoReflect() protoreflect.Message
- func (x *CPResourceSpec) Reset()
- func (x *CPResourceSpec) String() string
- type CPRestartRequest
- type CPStopRequest
- func (*CPStopRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CPStopRequest) GetDeploymentId() string
- func (x *CPStopRequest) GetForce() bool
- func (x *CPStopRequest) GetTimeoutSeconds() int32
- func (*CPStopRequest) ProtoMessage()
- func (x *CPStopRequest) ProtoReflect() protoreflect.Message
- func (x *CPStopRequest) Reset()
- func (x *CPStopRequest) String() string
- type CPUpdateConfigRequest
- func (*CPUpdateConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CPUpdateConfigRequest) GetConfig() *CPDeploymentConfig
- func (x *CPUpdateConfigRequest) GetDeploymentId() string
- func (*CPUpdateConfigRequest) ProtoMessage()
- func (x *CPUpdateConfigRequest) ProtoReflect() protoreflect.Message
- func (x *CPUpdateConfigRequest) Reset()
- func (x *CPUpdateConfigRequest) String() string
- type CommandType
- func (CommandType) Descriptor() protoreflect.EnumDescriptor
- func (x CommandType) Enum() *CommandType
- func (CommandType) EnumDescriptor() ([]byte, []int)deprecated
- func (x CommandType) Number() protoreflect.EnumNumber
- func (x CommandType) String() string
- func (CommandType) Type() protoreflect.EnumType
- type ControlPlaneServiceClient
- type ControlPlaneServiceServer
- type ControlPlaneService_PushLogsClient
- type ControlPlaneService_PushLogsServer
- type ControlPlaneService_WatchCommandsClient
- type ControlPlaneService_WatchCommandsServer
- type DeployRequest
- func (*DeployRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeployRequest) GetArtifact() string
- func (x *DeployRequest) GetBuildType() string
- func (x *DeployRequest) GetConfig() *RuntimeConfig
- func (x *DeployRequest) GetDeploymentId() string
- func (x *DeployRequest) GetSecrets() map[string]string
- func (*DeployRequest) ProtoMessage()
- func (x *DeployRequest) ProtoReflect() protoreflect.Message
- func (x *DeployRequest) Reset()
- func (x *DeployRequest) String() string
- type DeployResponse
- func (*DeployResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeployResponse) GetMessage() string
- func (x *DeployResponse) GetSuccess() bool
- func (*DeployResponse) ProtoMessage()
- func (x *DeployResponse) ProtoReflect() protoreflect.Message
- func (x *DeployResponse) Reset()
- func (x *DeployResponse) String() string
- type DeploymentCommand
- func (*DeploymentCommand) Descriptor() ([]byte, []int)deprecated
- func (x *DeploymentCommand) GetCommand() isDeploymentCommand_Command
- func (x *DeploymentCommand) GetCommandId() string
- func (x *DeploymentCommand) GetDeadline() *timestamppb.Timestamp
- func (x *DeploymentCommand) GetDeploy() *CPDeployRequest
- func (x *DeploymentCommand) GetRestart() *CPRestartRequest
- func (x *DeploymentCommand) GetStop() *CPStopRequest
- func (x *DeploymentCommand) GetStreamLogs() *CPLogStreamRequest
- func (x *DeploymentCommand) GetType() CommandType
- func (x *DeploymentCommand) GetUpdateConfig() *CPUpdateConfigRequest
- func (*DeploymentCommand) ProtoMessage()
- func (x *DeploymentCommand) ProtoReflect() protoreflect.Message
- func (x *DeploymentCommand) Reset()
- func (x *DeploymentCommand) String() string
- type DeploymentCommand_Deploy
- type DeploymentCommand_Restart
- type DeploymentCommand_Stop
- type DeploymentCommand_StreamLogs
- type DeploymentCommand_UpdateConfig
- type DeploymentStatus
- func (DeploymentStatus) Descriptor() protoreflect.EnumDescriptor
- func (x DeploymentStatus) Enum() *DeploymentStatus
- func (DeploymentStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x DeploymentStatus) Number() protoreflect.EnumNumber
- func (x DeploymentStatus) String() string
- func (DeploymentStatus) Type() protoreflect.EnumType
- type DiskStats
- func (*DiskStats) Descriptor() ([]byte, []int)deprecated
- func (x *DiskStats) GetAvailable() int64
- func (x *DiskStats) GetPath() string
- func (x *DiskStats) GetTotal() int64
- func (x *DiskStats) GetUsagePercent() float64
- func (x *DiskStats) GetUsed() int64
- func (*DiskStats) ProtoMessage()
- func (x *DiskStats) ProtoReflect() protoreflect.Message
- func (x *DiskStats) Reset()
- func (x *DiskStats) String() string
- type GetStatusRequest
- type GetStatusResponse
- func (*GetStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStatusResponse) GetDeploymentId() string
- func (x *GetStatusResponse) GetMessage() string
- func (x *GetStatusResponse) GetStartedAt() int64
- func (x *GetStatusResponse) GetStatus() string
- func (x *GetStatusResponse) GetUpdatedAt() int64
- func (*GetStatusResponse) ProtoMessage()
- func (x *GetStatusResponse) ProtoReflect() protoreflect.Message
- func (x *GetStatusResponse) Reset()
- func (x *GetStatusResponse) String() string
- type HealthCheckConfig
- func (*HealthCheckConfig) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckConfig) GetIntervalSeconds() int32
- func (x *HealthCheckConfig) GetPath() string
- func (x *HealthCheckConfig) GetPort() int32
- func (x *HealthCheckConfig) GetRetries() int32
- func (x *HealthCheckConfig) GetTimeoutSeconds() int32
- func (*HealthCheckConfig) ProtoMessage()
- func (x *HealthCheckConfig) ProtoReflect() protoreflect.Message
- func (x *HealthCheckConfig) Reset()
- func (x *HealthCheckConfig) String() string
- type HealthCheckRequest
- func (*HealthCheckRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckRequest) GetService() string
- func (*HealthCheckRequest) ProtoMessage()
- func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
- func (x *HealthCheckRequest) Reset()
- func (x *HealthCheckRequest) String() string
- type HealthCheckResponse
- func (*HealthCheckResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus
- func (*HealthCheckResponse) ProtoMessage()
- func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message
- func (x *HealthCheckResponse) Reset()
- func (x *HealthCheckResponse) String() string
- type HealthCheckResponse_ServingStatus
- func (HealthCheckResponse_ServingStatus) Descriptor() protoreflect.EnumDescriptor
- func (x HealthCheckResponse_ServingStatus) Enum() *HealthCheckResponse_ServingStatus
- func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x HealthCheckResponse_ServingStatus) Number() protoreflect.EnumNumber
- func (x HealthCheckResponse_ServingStatus) String() string
- func (HealthCheckResponse_ServingStatus) Type() protoreflect.EnumType
- type HealthClient
- type HealthServer
- type Health_WatchClient
- type Health_WatchServer
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatRequest) GetDraining() bool
- func (x *HeartbeatRequest) GetNodeId() string
- func (x *HeartbeatRequest) GetNodeInfo() *NodeInfo
- func (x *HeartbeatRequest) GetTimestamp() *timestamppb.Timestamp
- func (*HeartbeatRequest) ProtoMessage()
- func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
- func (x *HeartbeatRequest) Reset()
- func (x *HeartbeatRequest) String() string
- type HeartbeatResponse
- type LogEntry
- func (*LogEntry) Descriptor() ([]byte, []int)deprecated
- func (x *LogEntry) GetDeploymentId() string
- func (x *LogEntry) GetLevel() string
- func (x *LogEntry) GetMessage() string
- func (x *LogEntry) GetSource() string
- func (x *LogEntry) GetTimestamp() int64
- func (*LogEntry) ProtoMessage()
- func (x *LogEntry) ProtoReflect() protoreflect.Message
- func (x *LogEntry) Reset()
- func (x *LogEntry) String() string
- type NodeConfig
- func (*NodeConfig) Descriptor() ([]byte, []int)deprecated
- func (x *NodeConfig) GetHeartbeatIntervalSeconds() int32
- func (x *NodeConfig) GetLogBufferSize() int32
- func (x *NodeConfig) GetMaxConcurrentDeployments() int32
- func (*NodeConfig) ProtoMessage()
- func (x *NodeConfig) ProtoReflect() protoreflect.Message
- func (x *NodeConfig) Reset()
- func (x *NodeConfig) String() string
- type NodeDiskMetrics
- func (*NodeDiskMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *NodeDiskMetrics) GetContainerStorage() *DiskStats
- func (x *NodeDiskMetrics) GetNixStore() *DiskStats
- func (*NodeDiskMetrics) ProtoMessage()
- func (x *NodeDiskMetrics) ProtoReflect() protoreflect.Message
- func (x *NodeDiskMetrics) Reset()
- func (x *NodeDiskMetrics) String() string
- type NodeInfo
- func (*NodeInfo) Descriptor() ([]byte, []int)deprecated
- func (x *NodeInfo) GetActiveDeployments() int32
- func (x *NodeInfo) GetAddress() string
- func (x *NodeInfo) GetAvailableSlots() int32
- func (x *NodeInfo) GetCachedPaths() []string
- func (x *NodeInfo) GetDiskMetrics() *NodeDiskMetrics
- func (x *NodeInfo) GetGrpcPort() int32
- func (x *NodeInfo) GetHostname() string
- func (x *NodeInfo) GetId() string
- func (x *NodeInfo) GetResources() *ResourceMetrics
- func (*NodeInfo) ProtoMessage()
- func (x *NodeInfo) ProtoReflect() protoreflect.Message
- func (x *NodeInfo) Reset()
- func (x *NodeInfo) String() string
- type PortMapping
- func (*PortMapping) Descriptor() ([]byte, []int)deprecated
- func (x *PortMapping) GetContainerPort() int32
- func (x *PortMapping) GetProtocol() string
- func (*PortMapping) ProtoMessage()
- func (x *PortMapping) ProtoReflect() protoreflect.Message
- func (x *PortMapping) Reset()
- func (x *PortMapping) String() string
- type PushLogsResponse
- type RegisterRequest
- func (*RegisterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterRequest) GetAuthToken() string
- func (x *RegisterRequest) GetNodeInfo() *NodeInfo
- func (*RegisterRequest) ProtoMessage()
- func (x *RegisterRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterRequest) Reset()
- func (x *RegisterRequest) String() string
- type RegisterResponse
- func (*RegisterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterResponse) GetConfig() *NodeConfig
- func (x *RegisterResponse) GetMessage() string
- func (x *RegisterResponse) GetNodeId() string
- func (x *RegisterResponse) GetSuccess() bool
- func (*RegisterResponse) ProtoMessage()
- func (x *RegisterResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterResponse) Reset()
- func (x *RegisterResponse) String() string
- type ResourceMetrics
- func (*ResourceMetrics) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceMetrics) GetCpuAvailable() float64
- func (x *ResourceMetrics) GetCpuTotal() float64
- func (x *ResourceMetrics) GetDiskAvailable() int64
- func (x *ResourceMetrics) GetDiskTotal() int64
- func (x *ResourceMetrics) GetMemoryAvailable() int64
- func (x *ResourceMetrics) GetMemoryTotal() int64
- func (*ResourceMetrics) ProtoMessage()
- func (x *ResourceMetrics) ProtoReflect() protoreflect.Message
- func (x *ResourceMetrics) Reset()
- func (x *ResourceMetrics) String() string
- type ResourceSpec
- func (*ResourceSpec) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceSpec) GetCpu() string
- func (x *ResourceSpec) GetMemory() string
- func (*ResourceSpec) ProtoMessage()
- func (x *ResourceSpec) ProtoReflect() protoreflect.Message
- func (x *ResourceSpec) Reset()
- func (x *ResourceSpec) String() string
- type ResourceUsage
- func (*ResourceUsage) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceUsage) GetCpuPercent() float64
- func (x *ResourceUsage) GetMemoryBytes() int64
- func (x *ResourceUsage) GetNetworkRxBytes() int64
- func (x *ResourceUsage) GetNetworkTxBytes() int64
- func (*ResourceUsage) ProtoMessage()
- func (x *ResourceUsage) ProtoReflect() protoreflect.Message
- func (x *ResourceUsage) Reset()
- func (x *ResourceUsage) String() string
- type RuntimeConfig
- func (*RuntimeConfig) Descriptor() ([]byte, []int)deprecated
- func (x *RuntimeConfig) GetEnvVars() map[string]string
- func (x *RuntimeConfig) GetHealthCheck() *HealthCheckConfig
- func (x *RuntimeConfig) GetPorts() []*PortMapping
- func (x *RuntimeConfig) GetResources() *ResourceSpec
- func (*RuntimeConfig) ProtoMessage()
- func (x *RuntimeConfig) ProtoReflect() protoreflect.Message
- func (x *RuntimeConfig) Reset()
- func (x *RuntimeConfig) String() string
- type StatusReport
- func (*StatusReport) Descriptor() ([]byte, []int)deprecated
- func (x *StatusReport) GetCommandId() string
- func (x *StatusReport) GetContainerId() string
- func (x *StatusReport) GetDeploymentId() string
- func (x *StatusReport) GetErrorMessage() string
- func (x *StatusReport) GetExitCode() int32
- func (x *StatusReport) GetNodeId() string
- func (x *StatusReport) GetResourceUsage() *ResourceUsage
- func (x *StatusReport) GetStartedAt() *timestamppb.Timestamp
- func (x *StatusReport) GetStatus() DeploymentStatus
- func (*StatusReport) ProtoMessage()
- func (x *StatusReport) ProtoReflect() protoreflect.Message
- func (x *StatusReport) Reset()
- func (x *StatusReport) String() string
- type StatusResponse
- type StopRequest
- type StopResponse
- func (*StopResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StopResponse) GetMessage() string
- func (x *StopResponse) GetSuccess() bool
- func (*StopResponse) ProtoMessage()
- func (x *StopResponse) ProtoReflect() protoreflect.Message
- func (x *StopResponse) Reset()
- func (x *StopResponse) String() string
- type StreamLogsRequest
- func (*StreamLogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamLogsRequest) GetDeploymentId() string
- func (x *StreamLogsRequest) GetFollow() bool
- func (x *StreamLogsRequest) GetTailLines() int32
- func (*StreamLogsRequest) ProtoMessage()
- func (x *StreamLogsRequest) ProtoReflect() protoreflect.Message
- func (x *StreamLogsRequest) Reset()
- func (x *StreamLogsRequest) String() string
- type UnimplementedAgentServiceServer
- func (UnimplementedAgentServiceServer) Deploy(context.Context, *DeployRequest) (*DeployResponse, error)
- func (UnimplementedAgentServiceServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
- func (UnimplementedAgentServiceServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
- func (UnimplementedAgentServiceServer) StreamLogs(*StreamLogsRequest, grpc.ServerStreamingServer[LogEntry]) error
- type UnimplementedControlPlaneServiceServer
- func (UnimplementedControlPlaneServiceServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
- func (UnimplementedControlPlaneServiceServer) PushLogs(grpc.ClientStreamingServer[CPLogEntry, PushLogsResponse]) error
- func (UnimplementedControlPlaneServiceServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
- func (UnimplementedControlPlaneServiceServer) ReportStatus(context.Context, *StatusReport) (*StatusResponse, error)
- func (UnimplementedControlPlaneServiceServer) WatchCommands(*WatchCommandsRequest, grpc.ServerStreamingServer[DeploymentCommand]) error
- type UnimplementedHealthServer
- type UnsafeAgentServiceServer
- type UnsafeControlPlaneServiceServer
- type UnsafeHealthServer
- type WatchCommandsRequest
- func (*WatchCommandsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchCommandsRequest) GetAuthToken() string
- func (x *WatchCommandsRequest) GetNodeId() string
- func (*WatchCommandsRequest) ProtoMessage()
- func (x *WatchCommandsRequest) ProtoReflect() protoreflect.Message
- func (x *WatchCommandsRequest) Reset()
- func (x *WatchCommandsRequest) String() string
Constants ¶
const ( AgentService_Deploy_FullMethodName = "/agent.AgentService/Deploy" AgentService_Stop_FullMethodName = "/agent.AgentService/Stop" AgentService_GetStatus_FullMethodName = "/agent.AgentService/GetStatus" AgentService_StreamLogs_FullMethodName = "/agent.AgentService/StreamLogs" )
const ( ControlPlaneService_Register_FullMethodName = "/controlplane.ControlPlaneService/Register" ControlPlaneService_Heartbeat_FullMethodName = "/controlplane.ControlPlaneService/Heartbeat" ControlPlaneService_WatchCommands_FullMethodName = "/controlplane.ControlPlaneService/WatchCommands" ControlPlaneService_ReportStatus_FullMethodName = "/controlplane.ControlPlaneService/ReportStatus" ControlPlaneService_PushLogs_FullMethodName = "/controlplane.ControlPlaneService/PushLogs" )
const ( Health_Check_FullMethodName = "/controlplane.Health/Check" Health_Watch_FullMethodName = "/controlplane.Health/Watch" )
Variables ¶
var ( CommandType_name = map[int32]string{ 0: "COMMAND_UNKNOWN", 1: "COMMAND_DEPLOY", 2: "COMMAND_STOP", 3: "COMMAND_RESTART", 4: "COMMAND_UPDATE_CONFIG", 5: "COMMAND_STREAM_LOGS", } CommandType_value = map[string]int32{ "COMMAND_UNKNOWN": 0, "COMMAND_DEPLOY": 1, "COMMAND_STOP": 2, "COMMAND_RESTART": 3, "COMMAND_UPDATE_CONFIG": 4, "COMMAND_STREAM_LOGS": 5, } )
Enum value maps for CommandType.
var ( CPBuildType_name = map[int32]string{ 0: "CP_BUILD_TYPE_UNKNOWN", 1: "CP_BUILD_TYPE_OCI", 2: "CP_BUILD_TYPE_NIX", } CPBuildType_value = map[string]int32{ "CP_BUILD_TYPE_UNKNOWN": 0, "CP_BUILD_TYPE_OCI": 1, "CP_BUILD_TYPE_NIX": 2, } )
Enum value maps for CPBuildType.
var ( DeploymentStatus_name = map[int32]string{ 0: "STATUS_UNKNOWN", 1: "STATUS_PENDING", 2: "STATUS_PULLING", 3: "STATUS_STARTING", 4: "STATUS_RUNNING", 5: "STATUS_STOPPING", 6: "STATUS_STOPPED", 7: "STATUS_FAILED", } DeploymentStatus_value = map[string]int32{ "STATUS_UNKNOWN": 0, "STATUS_PENDING": 1, "STATUS_PULLING": 2, "STATUS_STARTING": 3, "STATUS_RUNNING": 4, "STATUS_STOPPING": 5, "STATUS_STOPPED": 6, "STATUS_FAILED": 7, } )
Enum value maps for DeploymentStatus.
var ( CPLogLevel_name = map[int32]string{ 0: "CP_LOG_UNKNOWN", 1: "CP_LOG_DEBUG", 2: "CP_LOG_INFO", 3: "CP_LOG_WARN", 4: "CP_LOG_ERROR", } CPLogLevel_value = map[string]int32{ "CP_LOG_UNKNOWN": 0, "CP_LOG_DEBUG": 1, "CP_LOG_INFO": 2, "CP_LOG_WARN": 3, "CP_LOG_ERROR": 4, } )
Enum value maps for CPLogLevel.
var ( HealthCheckResponse_ServingStatus_name = map[int32]string{ 0: "UNKNOWN", 1: "SERVING", 2: "NOT_SERVING", } HealthCheckResponse_ServingStatus_value = map[string]int32{ "UNKNOWN": 0, "SERVING": 1, "NOT_SERVING": 2, } )
Enum value maps for HealthCheckResponse_ServingStatus.
var AgentService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "agent.AgentService", HandlerType: (*AgentServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Deploy", Handler: _AgentService_Deploy_Handler, }, { MethodName: "Stop", Handler: _AgentService_Stop_Handler, }, { MethodName: "GetStatus", Handler: _AgentService_GetStatus_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamLogs", Handler: _AgentService_StreamLogs_Handler, ServerStreams: true, }, }, Metadata: "api/proto/agent.proto", }
AgentService_ServiceDesc is the grpc.ServiceDesc for AgentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ControlPlaneService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "controlplane.ControlPlaneService", HandlerType: (*ControlPlaneServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Register", Handler: _ControlPlaneService_Register_Handler, }, { MethodName: "Heartbeat", Handler: _ControlPlaneService_Heartbeat_Handler, }, { MethodName: "ReportStatus", Handler: _ControlPlaneService_ReportStatus_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "WatchCommands", Handler: _ControlPlaneService_WatchCommands_Handler, ServerStreams: true, }, { StreamName: "PushLogs", Handler: _ControlPlaneService_PushLogs_Handler, ClientStreams: true, }, }, Metadata: "api/proto/controlplane.proto", }
ControlPlaneService_ServiceDesc is the grpc.ServiceDesc for ControlPlaneService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_api_proto_agent_proto protoreflect.FileDescriptor
var File_api_proto_controlplane_proto protoreflect.FileDescriptor
var Health_ServiceDesc = grpc.ServiceDesc{ ServiceName: "controlplane.Health", HandlerType: (*HealthServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Check", Handler: _Health_Check_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Watch", Handler: _Health_Watch_Handler, ServerStreams: true, }, }, Metadata: "api/proto/controlplane.proto", }
Health_ServiceDesc is the grpc.ServiceDesc for Health service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAgentServiceServer ¶
func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)
func RegisterControlPlaneServiceServer ¶
func RegisterControlPlaneServiceServer(s grpc.ServiceRegistrar, srv ControlPlaneServiceServer)
func RegisterHealthServer ¶
func RegisterHealthServer(s grpc.ServiceRegistrar, srv HealthServer)
Types ¶
type AgentServiceClient ¶
type AgentServiceClient interface {
// Deploy instructs the agent to deploy an artifact on the node.
Deploy(ctx context.Context, in *DeployRequest, opts ...grpc.CallOption) (*DeployResponse, error)
// Stop instructs the agent to stop a running deployment.
Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
// GetStatus retrieves the current status of a deployment.
GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)
// StreamLogs streams logs from a deployment in real-time.
StreamLogs(ctx context.Context, in *StreamLogsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogEntry], error)
}
AgentServiceClient is the client API for AgentService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
AgentService defines the gRPC interface for communication between the control plane and node agents.
func NewAgentServiceClient ¶
func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient
type AgentServiceServer ¶
type AgentServiceServer interface {
// Deploy instructs the agent to deploy an artifact on the node.
Deploy(context.Context, *DeployRequest) (*DeployResponse, error)
// Stop instructs the agent to stop a running deployment.
Stop(context.Context, *StopRequest) (*StopResponse, error)
// GetStatus retrieves the current status of a deployment.
GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
// StreamLogs streams logs from a deployment in real-time.
StreamLogs(*StreamLogsRequest, grpc.ServerStreamingServer[LogEntry]) error
// contains filtered or unexported methods
}
AgentServiceServer is the server API for AgentService service. All implementations must embed UnimplementedAgentServiceServer for forward compatibility.
AgentService defines the gRPC interface for communication between the control plane and node agents.
type AgentService_StreamLogsClient ¶
type AgentService_StreamLogsClient = grpc.ServerStreamingClient[LogEntry]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AgentService_StreamLogsServer ¶
type AgentService_StreamLogsServer = grpc.ServerStreamingServer[LogEntry]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type CPBuildType ¶
type CPBuildType int32
const ( CPBuildType_CP_BUILD_TYPE_UNKNOWN CPBuildType = 0 CPBuildType_CP_BUILD_TYPE_OCI CPBuildType = 1 CPBuildType_CP_BUILD_TYPE_NIX CPBuildType = 2 )
func (CPBuildType) Descriptor ¶
func (CPBuildType) Descriptor() protoreflect.EnumDescriptor
func (CPBuildType) Enum ¶
func (x CPBuildType) Enum() *CPBuildType
func (CPBuildType) EnumDescriptor
deprecated
func (CPBuildType) EnumDescriptor() ([]byte, []int)
Deprecated: Use CPBuildType.Descriptor instead.
func (CPBuildType) Number ¶
func (x CPBuildType) Number() protoreflect.EnumNumber
func (CPBuildType) String ¶
func (x CPBuildType) String() string
func (CPBuildType) Type ¶
func (CPBuildType) Type() protoreflect.EnumType
type CPDeployRequest ¶
type CPDeployRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
AppId string `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
ServiceName string `protobuf:"bytes,3,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
Artifact string `protobuf:"bytes,4,opt,name=artifact,proto3" json:"artifact,omitempty"`
BuildType CPBuildType `protobuf:"varint,5,opt,name=build_type,json=buildType,proto3,enum=controlplane.CPBuildType" json:"build_type,omitempty"`
Config *CPDeploymentConfig `protobuf:"bytes,6,opt,name=config,proto3" json:"config,omitempty"`
// Version number for this deployment (used for container naming)
// Format: {app_name}-{service_name}-v{version}
// **Validates: Requirements 9.3, 9.4, 9.5**
Version int32 `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
// App name for container naming (optional, uses app_id if not provided)
AppName string `protobuf:"bytes,8,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
// contains filtered or unexported fields
}
func (*CPDeployRequest) Descriptor
deprecated
func (*CPDeployRequest) Descriptor() ([]byte, []int)
Deprecated: Use CPDeployRequest.ProtoReflect.Descriptor instead.
func (*CPDeployRequest) GetAppId ¶
func (x *CPDeployRequest) GetAppId() string
func (*CPDeployRequest) GetAppName ¶
func (x *CPDeployRequest) GetAppName() string
func (*CPDeployRequest) GetArtifact ¶
func (x *CPDeployRequest) GetArtifact() string
func (*CPDeployRequest) GetBuildType ¶
func (x *CPDeployRequest) GetBuildType() CPBuildType
func (*CPDeployRequest) GetConfig ¶
func (x *CPDeployRequest) GetConfig() *CPDeploymentConfig
func (*CPDeployRequest) GetDeploymentId ¶
func (x *CPDeployRequest) GetDeploymentId() string
func (*CPDeployRequest) GetServiceName ¶
func (x *CPDeployRequest) GetServiceName() string
func (*CPDeployRequest) GetVersion ¶
func (x *CPDeployRequest) GetVersion() int32
func (*CPDeployRequest) ProtoMessage ¶
func (*CPDeployRequest) ProtoMessage()
func (*CPDeployRequest) ProtoReflect ¶
func (x *CPDeployRequest) ProtoReflect() protoreflect.Message
func (*CPDeployRequest) Reset ¶
func (x *CPDeployRequest) Reset()
func (*CPDeployRequest) String ¶
func (x *CPDeployRequest) String() string
type CPDeploymentConfig ¶
type CPDeploymentConfig struct {
Resources *CPResourceSpec `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"`
Replicas int32 `protobuf:"varint,2,opt,name=replicas,proto3" json:"replicas,omitempty"`
EnvVars map[string]string `` /* 156-byte string literal not displayed */
DependsOn []string `protobuf:"bytes,4,rep,name=depends_on,json=dependsOn,proto3" json:"depends_on,omitempty"`
HealthCheck *CPHealthCheckConfig `protobuf:"bytes,5,opt,name=health_check,json=healthCheck,proto3" json:"health_check,omitempty"`
Port int32 `protobuf:"varint,6,opt,name=port,proto3" json:"port,omitempty"`
// contains filtered or unexported fields
}
func (*CPDeploymentConfig) Descriptor
deprecated
func (*CPDeploymentConfig) Descriptor() ([]byte, []int)
Deprecated: Use CPDeploymentConfig.ProtoReflect.Descriptor instead.
func (*CPDeploymentConfig) GetDependsOn ¶
func (x *CPDeploymentConfig) GetDependsOn() []string
func (*CPDeploymentConfig) GetEnvVars ¶
func (x *CPDeploymentConfig) GetEnvVars() map[string]string
func (*CPDeploymentConfig) GetHealthCheck ¶
func (x *CPDeploymentConfig) GetHealthCheck() *CPHealthCheckConfig
func (*CPDeploymentConfig) GetPort ¶
func (x *CPDeploymentConfig) GetPort() int32
func (*CPDeploymentConfig) GetReplicas ¶
func (x *CPDeploymentConfig) GetReplicas() int32
func (*CPDeploymentConfig) GetResources ¶
func (x *CPDeploymentConfig) GetResources() *CPResourceSpec
func (*CPDeploymentConfig) ProtoMessage ¶
func (*CPDeploymentConfig) ProtoMessage()
func (*CPDeploymentConfig) ProtoReflect ¶
func (x *CPDeploymentConfig) ProtoReflect() protoreflect.Message
func (*CPDeploymentConfig) Reset ¶
func (x *CPDeploymentConfig) Reset()
func (*CPDeploymentConfig) String ¶
func (x *CPDeploymentConfig) String() string
type CPHealthCheckConfig ¶
type CPHealthCheckConfig struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
IntervalSeconds int32 `protobuf:"varint,3,opt,name=interval_seconds,json=intervalSeconds,proto3" json:"interval_seconds,omitempty"`
TimeoutSeconds int32 `protobuf:"varint,4,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
HealthyThreshold int32 `protobuf:"varint,5,opt,name=healthy_threshold,json=healthyThreshold,proto3" json:"healthy_threshold,omitempty"`
UnhealthyThreshold int32 `protobuf:"varint,6,opt,name=unhealthy_threshold,json=unhealthyThreshold,proto3" json:"unhealthy_threshold,omitempty"`
// contains filtered or unexported fields
}
func (*CPHealthCheckConfig) Descriptor
deprecated
func (*CPHealthCheckConfig) Descriptor() ([]byte, []int)
Deprecated: Use CPHealthCheckConfig.ProtoReflect.Descriptor instead.
func (*CPHealthCheckConfig) GetHealthyThreshold ¶
func (x *CPHealthCheckConfig) GetHealthyThreshold() int32
func (*CPHealthCheckConfig) GetIntervalSeconds ¶
func (x *CPHealthCheckConfig) GetIntervalSeconds() int32
func (*CPHealthCheckConfig) GetPath ¶
func (x *CPHealthCheckConfig) GetPath() string
func (*CPHealthCheckConfig) GetPort ¶
func (x *CPHealthCheckConfig) GetPort() int32
func (*CPHealthCheckConfig) GetTimeoutSeconds ¶
func (x *CPHealthCheckConfig) GetTimeoutSeconds() int32
func (*CPHealthCheckConfig) GetUnhealthyThreshold ¶
func (x *CPHealthCheckConfig) GetUnhealthyThreshold() int32
func (*CPHealthCheckConfig) ProtoMessage ¶
func (*CPHealthCheckConfig) ProtoMessage()
func (*CPHealthCheckConfig) ProtoReflect ¶
func (x *CPHealthCheckConfig) ProtoReflect() protoreflect.Message
func (*CPHealthCheckConfig) Reset ¶
func (x *CPHealthCheckConfig) Reset()
func (*CPHealthCheckConfig) String ¶
func (x *CPHealthCheckConfig) String() string
type CPLogEntry ¶
type CPLogEntry struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
ServiceName string `protobuf:"bytes,3,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
Level CPLogLevel `protobuf:"varint,5,opt,name=level,proto3,enum=controlplane.CPLogLevel" json:"level,omitempty"`
Message string `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
Metadata map[string]string `` /* 143-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*CPLogEntry) Descriptor
deprecated
func (*CPLogEntry) Descriptor() ([]byte, []int)
Deprecated: Use CPLogEntry.ProtoReflect.Descriptor instead.
func (*CPLogEntry) GetDeploymentId ¶
func (x *CPLogEntry) GetDeploymentId() string
func (*CPLogEntry) GetLevel ¶
func (x *CPLogEntry) GetLevel() CPLogLevel
func (*CPLogEntry) GetMessage ¶
func (x *CPLogEntry) GetMessage() string
func (*CPLogEntry) GetMetadata ¶
func (x *CPLogEntry) GetMetadata() map[string]string
func (*CPLogEntry) GetServiceName ¶
func (x *CPLogEntry) GetServiceName() string
func (*CPLogEntry) GetStreamId ¶
func (x *CPLogEntry) GetStreamId() string
func (*CPLogEntry) GetTimestamp ¶
func (x *CPLogEntry) GetTimestamp() *timestamppb.Timestamp
func (*CPLogEntry) ProtoMessage ¶
func (*CPLogEntry) ProtoMessage()
func (*CPLogEntry) ProtoReflect ¶
func (x *CPLogEntry) ProtoReflect() protoreflect.Message
func (*CPLogEntry) Reset ¶
func (x *CPLogEntry) Reset()
func (*CPLogEntry) String ¶
func (x *CPLogEntry) String() string
type CPLogLevel ¶
type CPLogLevel int32
const ( CPLogLevel_CP_LOG_UNKNOWN CPLogLevel = 0 CPLogLevel_CP_LOG_DEBUG CPLogLevel = 1 CPLogLevel_CP_LOG_INFO CPLogLevel = 2 CPLogLevel_CP_LOG_WARN CPLogLevel = 3 CPLogLevel_CP_LOG_ERROR CPLogLevel = 4 )
func (CPLogLevel) Descriptor ¶
func (CPLogLevel) Descriptor() protoreflect.EnumDescriptor
func (CPLogLevel) Enum ¶
func (x CPLogLevel) Enum() *CPLogLevel
func (CPLogLevel) EnumDescriptor
deprecated
func (CPLogLevel) EnumDescriptor() ([]byte, []int)
Deprecated: Use CPLogLevel.Descriptor instead.
func (CPLogLevel) Number ¶
func (x CPLogLevel) Number() protoreflect.EnumNumber
func (CPLogLevel) String ¶
func (x CPLogLevel) String() string
func (CPLogLevel) Type ¶
func (CPLogLevel) Type() protoreflect.EnumType
type CPLogStreamRequest ¶
type CPLogStreamRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
TailLines int32 `protobuf:"varint,3,opt,name=tail_lines,json=tailLines,proto3" json:"tail_lines,omitempty"`
Follow bool `protobuf:"varint,4,opt,name=follow,proto3" json:"follow,omitempty"`
ServiceFilter string `protobuf:"bytes,5,opt,name=service_filter,json=serviceFilter,proto3" json:"service_filter,omitempty"`
LevelFilter CPLogLevel `protobuf:"varint,6,opt,name=level_filter,json=levelFilter,proto3,enum=controlplane.CPLogLevel" json:"level_filter,omitempty"`
// contains filtered or unexported fields
}
func (*CPLogStreamRequest) Descriptor
deprecated
func (*CPLogStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use CPLogStreamRequest.ProtoReflect.Descriptor instead.
func (*CPLogStreamRequest) GetDeploymentId ¶
func (x *CPLogStreamRequest) GetDeploymentId() string
func (*CPLogStreamRequest) GetFollow ¶
func (x *CPLogStreamRequest) GetFollow() bool
func (*CPLogStreamRequest) GetLevelFilter ¶
func (x *CPLogStreamRequest) GetLevelFilter() CPLogLevel
func (*CPLogStreamRequest) GetServiceFilter ¶
func (x *CPLogStreamRequest) GetServiceFilter() string
func (*CPLogStreamRequest) GetStreamId ¶
func (x *CPLogStreamRequest) GetStreamId() string
func (*CPLogStreamRequest) GetTailLines ¶
func (x *CPLogStreamRequest) GetTailLines() int32
func (*CPLogStreamRequest) ProtoMessage ¶
func (*CPLogStreamRequest) ProtoMessage()
func (*CPLogStreamRequest) ProtoReflect ¶
func (x *CPLogStreamRequest) ProtoReflect() protoreflect.Message
func (*CPLogStreamRequest) Reset ¶
func (x *CPLogStreamRequest) Reset()
func (*CPLogStreamRequest) String ¶
func (x *CPLogStreamRequest) String() string
type CPResourceSpec ¶
type CPResourceSpec struct {
Cpu string `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"` // CPU allocation, e.g., "0.5", "1", "2"
Memory string `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"` // Memory allocation, e.g., "256Mi", "1Gi"
// contains filtered or unexported fields
}
CPResourceSpec defines CPU and memory resource allocation.
func (*CPResourceSpec) Descriptor
deprecated
func (*CPResourceSpec) Descriptor() ([]byte, []int)
Deprecated: Use CPResourceSpec.ProtoReflect.Descriptor instead.
func (*CPResourceSpec) GetCpu ¶
func (x *CPResourceSpec) GetCpu() string
func (*CPResourceSpec) GetMemory ¶
func (x *CPResourceSpec) GetMemory() string
func (*CPResourceSpec) ProtoMessage ¶
func (*CPResourceSpec) ProtoMessage()
func (*CPResourceSpec) ProtoReflect ¶
func (x *CPResourceSpec) ProtoReflect() protoreflect.Message
func (*CPResourceSpec) Reset ¶
func (x *CPResourceSpec) Reset()
func (*CPResourceSpec) String ¶
func (x *CPResourceSpec) String() string
type CPRestartRequest ¶
type CPRestartRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
// contains filtered or unexported fields
}
func (*CPRestartRequest) Descriptor
deprecated
func (*CPRestartRequest) Descriptor() ([]byte, []int)
Deprecated: Use CPRestartRequest.ProtoReflect.Descriptor instead.
func (*CPRestartRequest) GetDeploymentId ¶
func (x *CPRestartRequest) GetDeploymentId() string
func (*CPRestartRequest) ProtoMessage ¶
func (*CPRestartRequest) ProtoMessage()
func (*CPRestartRequest) ProtoReflect ¶
func (x *CPRestartRequest) ProtoReflect() protoreflect.Message
func (*CPRestartRequest) Reset ¶
func (x *CPRestartRequest) Reset()
func (*CPRestartRequest) String ¶
func (x *CPRestartRequest) String() string
type CPStopRequest ¶
type CPStopRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
TimeoutSeconds int32 `protobuf:"varint,3,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
// contains filtered or unexported fields
}
func (*CPStopRequest) Descriptor
deprecated
func (*CPStopRequest) Descriptor() ([]byte, []int)
Deprecated: Use CPStopRequest.ProtoReflect.Descriptor instead.
func (*CPStopRequest) GetDeploymentId ¶
func (x *CPStopRequest) GetDeploymentId() string
func (*CPStopRequest) GetForce ¶
func (x *CPStopRequest) GetForce() bool
func (*CPStopRequest) GetTimeoutSeconds ¶
func (x *CPStopRequest) GetTimeoutSeconds() int32
func (*CPStopRequest) ProtoMessage ¶
func (*CPStopRequest) ProtoMessage()
func (*CPStopRequest) ProtoReflect ¶
func (x *CPStopRequest) ProtoReflect() protoreflect.Message
func (*CPStopRequest) Reset ¶
func (x *CPStopRequest) Reset()
func (*CPStopRequest) String ¶
func (x *CPStopRequest) String() string
type CPUpdateConfigRequest ¶
type CPUpdateConfigRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
Config *CPDeploymentConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*CPUpdateConfigRequest) Descriptor
deprecated
func (*CPUpdateConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use CPUpdateConfigRequest.ProtoReflect.Descriptor instead.
func (*CPUpdateConfigRequest) GetConfig ¶
func (x *CPUpdateConfigRequest) GetConfig() *CPDeploymentConfig
func (*CPUpdateConfigRequest) GetDeploymentId ¶
func (x *CPUpdateConfigRequest) GetDeploymentId() string
func (*CPUpdateConfigRequest) ProtoMessage ¶
func (*CPUpdateConfigRequest) ProtoMessage()
func (*CPUpdateConfigRequest) ProtoReflect ¶
func (x *CPUpdateConfigRequest) ProtoReflect() protoreflect.Message
func (*CPUpdateConfigRequest) Reset ¶
func (x *CPUpdateConfigRequest) Reset()
func (*CPUpdateConfigRequest) String ¶
func (x *CPUpdateConfigRequest) String() string
type CommandType ¶
type CommandType int32
const ( CommandType_COMMAND_UNKNOWN CommandType = 0 CommandType_COMMAND_DEPLOY CommandType = 1 CommandType_COMMAND_STOP CommandType = 2 CommandType_COMMAND_RESTART CommandType = 3 CommandType_COMMAND_UPDATE_CONFIG CommandType = 4 CommandType_COMMAND_STREAM_LOGS CommandType = 5 )
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 ControlPlaneServiceClient ¶
type ControlPlaneServiceClient interface {
// Node registration (unary)
Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
// Heartbeat (unary, every 10s)
Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
// Watch for deployment commands (server streaming, persistent)
WatchCommands(ctx context.Context, in *WatchCommandsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DeploymentCommand], error)
// Report deployment status changes (unary)
ReportStatus(ctx context.Context, in *StatusReport, opts ...grpc.CallOption) (*StatusResponse, error)
// Stream logs to control plane (client streaming)
PushLogs(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[CPLogEntry, PushLogsResponse], error)
}
ControlPlaneServiceClient is the client API for ControlPlaneService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
ControlPlaneService - all RPCs initiated by node agents
func NewControlPlaneServiceClient ¶
func NewControlPlaneServiceClient(cc grpc.ClientConnInterface) ControlPlaneServiceClient
type ControlPlaneServiceServer ¶
type ControlPlaneServiceServer interface {
// Node registration (unary)
Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
// Heartbeat (unary, every 10s)
Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
// Watch for deployment commands (server streaming, persistent)
WatchCommands(*WatchCommandsRequest, grpc.ServerStreamingServer[DeploymentCommand]) error
// Report deployment status changes (unary)
ReportStatus(context.Context, *StatusReport) (*StatusResponse, error)
// Stream logs to control plane (client streaming)
PushLogs(grpc.ClientStreamingServer[CPLogEntry, PushLogsResponse]) error
// contains filtered or unexported methods
}
ControlPlaneServiceServer is the server API for ControlPlaneService service. All implementations must embed UnimplementedControlPlaneServiceServer for forward compatibility.
ControlPlaneService - all RPCs initiated by node agents
type ControlPlaneService_PushLogsClient ¶
type ControlPlaneService_PushLogsClient = grpc.ClientStreamingClient[CPLogEntry, PushLogsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ControlPlaneService_PushLogsServer ¶
type ControlPlaneService_PushLogsServer = grpc.ClientStreamingServer[CPLogEntry, PushLogsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ControlPlaneService_WatchCommandsClient ¶
type ControlPlaneService_WatchCommandsClient = grpc.ServerStreamingClient[DeploymentCommand]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ControlPlaneService_WatchCommandsServer ¶
type ControlPlaneService_WatchCommandsServer = grpc.ServerStreamingServer[DeploymentCommand]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DeployRequest ¶
type DeployRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
Artifact string `protobuf:"bytes,2,opt,name=artifact,proto3" json:"artifact,omitempty"`
BuildType string `protobuf:"bytes,3,opt,name=build_type,json=buildType,proto3" json:"build_type,omitempty"` // "oci" or "pure-nix"
Config *RuntimeConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
Secrets map[string]string `` /* 141-byte string literal not displayed */
// contains filtered or unexported fields
}
DeployRequest contains all information needed to deploy an artifact.
func (*DeployRequest) Descriptor
deprecated
func (*DeployRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeployRequest.ProtoReflect.Descriptor instead.
func (*DeployRequest) GetArtifact ¶
func (x *DeployRequest) GetArtifact() string
func (*DeployRequest) GetBuildType ¶
func (x *DeployRequest) GetBuildType() string
func (*DeployRequest) GetConfig ¶
func (x *DeployRequest) GetConfig() *RuntimeConfig
func (*DeployRequest) GetDeploymentId ¶
func (x *DeployRequest) GetDeploymentId() string
func (*DeployRequest) GetSecrets ¶
func (x *DeployRequest) GetSecrets() map[string]string
func (*DeployRequest) ProtoMessage ¶
func (*DeployRequest) ProtoMessage()
func (*DeployRequest) ProtoReflect ¶
func (x *DeployRequest) ProtoReflect() protoreflect.Message
func (*DeployRequest) Reset ¶
func (x *DeployRequest) Reset()
func (*DeployRequest) String ¶
func (x *DeployRequest) String() string
type DeployResponse ¶
type DeployResponse 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
}
DeployResponse is returned after a deploy request is processed.
func (*DeployResponse) Descriptor
deprecated
func (*DeployResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeployResponse.ProtoReflect.Descriptor instead.
func (*DeployResponse) GetMessage ¶
func (x *DeployResponse) GetMessage() string
func (*DeployResponse) GetSuccess ¶
func (x *DeployResponse) GetSuccess() bool
func (*DeployResponse) ProtoMessage ¶
func (*DeployResponse) ProtoMessage()
func (*DeployResponse) ProtoReflect ¶
func (x *DeployResponse) ProtoReflect() protoreflect.Message
func (*DeployResponse) Reset ¶
func (x *DeployResponse) Reset()
func (*DeployResponse) String ¶
func (x *DeployResponse) String() string
type DeploymentCommand ¶
type DeploymentCommand struct {
CommandId string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
Type CommandType `protobuf:"varint,2,opt,name=type,proto3,enum=controlplane.CommandType" json:"type,omitempty"`
Deadline *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
// Types that are valid to be assigned to Command:
//
// *DeploymentCommand_Deploy
// *DeploymentCommand_Stop
// *DeploymentCommand_Restart
// *DeploymentCommand_UpdateConfig
// *DeploymentCommand_StreamLogs
Command isDeploymentCommand_Command `protobuf_oneof:"command"`
// contains filtered or unexported fields
}
func (*DeploymentCommand) Descriptor
deprecated
func (*DeploymentCommand) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentCommand.ProtoReflect.Descriptor instead.
func (*DeploymentCommand) GetCommand ¶
func (x *DeploymentCommand) GetCommand() isDeploymentCommand_Command
func (*DeploymentCommand) GetCommandId ¶
func (x *DeploymentCommand) GetCommandId() string
func (*DeploymentCommand) GetDeadline ¶
func (x *DeploymentCommand) GetDeadline() *timestamppb.Timestamp
func (*DeploymentCommand) GetDeploy ¶
func (x *DeploymentCommand) GetDeploy() *CPDeployRequest
func (*DeploymentCommand) GetRestart ¶
func (x *DeploymentCommand) GetRestart() *CPRestartRequest
func (*DeploymentCommand) GetStop ¶
func (x *DeploymentCommand) GetStop() *CPStopRequest
func (*DeploymentCommand) GetStreamLogs ¶
func (x *DeploymentCommand) GetStreamLogs() *CPLogStreamRequest
func (*DeploymentCommand) GetType ¶
func (x *DeploymentCommand) GetType() CommandType
func (*DeploymentCommand) GetUpdateConfig ¶
func (x *DeploymentCommand) GetUpdateConfig() *CPUpdateConfigRequest
func (*DeploymentCommand) ProtoMessage ¶
func (*DeploymentCommand) ProtoMessage()
func (*DeploymentCommand) ProtoReflect ¶
func (x *DeploymentCommand) ProtoReflect() protoreflect.Message
func (*DeploymentCommand) Reset ¶
func (x *DeploymentCommand) Reset()
func (*DeploymentCommand) String ¶
func (x *DeploymentCommand) String() string
type DeploymentCommand_Deploy ¶
type DeploymentCommand_Deploy struct {
Deploy *CPDeployRequest `protobuf:"bytes,10,opt,name=deploy,proto3,oneof"`
}
type DeploymentCommand_Restart ¶
type DeploymentCommand_Restart struct {
Restart *CPRestartRequest `protobuf:"bytes,12,opt,name=restart,proto3,oneof"`
}
type DeploymentCommand_Stop ¶
type DeploymentCommand_Stop struct {
Stop *CPStopRequest `protobuf:"bytes,11,opt,name=stop,proto3,oneof"`
}
type DeploymentCommand_StreamLogs ¶
type DeploymentCommand_StreamLogs struct {
StreamLogs *CPLogStreamRequest `protobuf:"bytes,14,opt,name=stream_logs,json=streamLogs,proto3,oneof"`
}
type DeploymentCommand_UpdateConfig ¶
type DeploymentCommand_UpdateConfig struct {
UpdateConfig *CPUpdateConfigRequest `protobuf:"bytes,13,opt,name=update_config,json=updateConfig,proto3,oneof"`
}
type DeploymentStatus ¶
type DeploymentStatus int32
const ( DeploymentStatus_STATUS_UNKNOWN DeploymentStatus = 0 DeploymentStatus_STATUS_PENDING DeploymentStatus = 1 DeploymentStatus_STATUS_PULLING DeploymentStatus = 2 DeploymentStatus_STATUS_STARTING DeploymentStatus = 3 DeploymentStatus_STATUS_RUNNING DeploymentStatus = 4 DeploymentStatus_STATUS_STOPPING DeploymentStatus = 5 DeploymentStatus_STATUS_STOPPED DeploymentStatus = 6 DeploymentStatus_STATUS_FAILED DeploymentStatus = 7 )
func (DeploymentStatus) Descriptor ¶
func (DeploymentStatus) Descriptor() protoreflect.EnumDescriptor
func (DeploymentStatus) Enum ¶
func (x DeploymentStatus) Enum() *DeploymentStatus
func (DeploymentStatus) EnumDescriptor
deprecated
func (DeploymentStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use DeploymentStatus.Descriptor instead.
func (DeploymentStatus) Number ¶
func (x DeploymentStatus) Number() protoreflect.EnumNumber
func (DeploymentStatus) String ¶
func (x DeploymentStatus) String() string
func (DeploymentStatus) Type ¶
func (DeploymentStatus) Type() protoreflect.EnumType
type DiskStats ¶
type DiskStats struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
Used int64 `protobuf:"varint,3,opt,name=used,proto3" json:"used,omitempty"`
Available int64 `protobuf:"varint,4,opt,name=available,proto3" json:"available,omitempty"`
UsagePercent float64 `protobuf:"fixed64,5,opt,name=usage_percent,json=usagePercent,proto3" json:"usage_percent,omitempty"`
// contains filtered or unexported fields
}
DiskStats represents disk usage statistics for a specific path. **Validates: Requirements 20.1**
func (*DiskStats) Descriptor
deprecated
func (*DiskStats) GetAvailable ¶
func (*DiskStats) GetUsagePercent ¶
func (*DiskStats) ProtoMessage ¶
func (*DiskStats) ProtoMessage()
func (*DiskStats) ProtoReflect ¶
func (x *DiskStats) ProtoReflect() protoreflect.Message
type GetStatusRequest ¶
type GetStatusRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
// contains filtered or unexported fields
}
GetStatusRequest contains the deployment to query.
func (*GetStatusRequest) Descriptor
deprecated
func (*GetStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.
func (*GetStatusRequest) GetDeploymentId ¶
func (x *GetStatusRequest) GetDeploymentId() string
func (*GetStatusRequest) ProtoMessage ¶
func (*GetStatusRequest) ProtoMessage()
func (*GetStatusRequest) ProtoReflect ¶
func (x *GetStatusRequest) ProtoReflect() protoreflect.Message
func (*GetStatusRequest) Reset ¶
func (x *GetStatusRequest) Reset()
func (*GetStatusRequest) String ¶
func (x *GetStatusRequest) String() string
type GetStatusResponse ¶
type GetStatusResponse struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // pending, starting, running, stopping, stopped, failed
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
StartedAt int64 `protobuf:"varint,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` // Unix timestamp, 0 if not started
UpdatedAt int64 `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"` // Unix timestamp
// contains filtered or unexported fields
}
GetStatusResponse contains the current deployment status.
func (*GetStatusResponse) Descriptor
deprecated
func (*GetStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.
func (*GetStatusResponse) GetDeploymentId ¶
func (x *GetStatusResponse) GetDeploymentId() string
func (*GetStatusResponse) GetMessage ¶
func (x *GetStatusResponse) GetMessage() string
func (*GetStatusResponse) GetStartedAt ¶
func (x *GetStatusResponse) GetStartedAt() int64
func (*GetStatusResponse) GetStatus ¶
func (x *GetStatusResponse) GetStatus() string
func (*GetStatusResponse) GetUpdatedAt ¶
func (x *GetStatusResponse) GetUpdatedAt() int64
func (*GetStatusResponse) ProtoMessage ¶
func (*GetStatusResponse) ProtoMessage()
func (*GetStatusResponse) ProtoReflect ¶
func (x *GetStatusResponse) ProtoReflect() protoreflect.Message
func (*GetStatusResponse) Reset ¶
func (x *GetStatusResponse) Reset()
func (*GetStatusResponse) String ¶
func (x *GetStatusResponse) String() string
type HealthCheckConfig ¶
type HealthCheckConfig struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
IntervalSeconds int32 `protobuf:"varint,3,opt,name=interval_seconds,json=intervalSeconds,proto3" json:"interval_seconds,omitempty"`
TimeoutSeconds int32 `protobuf:"varint,4,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
Retries int32 `protobuf:"varint,5,opt,name=retries,proto3" json:"retries,omitempty"`
// contains filtered or unexported fields
}
HealthCheckConfig defines health check settings for a service.
func (*HealthCheckConfig) Descriptor
deprecated
func (*HealthCheckConfig) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckConfig.ProtoReflect.Descriptor instead.
func (*HealthCheckConfig) GetIntervalSeconds ¶
func (x *HealthCheckConfig) GetIntervalSeconds() int32
func (*HealthCheckConfig) GetPath ¶
func (x *HealthCheckConfig) GetPath() string
func (*HealthCheckConfig) GetPort ¶
func (x *HealthCheckConfig) GetPort() int32
func (*HealthCheckConfig) GetRetries ¶
func (x *HealthCheckConfig) GetRetries() int32
func (*HealthCheckConfig) GetTimeoutSeconds ¶
func (x *HealthCheckConfig) GetTimeoutSeconds() int32
func (*HealthCheckConfig) ProtoMessage ¶
func (*HealthCheckConfig) ProtoMessage()
func (*HealthCheckConfig) ProtoReflect ¶
func (x *HealthCheckConfig) ProtoReflect() protoreflect.Message
func (*HealthCheckConfig) Reset ¶
func (x *HealthCheckConfig) Reset()
func (*HealthCheckConfig) String ¶
func (x *HealthCheckConfig) String() string
type HealthCheckRequest ¶
type HealthCheckRequest struct {
Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
// contains filtered or unexported fields
}
func (*HealthCheckRequest) Descriptor
deprecated
func (*HealthCheckRequest) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.
func (*HealthCheckRequest) GetService ¶
func (x *HealthCheckRequest) GetService() string
func (*HealthCheckRequest) ProtoMessage ¶
func (*HealthCheckRequest) ProtoMessage()
func (*HealthCheckRequest) ProtoReflect ¶
func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
func (*HealthCheckRequest) Reset ¶
func (x *HealthCheckRequest) Reset()
func (*HealthCheckRequest) String ¶
func (x *HealthCheckRequest) String() string
type HealthCheckResponse ¶
type HealthCheckResponse struct {
Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=controlplane.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
// contains filtered or unexported fields
}
func (*HealthCheckResponse) Descriptor
deprecated
func (*HealthCheckResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.
func (*HealthCheckResponse) GetStatus ¶
func (x *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus
func (*HealthCheckResponse) ProtoMessage ¶
func (*HealthCheckResponse) ProtoMessage()
func (*HealthCheckResponse) ProtoReflect ¶
func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message
func (*HealthCheckResponse) Reset ¶
func (x *HealthCheckResponse) Reset()
func (*HealthCheckResponse) String ¶
func (x *HealthCheckResponse) String() string
type HealthCheckResponse_ServingStatus ¶
type HealthCheckResponse_ServingStatus int32
const ( HealthCheckResponse_UNKNOWN HealthCheckResponse_ServingStatus = 0 HealthCheckResponse_SERVING HealthCheckResponse_ServingStatus = 1 HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2 )
func (HealthCheckResponse_ServingStatus) Descriptor ¶
func (HealthCheckResponse_ServingStatus) Descriptor() protoreflect.EnumDescriptor
func (HealthCheckResponse_ServingStatus) Enum ¶
func (x HealthCheckResponse_ServingStatus) Enum() *HealthCheckResponse_ServingStatus
func (HealthCheckResponse_ServingStatus) EnumDescriptor
deprecated
func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use HealthCheckResponse_ServingStatus.Descriptor instead.
func (HealthCheckResponse_ServingStatus) Number ¶
func (x HealthCheckResponse_ServingStatus) Number() protoreflect.EnumNumber
func (HealthCheckResponse_ServingStatus) String ¶
func (x HealthCheckResponse_ServingStatus) String() string
func (HealthCheckResponse_ServingStatus) Type ¶
func (HealthCheckResponse_ServingStatus) Type() protoreflect.EnumType
type HealthClient ¶
type HealthClient interface {
Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
Watch(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[HealthCheckResponse], error)
}
HealthClient is the client API for Health service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
Health checking (standard gRPC health protocol)
func NewHealthClient ¶
func NewHealthClient(cc grpc.ClientConnInterface) HealthClient
type HealthServer ¶
type HealthServer interface {
Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
Watch(*HealthCheckRequest, grpc.ServerStreamingServer[HealthCheckResponse]) error
// contains filtered or unexported methods
}
HealthServer is the server API for Health service. All implementations must embed UnimplementedHealthServer for forward compatibility.
Health checking (standard gRPC health protocol)
type Health_WatchClient ¶
type Health_WatchClient = grpc.ServerStreamingClient[HealthCheckResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Health_WatchServer ¶
type Health_WatchServer = grpc.ServerStreamingServer[HealthCheckResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type HeartbeatRequest ¶
type HeartbeatRequest struct {
NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
NodeInfo *NodeInfo `protobuf:"bytes,2,opt,name=node_info,json=nodeInfo,proto3" json:"node_info,omitempty"`
Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// draining indicates the node is shutting down and should not receive new deployments
Draining bool `protobuf:"varint,4,opt,name=draining,proto3" json:"draining,omitempty"`
// contains filtered or unexported fields
}
func (*HeartbeatRequest) Descriptor
deprecated
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.
func (*HeartbeatRequest) GetDraining ¶
func (x *HeartbeatRequest) GetDraining() bool
func (*HeartbeatRequest) GetNodeId ¶
func (x *HeartbeatRequest) GetNodeId() string
func (*HeartbeatRequest) GetNodeInfo ¶
func (x *HeartbeatRequest) GetNodeInfo() *NodeInfo
func (*HeartbeatRequest) GetTimestamp ¶
func (x *HeartbeatRequest) GetTimestamp() *timestamppb.Timestamp
func (*HeartbeatRequest) ProtoMessage ¶
func (*HeartbeatRequest) ProtoMessage()
func (*HeartbeatRequest) ProtoReflect ¶
func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
func (*HeartbeatRequest) Reset ¶
func (x *HeartbeatRequest) Reset()
func (*HeartbeatRequest) String ¶
func (x *HeartbeatRequest) String() string
type HeartbeatResponse ¶
type HeartbeatResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
// contains filtered or unexported fields
}
func (*HeartbeatResponse) Descriptor
deprecated
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.
func (*HeartbeatResponse) GetSuccess ¶
func (x *HeartbeatResponse) GetSuccess() bool
func (*HeartbeatResponse) ProtoMessage ¶
func (*HeartbeatResponse) ProtoMessage()
func (*HeartbeatResponse) ProtoReflect ¶
func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message
func (*HeartbeatResponse) Reset ¶
func (x *HeartbeatResponse) Reset()
func (*HeartbeatResponse) String ¶
func (x *HeartbeatResponse) String() string
type LogEntry ¶
type LogEntry struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // "build" or "runtime"
Level string `protobuf:"bytes,3,opt,name=level,proto3" json:"level,omitempty"` // "info", "warn", "error"
Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
Timestamp int64 `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Unix timestamp in nanoseconds
// contains filtered or unexported fields
}
LogEntry represents a single log line.
func (*LogEntry) Descriptor
deprecated
func (*LogEntry) GetDeploymentId ¶
func (*LogEntry) GetMessage ¶
func (*LogEntry) GetTimestamp ¶
func (*LogEntry) ProtoMessage ¶
func (*LogEntry) ProtoMessage()
func (*LogEntry) ProtoReflect ¶
func (x *LogEntry) ProtoReflect() protoreflect.Message
type NodeConfig ¶
type NodeConfig struct {
HeartbeatIntervalSeconds int32 `` /* 136-byte string literal not displayed */
MaxConcurrentDeployments int32 `` /* 136-byte string literal not displayed */
LogBufferSize int32 `protobuf:"varint,3,opt,name=log_buffer_size,json=logBufferSize,proto3" json:"log_buffer_size,omitempty"`
// contains filtered or unexported fields
}
func (*NodeConfig) Descriptor
deprecated
func (*NodeConfig) Descriptor() ([]byte, []int)
Deprecated: Use NodeConfig.ProtoReflect.Descriptor instead.
func (*NodeConfig) GetHeartbeatIntervalSeconds ¶
func (x *NodeConfig) GetHeartbeatIntervalSeconds() int32
func (*NodeConfig) GetLogBufferSize ¶
func (x *NodeConfig) GetLogBufferSize() int32
func (*NodeConfig) GetMaxConcurrentDeployments ¶
func (x *NodeConfig) GetMaxConcurrentDeployments() int32
func (*NodeConfig) ProtoMessage ¶
func (*NodeConfig) ProtoMessage()
func (*NodeConfig) ProtoReflect ¶
func (x *NodeConfig) ProtoReflect() protoreflect.Message
func (*NodeConfig) Reset ¶
func (x *NodeConfig) Reset()
func (*NodeConfig) String ¶
func (x *NodeConfig) String() string
type NodeDiskMetrics ¶
type NodeDiskMetrics struct {
NixStore *DiskStats `protobuf:"bytes,1,opt,name=nix_store,json=nixStore,proto3" json:"nix_store,omitempty"`
ContainerStorage *DiskStats `protobuf:"bytes,2,opt,name=container_storage,json=containerStorage,proto3" json:"container_storage,omitempty"`
// contains filtered or unexported fields
}
NodeDiskMetrics contains disk usage metrics for specific paths on a node. **Validates: Requirements 20.1**
func (*NodeDiskMetrics) Descriptor
deprecated
func (*NodeDiskMetrics) Descriptor() ([]byte, []int)
Deprecated: Use NodeDiskMetrics.ProtoReflect.Descriptor instead.
func (*NodeDiskMetrics) GetContainerStorage ¶
func (x *NodeDiskMetrics) GetContainerStorage() *DiskStats
func (*NodeDiskMetrics) GetNixStore ¶
func (x *NodeDiskMetrics) GetNixStore() *DiskStats
func (*NodeDiskMetrics) ProtoMessage ¶
func (*NodeDiskMetrics) ProtoMessage()
func (*NodeDiskMetrics) ProtoReflect ¶
func (x *NodeDiskMetrics) ProtoReflect() protoreflect.Message
func (*NodeDiskMetrics) Reset ¶
func (x *NodeDiskMetrics) Reset()
func (*NodeDiskMetrics) String ¶
func (x *NodeDiskMetrics) String() string
type NodeInfo ¶
type NodeInfo struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
GrpcPort int32 `protobuf:"varint,4,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"`
Resources *ResourceMetrics `protobuf:"bytes,5,opt,name=resources,proto3" json:"resources,omitempty"`
CachedPaths []string `protobuf:"bytes,6,rep,name=cached_paths,json=cachedPaths,proto3" json:"cached_paths,omitempty"`
AvailableSlots int32 `protobuf:"varint,7,opt,name=available_slots,json=availableSlots,proto3" json:"available_slots,omitempty"`
ActiveDeployments int32 `protobuf:"varint,8,opt,name=active_deployments,json=activeDeployments,proto3" json:"active_deployments,omitempty"`
// Disk metrics for specific paths (nix store, container storage)
// **Validates: Requirements 20.1**
DiskMetrics *NodeDiskMetrics `protobuf:"bytes,9,opt,name=disk_metrics,json=diskMetrics,proto3" json:"disk_metrics,omitempty"`
// contains filtered or unexported fields
}
func (*NodeInfo) Descriptor
deprecated
func (*NodeInfo) GetActiveDeployments ¶
func (*NodeInfo) GetAddress ¶
func (*NodeInfo) GetAvailableSlots ¶
func (*NodeInfo) GetCachedPaths ¶
func (*NodeInfo) GetDiskMetrics ¶
func (x *NodeInfo) GetDiskMetrics() *NodeDiskMetrics
func (*NodeInfo) GetGrpcPort ¶
func (*NodeInfo) GetHostname ¶
func (*NodeInfo) GetResources ¶
func (x *NodeInfo) GetResources() *ResourceMetrics
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) ProtoReflect ¶
func (x *NodeInfo) ProtoReflect() protoreflect.Message
type PortMapping ¶
type PortMapping struct {
ContainerPort int32 `protobuf:"varint,1,opt,name=container_port,json=containerPort,proto3" json:"container_port,omitempty"`
Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"` // tcp or udp, defaults to tcp
// contains filtered or unexported fields
}
PortMapping defines a port mapping for a service.
func (*PortMapping) Descriptor
deprecated
func (*PortMapping) Descriptor() ([]byte, []int)
Deprecated: Use PortMapping.ProtoReflect.Descriptor instead.
func (*PortMapping) GetContainerPort ¶
func (x *PortMapping) GetContainerPort() int32
func (*PortMapping) GetProtocol ¶
func (x *PortMapping) GetProtocol() string
func (*PortMapping) ProtoMessage ¶
func (*PortMapping) ProtoMessage()
func (*PortMapping) ProtoReflect ¶
func (x *PortMapping) ProtoReflect() protoreflect.Message
func (*PortMapping) Reset ¶
func (x *PortMapping) Reset()
func (*PortMapping) String ¶
func (x *PortMapping) String() string
type PushLogsResponse ¶
type PushLogsResponse struct {
EntriesReceived int64 `protobuf:"varint,1,opt,name=entries_received,json=entriesReceived,proto3" json:"entries_received,omitempty"`
// contains filtered or unexported fields
}
func (*PushLogsResponse) Descriptor
deprecated
func (*PushLogsResponse) Descriptor() ([]byte, []int)
Deprecated: Use PushLogsResponse.ProtoReflect.Descriptor instead.
func (*PushLogsResponse) GetEntriesReceived ¶
func (x *PushLogsResponse) GetEntriesReceived() int64
func (*PushLogsResponse) ProtoMessage ¶
func (*PushLogsResponse) ProtoMessage()
func (*PushLogsResponse) ProtoReflect ¶
func (x *PushLogsResponse) ProtoReflect() protoreflect.Message
func (*PushLogsResponse) Reset ¶
func (x *PushLogsResponse) Reset()
func (*PushLogsResponse) String ¶
func (x *PushLogsResponse) String() string
type RegisterRequest ¶
type RegisterRequest struct {
NodeInfo *NodeInfo `protobuf:"bytes,1,opt,name=node_info,json=nodeInfo,proto3" json:"node_info,omitempty"`
AuthToken string `protobuf:"bytes,2,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterRequest) Descriptor
deprecated
func (*RegisterRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.
func (*RegisterRequest) GetAuthToken ¶
func (x *RegisterRequest) GetAuthToken() string
func (*RegisterRequest) GetNodeInfo ¶
func (x *RegisterRequest) GetNodeInfo() *NodeInfo
func (*RegisterRequest) ProtoMessage ¶
func (*RegisterRequest) ProtoMessage()
func (*RegisterRequest) ProtoReflect ¶
func (x *RegisterRequest) ProtoReflect() protoreflect.Message
func (*RegisterRequest) Reset ¶
func (x *RegisterRequest) Reset()
func (*RegisterRequest) String ¶
func (x *RegisterRequest) String() string
type RegisterResponse ¶
type RegisterResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
NodeId string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
Config *NodeConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterResponse) Descriptor
deprecated
func (*RegisterResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.
func (*RegisterResponse) GetConfig ¶
func (x *RegisterResponse) GetConfig() *NodeConfig
func (*RegisterResponse) GetMessage ¶
func (x *RegisterResponse) GetMessage() string
func (*RegisterResponse) GetNodeId ¶
func (x *RegisterResponse) GetNodeId() string
func (*RegisterResponse) GetSuccess ¶
func (x *RegisterResponse) GetSuccess() bool
func (*RegisterResponse) ProtoMessage ¶
func (*RegisterResponse) ProtoMessage()
func (*RegisterResponse) ProtoReflect ¶
func (x *RegisterResponse) ProtoReflect() protoreflect.Message
func (*RegisterResponse) Reset ¶
func (x *RegisterResponse) Reset()
func (*RegisterResponse) String ¶
func (x *RegisterResponse) String() string
type ResourceMetrics ¶
type ResourceMetrics struct {
CpuTotal float64 `protobuf:"fixed64,1,opt,name=cpu_total,json=cpuTotal,proto3" json:"cpu_total,omitempty"`
CpuAvailable float64 `protobuf:"fixed64,2,opt,name=cpu_available,json=cpuAvailable,proto3" json:"cpu_available,omitempty"`
MemoryTotal int64 `protobuf:"varint,3,opt,name=memory_total,json=memoryTotal,proto3" json:"memory_total,omitempty"`
MemoryAvailable int64 `protobuf:"varint,4,opt,name=memory_available,json=memoryAvailable,proto3" json:"memory_available,omitempty"`
DiskTotal int64 `protobuf:"varint,5,opt,name=disk_total,json=diskTotal,proto3" json:"disk_total,omitempty"`
DiskAvailable int64 `protobuf:"varint,6,opt,name=disk_available,json=diskAvailable,proto3" json:"disk_available,omitempty"`
// contains filtered or unexported fields
}
func (*ResourceMetrics) Descriptor
deprecated
func (*ResourceMetrics) Descriptor() ([]byte, []int)
Deprecated: Use ResourceMetrics.ProtoReflect.Descriptor instead.
func (*ResourceMetrics) GetCpuAvailable ¶
func (x *ResourceMetrics) GetCpuAvailable() float64
func (*ResourceMetrics) GetCpuTotal ¶
func (x *ResourceMetrics) GetCpuTotal() float64
func (*ResourceMetrics) GetDiskAvailable ¶
func (x *ResourceMetrics) GetDiskAvailable() int64
func (*ResourceMetrics) GetDiskTotal ¶
func (x *ResourceMetrics) GetDiskTotal() int64
func (*ResourceMetrics) GetMemoryAvailable ¶
func (x *ResourceMetrics) GetMemoryAvailable() int64
func (*ResourceMetrics) GetMemoryTotal ¶
func (x *ResourceMetrics) GetMemoryTotal() int64
func (*ResourceMetrics) ProtoMessage ¶
func (*ResourceMetrics) ProtoMessage()
func (*ResourceMetrics) ProtoReflect ¶
func (x *ResourceMetrics) ProtoReflect() protoreflect.Message
func (*ResourceMetrics) Reset ¶
func (x *ResourceMetrics) Reset()
func (*ResourceMetrics) String ¶
func (x *ResourceMetrics) String() string
type ResourceSpec ¶
type ResourceSpec struct {
Cpu string `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"` // CPU allocation, e.g., "0.5", "1", "2"
Memory string `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"` // Memory allocation, e.g., "256Mi", "1Gi"
// contains filtered or unexported fields
}
ResourceSpec defines CPU and memory resource allocation.
func (*ResourceSpec) Descriptor
deprecated
func (*ResourceSpec) Descriptor() ([]byte, []int)
Deprecated: Use ResourceSpec.ProtoReflect.Descriptor instead.
func (*ResourceSpec) GetCpu ¶
func (x *ResourceSpec) GetCpu() string
func (*ResourceSpec) GetMemory ¶
func (x *ResourceSpec) GetMemory() string
func (*ResourceSpec) ProtoMessage ¶
func (*ResourceSpec) ProtoMessage()
func (*ResourceSpec) ProtoReflect ¶
func (x *ResourceSpec) ProtoReflect() protoreflect.Message
func (*ResourceSpec) Reset ¶
func (x *ResourceSpec) Reset()
func (*ResourceSpec) String ¶
func (x *ResourceSpec) String() string
type ResourceUsage ¶
type ResourceUsage struct {
CpuPercent float64 `protobuf:"fixed64,1,opt,name=cpu_percent,json=cpuPercent,proto3" json:"cpu_percent,omitempty"`
MemoryBytes int64 `protobuf:"varint,2,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
NetworkRxBytes int64 `protobuf:"varint,3,opt,name=network_rx_bytes,json=networkRxBytes,proto3" json:"network_rx_bytes,omitempty"`
NetworkTxBytes int64 `protobuf:"varint,4,opt,name=network_tx_bytes,json=networkTxBytes,proto3" json:"network_tx_bytes,omitempty"`
// contains filtered or unexported fields
}
func (*ResourceUsage) Descriptor
deprecated
func (*ResourceUsage) Descriptor() ([]byte, []int)
Deprecated: Use ResourceUsage.ProtoReflect.Descriptor instead.
func (*ResourceUsage) GetCpuPercent ¶
func (x *ResourceUsage) GetCpuPercent() float64
func (*ResourceUsage) GetMemoryBytes ¶
func (x *ResourceUsage) GetMemoryBytes() int64
func (*ResourceUsage) GetNetworkRxBytes ¶
func (x *ResourceUsage) GetNetworkRxBytes() int64
func (*ResourceUsage) GetNetworkTxBytes ¶
func (x *ResourceUsage) GetNetworkTxBytes() int64
func (*ResourceUsage) ProtoMessage ¶
func (*ResourceUsage) ProtoMessage()
func (*ResourceUsage) ProtoReflect ¶
func (x *ResourceUsage) ProtoReflect() protoreflect.Message
func (*ResourceUsage) Reset ¶
func (x *ResourceUsage) Reset()
func (*ResourceUsage) String ¶
func (x *ResourceUsage) String() string
type RuntimeConfig ¶
type RuntimeConfig struct {
Resources *ResourceSpec `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"`
EnvVars map[string]string `` /* 156-byte string literal not displayed */
Ports []*PortMapping `protobuf:"bytes,3,rep,name=ports,proto3" json:"ports,omitempty"`
HealthCheck *HealthCheckConfig `protobuf:"bytes,4,opt,name=health_check,json=healthCheck,proto3" json:"health_check,omitempty"`
// contains filtered or unexported fields
}
RuntimeConfig holds runtime configuration for a deployment.
func (*RuntimeConfig) Descriptor
deprecated
func (*RuntimeConfig) Descriptor() ([]byte, []int)
Deprecated: Use RuntimeConfig.ProtoReflect.Descriptor instead.
func (*RuntimeConfig) GetEnvVars ¶
func (x *RuntimeConfig) GetEnvVars() map[string]string
func (*RuntimeConfig) GetHealthCheck ¶
func (x *RuntimeConfig) GetHealthCheck() *HealthCheckConfig
func (*RuntimeConfig) GetPorts ¶
func (x *RuntimeConfig) GetPorts() []*PortMapping
func (*RuntimeConfig) GetResources ¶
func (x *RuntimeConfig) GetResources() *ResourceSpec
func (*RuntimeConfig) ProtoMessage ¶
func (*RuntimeConfig) ProtoMessage()
func (*RuntimeConfig) ProtoReflect ¶
func (x *RuntimeConfig) ProtoReflect() protoreflect.Message
func (*RuntimeConfig) Reset ¶
func (x *RuntimeConfig) Reset()
func (*RuntimeConfig) String ¶
func (x *RuntimeConfig) String() string
type StatusReport ¶
type StatusReport struct {
NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
DeploymentId string `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
CommandId string `protobuf:"bytes,3,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
Status DeploymentStatus `protobuf:"varint,4,opt,name=status,proto3,enum=controlplane.DeploymentStatus" json:"status,omitempty"`
ContainerId string `protobuf:"bytes,5,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
StartedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
ExitCode int32 `protobuf:"varint,7,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
ErrorMessage string `protobuf:"bytes,8,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
ResourceUsage *ResourceUsage `protobuf:"bytes,9,opt,name=resource_usage,json=resourceUsage,proto3" json:"resource_usage,omitempty"`
// contains filtered or unexported fields
}
func (*StatusReport) Descriptor
deprecated
func (*StatusReport) Descriptor() ([]byte, []int)
Deprecated: Use StatusReport.ProtoReflect.Descriptor instead.
func (*StatusReport) GetCommandId ¶
func (x *StatusReport) GetCommandId() string
func (*StatusReport) GetContainerId ¶
func (x *StatusReport) GetContainerId() string
func (*StatusReport) GetDeploymentId ¶
func (x *StatusReport) GetDeploymentId() string
func (*StatusReport) GetErrorMessage ¶
func (x *StatusReport) GetErrorMessage() string
func (*StatusReport) GetExitCode ¶
func (x *StatusReport) GetExitCode() int32
func (*StatusReport) GetNodeId ¶
func (x *StatusReport) GetNodeId() string
func (*StatusReport) GetResourceUsage ¶
func (x *StatusReport) GetResourceUsage() *ResourceUsage
func (*StatusReport) GetStartedAt ¶
func (x *StatusReport) GetStartedAt() *timestamppb.Timestamp
func (*StatusReport) GetStatus ¶
func (x *StatusReport) GetStatus() DeploymentStatus
func (*StatusReport) ProtoMessage ¶
func (*StatusReport) ProtoMessage()
func (*StatusReport) ProtoReflect ¶
func (x *StatusReport) ProtoReflect() protoreflect.Message
func (*StatusReport) Reset ¶
func (x *StatusReport) Reset()
func (*StatusReport) String ¶
func (x *StatusReport) String() string
type StatusResponse ¶
type StatusResponse struct {
Acknowledged bool `protobuf:"varint,1,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`
// contains filtered or unexported fields
}
func (*StatusResponse) Descriptor
deprecated
func (*StatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.
func (*StatusResponse) GetAcknowledged ¶
func (x *StatusResponse) GetAcknowledged() bool
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) ProtoReflect ¶
func (x *StatusResponse) ProtoReflect() protoreflect.Message
func (*StatusResponse) Reset ¶
func (x *StatusResponse) Reset()
func (*StatusResponse) String ¶
func (x *StatusResponse) String() string
type StopRequest ¶
type StopRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
// contains filtered or unexported fields
}
StopRequest contains the deployment to stop.
func (*StopRequest) Descriptor
deprecated
func (*StopRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.
func (*StopRequest) GetDeploymentId ¶
func (x *StopRequest) GetDeploymentId() string
func (*StopRequest) ProtoMessage ¶
func (*StopRequest) ProtoMessage()
func (*StopRequest) ProtoReflect ¶
func (x *StopRequest) ProtoReflect() protoreflect.Message
func (*StopRequest) Reset ¶
func (x *StopRequest) Reset()
func (*StopRequest) String ¶
func (x *StopRequest) String() string
type StopResponse ¶
type StopResponse 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
}
StopResponse is returned after a stop request is processed.
func (*StopResponse) Descriptor
deprecated
func (*StopResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.
func (*StopResponse) GetMessage ¶
func (x *StopResponse) GetMessage() string
func (*StopResponse) GetSuccess ¶
func (x *StopResponse) GetSuccess() bool
func (*StopResponse) ProtoMessage ¶
func (*StopResponse) ProtoMessage()
func (*StopResponse) ProtoReflect ¶
func (x *StopResponse) ProtoReflect() protoreflect.Message
func (*StopResponse) Reset ¶
func (x *StopResponse) Reset()
func (*StopResponse) String ¶
func (x *StopResponse) String() string
type StreamLogsRequest ¶
type StreamLogsRequest struct {
DeploymentId string `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
Follow bool `protobuf:"varint,2,opt,name=follow,proto3" json:"follow,omitempty"` // If true, continue streaming new logs
TailLines int32 `protobuf:"varint,3,opt,name=tail_lines,json=tailLines,proto3" json:"tail_lines,omitempty"` // Number of recent lines to return initially (0 = all)
// contains filtered or unexported fields
}
StreamLogsRequest specifies which deployment's logs to stream.
func (*StreamLogsRequest) Descriptor
deprecated
func (*StreamLogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamLogsRequest.ProtoReflect.Descriptor instead.
func (*StreamLogsRequest) GetDeploymentId ¶
func (x *StreamLogsRequest) GetDeploymentId() string
func (*StreamLogsRequest) GetFollow ¶
func (x *StreamLogsRequest) GetFollow() bool
func (*StreamLogsRequest) GetTailLines ¶
func (x *StreamLogsRequest) GetTailLines() int32
func (*StreamLogsRequest) ProtoMessage ¶
func (*StreamLogsRequest) ProtoMessage()
func (*StreamLogsRequest) ProtoReflect ¶
func (x *StreamLogsRequest) ProtoReflect() protoreflect.Message
func (*StreamLogsRequest) Reset ¶
func (x *StreamLogsRequest) Reset()
func (*StreamLogsRequest) String ¶
func (x *StreamLogsRequest) String() string
type UnimplementedAgentServiceServer ¶
type UnimplementedAgentServiceServer struct{}
UnimplementedAgentServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAgentServiceServer) Deploy ¶
func (UnimplementedAgentServiceServer) Deploy(context.Context, *DeployRequest) (*DeployResponse, error)
func (UnimplementedAgentServiceServer) GetStatus ¶
func (UnimplementedAgentServiceServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
func (UnimplementedAgentServiceServer) Stop ¶
func (UnimplementedAgentServiceServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
func (UnimplementedAgentServiceServer) StreamLogs ¶
func (UnimplementedAgentServiceServer) StreamLogs(*StreamLogsRequest, grpc.ServerStreamingServer[LogEntry]) error
type UnimplementedControlPlaneServiceServer ¶
type UnimplementedControlPlaneServiceServer struct{}
UnimplementedControlPlaneServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedControlPlaneServiceServer) Heartbeat ¶
func (UnimplementedControlPlaneServiceServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
func (UnimplementedControlPlaneServiceServer) PushLogs ¶
func (UnimplementedControlPlaneServiceServer) PushLogs(grpc.ClientStreamingServer[CPLogEntry, PushLogsResponse]) error
func (UnimplementedControlPlaneServiceServer) Register ¶
func (UnimplementedControlPlaneServiceServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
func (UnimplementedControlPlaneServiceServer) ReportStatus ¶
func (UnimplementedControlPlaneServiceServer) ReportStatus(context.Context, *StatusReport) (*StatusResponse, error)
func (UnimplementedControlPlaneServiceServer) WatchCommands ¶
func (UnimplementedControlPlaneServiceServer) WatchCommands(*WatchCommandsRequest, grpc.ServerStreamingServer[DeploymentCommand]) error
type UnimplementedHealthServer ¶
type UnimplementedHealthServer struct{}
UnimplementedHealthServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedHealthServer) Check ¶
func (UnimplementedHealthServer) Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
type UnsafeAgentServiceServer ¶
type UnsafeAgentServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAgentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServiceServer will result in compilation errors.
type UnsafeControlPlaneServiceServer ¶
type UnsafeControlPlaneServiceServer interface {
// contains filtered or unexported methods
}
UnsafeControlPlaneServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlPlaneServiceServer will result in compilation errors.
type UnsafeHealthServer ¶
type UnsafeHealthServer interface {
// contains filtered or unexported methods
}
UnsafeHealthServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthServer will result in compilation errors.
type WatchCommandsRequest ¶
type WatchCommandsRequest struct {
NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
AuthToken string `protobuf:"bytes,2,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
// contains filtered or unexported fields
}
func (*WatchCommandsRequest) Descriptor
deprecated
func (*WatchCommandsRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchCommandsRequest.ProtoReflect.Descriptor instead.
func (*WatchCommandsRequest) GetAuthToken ¶
func (x *WatchCommandsRequest) GetAuthToken() string
func (*WatchCommandsRequest) GetNodeId ¶
func (x *WatchCommandsRequest) GetNodeId() string
func (*WatchCommandsRequest) ProtoMessage ¶
func (*WatchCommandsRequest) ProtoMessage()
func (*WatchCommandsRequest) ProtoReflect ¶
func (x *WatchCommandsRequest) ProtoReflect() protoreflect.Message
func (*WatchCommandsRequest) Reset ¶
func (x *WatchCommandsRequest) Reset()
func (*WatchCommandsRequest) String ¶
func (x *WatchCommandsRequest) String() string