proto

package
v0.0.10 Latest Latest
Warning

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

Go to latest
Published: Jan 25, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
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"
)
View Source
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"
)
View Source
const (
	Health_Check_FullMethodName = "/controlplane.Health/Check"
	Health_Watch_FullMethodName = "/controlplane.Health/Watch"
)

Variables

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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)

View Source
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)

View Source
var File_api_proto_agent_proto protoreflect.FileDescriptor
View Source
var File_api_proto_controlplane_proto protoreflect.FileDescriptor
View Source
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.

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) 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

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

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) 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

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

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) Enum

func (DeploymentStatus) EnumDescriptor deprecated

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

Deprecated: Use DeploymentStatus.Descriptor instead.

func (DeploymentStatus) Number

func (DeploymentStatus) String

func (x DeploymentStatus) String() string

func (DeploymentStatus) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use DiskStats.ProtoReflect.Descriptor instead.

func (*DiskStats) GetAvailable

func (x *DiskStats) GetAvailable() int64

func (*DiskStats) GetPath

func (x *DiskStats) GetPath() string

func (*DiskStats) GetTotal

func (x *DiskStats) GetTotal() int64

func (*DiskStats) GetUsagePercent

func (x *DiskStats) GetUsagePercent() float64

func (*DiskStats) GetUsed

func (x *DiskStats) GetUsed() int64

func (*DiskStats) ProtoMessage

func (*DiskStats) ProtoMessage()

func (*DiskStats) ProtoReflect

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

func (*DiskStats) Reset

func (x *DiskStats) Reset()

func (*DiskStats) String

func (x *DiskStats) String() string

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 (*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) Enum

func (HealthCheckResponse_ServingStatus) EnumDescriptor deprecated

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

Deprecated: Use HealthCheckResponse_ServingStatus.Descriptor instead.

func (HealthCheckResponse_ServingStatus) Number

func (HealthCheckResponse_ServingStatus) String

func (HealthCheckResponse_ServingStatus) Type

type HealthClient

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) Descriptor() ([]byte, []int)

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetDeploymentId

func (x *LogEntry) GetDeploymentId() string

func (*LogEntry) GetLevel

func (x *LogEntry) GetLevel() string

func (*LogEntry) GetMessage

func (x *LogEntry) GetMessage() string

func (*LogEntry) GetSource

func (x *LogEntry) GetSource() string

func (*LogEntry) GetTimestamp

func (x *LogEntry) GetTimestamp() int64

func (*LogEntry) ProtoMessage

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect

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

func (*LogEntry) Reset

func (x *LogEntry) Reset()

func (*LogEntry) String

func (x *LogEntry) String() string

type 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) Descriptor() ([]byte, []int)

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetActiveDeployments

func (x *NodeInfo) GetActiveDeployments() int32

func (*NodeInfo) GetAddress

func (x *NodeInfo) GetAddress() string

func (*NodeInfo) GetAvailableSlots

func (x *NodeInfo) GetAvailableSlots() int32

func (*NodeInfo) GetCachedPaths

func (x *NodeInfo) GetCachedPaths() []string

func (*NodeInfo) GetDiskMetrics

func (x *NodeInfo) GetDiskMetrics() *NodeDiskMetrics

func (*NodeInfo) GetGrpcPort

func (x *NodeInfo) GetGrpcPort() int32

func (*NodeInfo) GetHostname

func (x *NodeInfo) GetHostname() string

func (*NodeInfo) GetId

func (x *NodeInfo) GetId() string

func (*NodeInfo) GetResources

func (x *NodeInfo) GetResources() *ResourceMetrics

func (*NodeInfo) ProtoMessage

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect

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

func (*NodeInfo) Reset

func (x *NodeInfo) Reset()

func (*NodeInfo) String

func (x *NodeInfo) String() string

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) GetStatus

func (UnimplementedAgentServiceServer) Stop

func (UnimplementedAgentServiceServer) StreamLogs

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) PushLogs

func (UnimplementedControlPlaneServiceServer) Register

func (UnimplementedControlPlaneServiceServer) ReportStatus

func (UnimplementedControlPlaneServiceServer) WatchCommands

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL