proto

package
v1.6.0 Latest Latest
Warning

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

Go to latest
Published: Oct 15, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	WarrenAPI_RegisterNode_FullMethodName          = "/warren.v1.WarrenAPI/RegisterNode"
	WarrenAPI_Heartbeat_FullMethodName             = "/warren.v1.WarrenAPI/Heartbeat"
	WarrenAPI_ListNodes_FullMethodName             = "/warren.v1.WarrenAPI/ListNodes"
	WarrenAPI_GetNode_FullMethodName               = "/warren.v1.WarrenAPI/GetNode"
	WarrenAPI_RemoveNode_FullMethodName            = "/warren.v1.WarrenAPI/RemoveNode"
	WarrenAPI_CreateService_FullMethodName         = "/warren.v1.WarrenAPI/CreateService"
	WarrenAPI_UpdateService_FullMethodName         = "/warren.v1.WarrenAPI/UpdateService"
	WarrenAPI_UpdateServiceImage_FullMethodName    = "/warren.v1.WarrenAPI/UpdateServiceImage"
	WarrenAPI_RollbackService_FullMethodName       = "/warren.v1.WarrenAPI/RollbackService"
	WarrenAPI_DeleteService_FullMethodName         = "/warren.v1.WarrenAPI/DeleteService"
	WarrenAPI_GetService_FullMethodName            = "/warren.v1.WarrenAPI/GetService"
	WarrenAPI_ListServices_FullMethodName          = "/warren.v1.WarrenAPI/ListServices"
	WarrenAPI_UpdateContainerStatus_FullMethodName = "/warren.v1.WarrenAPI/UpdateContainerStatus"
	WarrenAPI_ListContainers_FullMethodName        = "/warren.v1.WarrenAPI/ListContainers"
	WarrenAPI_GetContainer_FullMethodName          = "/warren.v1.WarrenAPI/GetContainer"
	WarrenAPI_WatchContainers_FullMethodName       = "/warren.v1.WarrenAPI/WatchContainers"
	WarrenAPI_ReportContainerHealth_FullMethodName = "/warren.v1.WarrenAPI/ReportContainerHealth"
	WarrenAPI_CreateSecret_FullMethodName          = "/warren.v1.WarrenAPI/CreateSecret"
	WarrenAPI_GetSecretByName_FullMethodName       = "/warren.v1.WarrenAPI/GetSecretByName"
	WarrenAPI_DeleteSecret_FullMethodName          = "/warren.v1.WarrenAPI/DeleteSecret"
	WarrenAPI_ListSecrets_FullMethodName           = "/warren.v1.WarrenAPI/ListSecrets"
	WarrenAPI_CreateVolume_FullMethodName          = "/warren.v1.WarrenAPI/CreateVolume"
	WarrenAPI_GetVolumeByName_FullMethodName       = "/warren.v1.WarrenAPI/GetVolumeByName"
	WarrenAPI_DeleteVolume_FullMethodName          = "/warren.v1.WarrenAPI/DeleteVolume"
	WarrenAPI_ListVolumes_FullMethodName           = "/warren.v1.WarrenAPI/ListVolumes"
	WarrenAPI_GenerateJoinToken_FullMethodName     = "/warren.v1.WarrenAPI/GenerateJoinToken"
	WarrenAPI_JoinCluster_FullMethodName           = "/warren.v1.WarrenAPI/JoinCluster"
	WarrenAPI_GetClusterInfo_FullMethodName        = "/warren.v1.WarrenAPI/GetClusterInfo"
	WarrenAPI_RequestCertificate_FullMethodName    = "/warren.v1.WarrenAPI/RequestCertificate"
	WarrenAPI_CreateIngress_FullMethodName         = "/warren.v1.WarrenAPI/CreateIngress"
	WarrenAPI_UpdateIngress_FullMethodName         = "/warren.v1.WarrenAPI/UpdateIngress"
	WarrenAPI_DeleteIngress_FullMethodName         = "/warren.v1.WarrenAPI/DeleteIngress"
	WarrenAPI_GetIngress_FullMethodName            = "/warren.v1.WarrenAPI/GetIngress"
	WarrenAPI_ListIngresses_FullMethodName         = "/warren.v1.WarrenAPI/ListIngresses"
	WarrenAPI_CreateTLSCertificate_FullMethodName  = "/warren.v1.WarrenAPI/CreateTLSCertificate"
	WarrenAPI_GetTLSCertificate_FullMethodName     = "/warren.v1.WarrenAPI/GetTLSCertificate"
	WarrenAPI_ListTLSCertificates_FullMethodName   = "/warren.v1.WarrenAPI/ListTLSCertificates"
	WarrenAPI_DeleteTLSCertificate_FullMethodName  = "/warren.v1.WarrenAPI/DeleteTLSCertificate"
	WarrenAPI_StreamEvents_FullMethodName          = "/warren.v1.WarrenAPI/StreamEvents"
)

Variables

View Source
var (
	HealthCheck_Type_name = map[int32]string{
		0: "HTTP",
		1: "TCP",
		2: "EXEC",
	}
	HealthCheck_Type_value = map[string]int32{
		"HTTP": 0,
		"TCP":  1,
		"EXEC": 2,
	}
)

Enum value maps for HealthCheck_Type.

View Source
var (
	PortMapping_PublishMode_name = map[int32]string{
		0: "HOST",
		1: "INGRESS",
	}
	PortMapping_PublishMode_value = map[string]int32{
		"HOST":    0,
		"INGRESS": 1,
	}
)

Enum value maps for PortMapping_PublishMode.

View Source
var File_api_proto_warren_proto protoreflect.FileDescriptor
View Source
var WarrenAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "warren.v1.WarrenAPI",
	HandlerType: (*WarrenAPIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterNode",
			Handler:    _WarrenAPI_RegisterNode_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _WarrenAPI_Heartbeat_Handler,
		},
		{
			MethodName: "ListNodes",
			Handler:    _WarrenAPI_ListNodes_Handler,
		},
		{
			MethodName: "GetNode",
			Handler:    _WarrenAPI_GetNode_Handler,
		},
		{
			MethodName: "RemoveNode",
			Handler:    _WarrenAPI_RemoveNode_Handler,
		},
		{
			MethodName: "CreateService",
			Handler:    _WarrenAPI_CreateService_Handler,
		},
		{
			MethodName: "UpdateService",
			Handler:    _WarrenAPI_UpdateService_Handler,
		},
		{
			MethodName: "UpdateServiceImage",
			Handler:    _WarrenAPI_UpdateServiceImage_Handler,
		},
		{
			MethodName: "RollbackService",
			Handler:    _WarrenAPI_RollbackService_Handler,
		},
		{
			MethodName: "DeleteService",
			Handler:    _WarrenAPI_DeleteService_Handler,
		},
		{
			MethodName: "GetService",
			Handler:    _WarrenAPI_GetService_Handler,
		},
		{
			MethodName: "ListServices",
			Handler:    _WarrenAPI_ListServices_Handler,
		},
		{
			MethodName: "UpdateContainerStatus",
			Handler:    _WarrenAPI_UpdateContainerStatus_Handler,
		},
		{
			MethodName: "ListContainers",
			Handler:    _WarrenAPI_ListContainers_Handler,
		},
		{
			MethodName: "GetContainer",
			Handler:    _WarrenAPI_GetContainer_Handler,
		},
		{
			MethodName: "ReportContainerHealth",
			Handler:    _WarrenAPI_ReportContainerHealth_Handler,
		},
		{
			MethodName: "CreateSecret",
			Handler:    _WarrenAPI_CreateSecret_Handler,
		},
		{
			MethodName: "GetSecretByName",
			Handler:    _WarrenAPI_GetSecretByName_Handler,
		},
		{
			MethodName: "DeleteSecret",
			Handler:    _WarrenAPI_DeleteSecret_Handler,
		},
		{
			MethodName: "ListSecrets",
			Handler:    _WarrenAPI_ListSecrets_Handler,
		},
		{
			MethodName: "CreateVolume",
			Handler:    _WarrenAPI_CreateVolume_Handler,
		},
		{
			MethodName: "GetVolumeByName",
			Handler:    _WarrenAPI_GetVolumeByName_Handler,
		},
		{
			MethodName: "DeleteVolume",
			Handler:    _WarrenAPI_DeleteVolume_Handler,
		},
		{
			MethodName: "ListVolumes",
			Handler:    _WarrenAPI_ListVolumes_Handler,
		},
		{
			MethodName: "GenerateJoinToken",
			Handler:    _WarrenAPI_GenerateJoinToken_Handler,
		},
		{
			MethodName: "JoinCluster",
			Handler:    _WarrenAPI_JoinCluster_Handler,
		},
		{
			MethodName: "GetClusterInfo",
			Handler:    _WarrenAPI_GetClusterInfo_Handler,
		},
		{
			MethodName: "RequestCertificate",
			Handler:    _WarrenAPI_RequestCertificate_Handler,
		},
		{
			MethodName: "CreateIngress",
			Handler:    _WarrenAPI_CreateIngress_Handler,
		},
		{
			MethodName: "UpdateIngress",
			Handler:    _WarrenAPI_UpdateIngress_Handler,
		},
		{
			MethodName: "DeleteIngress",
			Handler:    _WarrenAPI_DeleteIngress_Handler,
		},
		{
			MethodName: "GetIngress",
			Handler:    _WarrenAPI_GetIngress_Handler,
		},
		{
			MethodName: "ListIngresses",
			Handler:    _WarrenAPI_ListIngresses_Handler,
		},
		{
			MethodName: "CreateTLSCertificate",
			Handler:    _WarrenAPI_CreateTLSCertificate_Handler,
		},
		{
			MethodName: "GetTLSCertificate",
			Handler:    _WarrenAPI_GetTLSCertificate_Handler,
		},
		{
			MethodName: "ListTLSCertificates",
			Handler:    _WarrenAPI_ListTLSCertificates_Handler,
		},
		{
			MethodName: "DeleteTLSCertificate",
			Handler:    _WarrenAPI_DeleteTLSCertificate_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchContainers",
			Handler:       _WarrenAPI_WatchContainers_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamEvents",
			Handler:       _WarrenAPI_StreamEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/proto/warren.proto",
}

WarrenAPI_ServiceDesc is the grpc.ServiceDesc for WarrenAPI service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterWarrenAPIServer

func RegisterWarrenAPIServer(s grpc.ServiceRegistrar, srv WarrenAPIServer)

Types

type ClusterServer

type ClusterServer struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address  string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Suffrage string `protobuf:"bytes,3,opt,name=suffrage,proto3" json:"suffrage,omitempty"` // "Voter", "Nonvoter", "Staging"
	// contains filtered or unexported fields
}

func (*ClusterServer) Descriptor deprecated

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

Deprecated: Use ClusterServer.ProtoReflect.Descriptor instead.

func (*ClusterServer) GetAddress

func (x *ClusterServer) GetAddress() string

func (*ClusterServer) GetId

func (x *ClusterServer) GetId() string

func (*ClusterServer) GetSuffrage

func (x *ClusterServer) GetSuffrage() string

func (*ClusterServer) ProtoMessage

func (*ClusterServer) ProtoMessage()

func (*ClusterServer) ProtoReflect

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

func (*ClusterServer) Reset

func (x *ClusterServer) Reset()

func (*ClusterServer) String

func (x *ClusterServer) String() string

type Container added in v1.1.1

type Container struct {
	Id                 string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ServiceId          string                 `protobuf:"bytes,2,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	ServiceName        string                 `protobuf:"bytes,3,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	NodeId             string                 `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	RuntimeContainerId string                 `protobuf:"bytes,5,opt,name=runtime_container_id,json=runtimeContainerId,proto3" json:"runtime_container_id,omitempty"`
	DesiredState       string                 `protobuf:"bytes,6,opt,name=desired_state,json=desiredState,proto3" json:"desired_state,omitempty"` // "running", "shutdown"
	ActualState        string                 `protobuf:"bytes,7,opt,name=actual_state,json=actualState,proto3" json:"actual_state,omitempty"`    // "pending", "running", "failed", "stopped"
	Image              string                 `protobuf:"bytes,8,opt,name=image,proto3" json:"image,omitempty"`
	Command            []string               `protobuf:"bytes,9,rep,name=command,proto3" json:"command,omitempty"`
	Env                map[string]string      `` /* 134-byte string literal not displayed */
	Resources          *ResourceRequirements  `protobuf:"bytes,11,opt,name=resources,proto3" json:"resources,omitempty"`
	Volumes            []*VolumeMount         `protobuf:"bytes,12,rep,name=volumes,proto3" json:"volumes,omitempty"`
	HealthCheck        *HealthCheck           `protobuf:"bytes,13,opt,name=health_check,json=healthCheck,proto3" json:"health_check,omitempty"`
	RestartPolicy      *RestartPolicy         `protobuf:"bytes,14,opt,name=restart_policy,json=restartPolicy,proto3" json:"restart_policy,omitempty"`
	CreatedAt          *timestamppb.Timestamp `protobuf:"bytes,15,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt          *timestamppb.Timestamp `protobuf:"bytes,16,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Error              string                 `protobuf:"bytes,17,opt,name=error,proto3" json:"error,omitempty"`
	Secrets            []string               `protobuf:"bytes,18,rep,name=secrets,proto3" json:"secrets,omitempty"`                             // Secret names to mount
	StopTimeout        int32                  `protobuf:"varint,19,opt,name=stop_timeout,json=stopTimeout,proto3" json:"stop_timeout,omitempty"` // Seconds to wait before force-killing (default: 10)
	// contains filtered or unexported fields
}

Container messages

func (*Container) Descriptor deprecated added in v1.1.1

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

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetActualState added in v1.1.1

func (x *Container) GetActualState() string

func (*Container) GetCommand added in v1.1.1

func (x *Container) GetCommand() []string

func (*Container) GetCreatedAt added in v1.1.1

func (x *Container) GetCreatedAt() *timestamppb.Timestamp

func (*Container) GetDesiredState added in v1.1.1

func (x *Container) GetDesiredState() string

func (*Container) GetEnv added in v1.1.1

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

func (*Container) GetError added in v1.1.1

func (x *Container) GetError() string

func (*Container) GetHealthCheck added in v1.1.1

func (x *Container) GetHealthCheck() *HealthCheck

func (*Container) GetId added in v1.1.1

func (x *Container) GetId() string

func (*Container) GetImage added in v1.1.1

func (x *Container) GetImage() string

func (*Container) GetNodeId added in v1.1.1

func (x *Container) GetNodeId() string

func (*Container) GetResources added in v1.1.1

func (x *Container) GetResources() *ResourceRequirements

func (*Container) GetRestartPolicy added in v1.1.1

func (x *Container) GetRestartPolicy() *RestartPolicy

func (*Container) GetRuntimeContainerId added in v1.1.1

func (x *Container) GetRuntimeContainerId() string

func (*Container) GetSecrets added in v1.1.1

func (x *Container) GetSecrets() []string

func (*Container) GetServiceId added in v1.1.1

func (x *Container) GetServiceId() string

func (*Container) GetServiceName added in v1.1.1

func (x *Container) GetServiceName() string

func (*Container) GetStopTimeout added in v1.1.1

func (x *Container) GetStopTimeout() int32

func (*Container) GetUpdatedAt added in v1.1.1

func (x *Container) GetUpdatedAt() *timestamppb.Timestamp

func (*Container) GetVolumes added in v1.1.1

func (x *Container) GetVolumes() []*VolumeMount

func (*Container) ProtoMessage added in v1.1.1

func (*Container) ProtoMessage()

func (*Container) ProtoReflect added in v1.1.1

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

func (*Container) Reset added in v1.1.1

func (x *Container) Reset()

func (*Container) String added in v1.1.1

func (x *Container) String() string

type ContainerEvent added in v1.1.1

type ContainerEvent struct {
	Type      string     `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // "add", "update", "delete"
	Container *Container `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerEvent) Descriptor deprecated added in v1.1.1

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

Deprecated: Use ContainerEvent.ProtoReflect.Descriptor instead.

func (*ContainerEvent) GetContainer added in v1.1.1

func (x *ContainerEvent) GetContainer() *Container

func (*ContainerEvent) GetType added in v1.1.1

func (x *ContainerEvent) GetType() string

func (*ContainerEvent) ProtoMessage added in v1.1.1

func (*ContainerEvent) ProtoMessage()

func (*ContainerEvent) ProtoReflect added in v1.1.1

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

func (*ContainerEvent) Reset added in v1.1.1

func (x *ContainerEvent) Reset()

func (*ContainerEvent) String added in v1.1.1

func (x *ContainerEvent) String() string

type ContainerStatus added in v1.1.1

type ContainerStatus struct {
	ContainerId        string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ActualState        string `protobuf:"bytes,2,opt,name=actual_state,json=actualState,proto3" json:"actual_state,omitempty"` // "running", "failed", "stopped"
	RuntimeContainerId string `protobuf:"bytes,3,opt,name=runtime_container_id,json=runtimeContainerId,proto3" json:"runtime_container_id,omitempty"`
	Error              string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerStatus) Descriptor deprecated added in v1.1.1

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

Deprecated: Use ContainerStatus.ProtoReflect.Descriptor instead.

func (*ContainerStatus) GetActualState added in v1.1.1

func (x *ContainerStatus) GetActualState() string

func (*ContainerStatus) GetContainerId added in v1.1.1

func (x *ContainerStatus) GetContainerId() string

func (*ContainerStatus) GetError added in v1.1.1

func (x *ContainerStatus) GetError() string

func (*ContainerStatus) GetRuntimeContainerId added in v1.1.1

func (x *ContainerStatus) GetRuntimeContainerId() string

func (*ContainerStatus) ProtoMessage added in v1.1.1

func (*ContainerStatus) ProtoMessage()

func (*ContainerStatus) ProtoReflect added in v1.1.1

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

func (*ContainerStatus) Reset added in v1.1.1

func (x *ContainerStatus) Reset()

func (*ContainerStatus) String added in v1.1.1

func (x *ContainerStatus) String() string

type CreateIngressRequest

type CreateIngressRequest struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Rules  []*IngressRule    `protobuf:"bytes,2,rep,name=rules,proto3" json:"rules,omitempty"`
	Tls    *IngressTLS       `protobuf:"bytes,3,opt,name=tls,proto3" json:"tls,omitempty"`
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateIngressRequest) Descriptor deprecated

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

Deprecated: Use CreateIngressRequest.ProtoReflect.Descriptor instead.

func (*CreateIngressRequest) GetLabels

func (x *CreateIngressRequest) GetLabels() map[string]string

func (*CreateIngressRequest) GetName

func (x *CreateIngressRequest) GetName() string

func (*CreateIngressRequest) GetRules

func (x *CreateIngressRequest) GetRules() []*IngressRule

func (*CreateIngressRequest) GetTls

func (x *CreateIngressRequest) GetTls() *IngressTLS

func (*CreateIngressRequest) ProtoMessage

func (*CreateIngressRequest) ProtoMessage()

func (*CreateIngressRequest) ProtoReflect

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

func (*CreateIngressRequest) Reset

func (x *CreateIngressRequest) Reset()

func (*CreateIngressRequest) String

func (x *CreateIngressRequest) String() string

type CreateIngressResponse

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

func (*CreateIngressResponse) Descriptor deprecated

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

Deprecated: Use CreateIngressResponse.ProtoReflect.Descriptor instead.

func (*CreateIngressResponse) GetIngress

func (x *CreateIngressResponse) GetIngress() *Ingress

func (*CreateIngressResponse) ProtoMessage

func (*CreateIngressResponse) ProtoMessage()

func (*CreateIngressResponse) ProtoReflect

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

func (*CreateIngressResponse) Reset

func (x *CreateIngressResponse) Reset()

func (*CreateIngressResponse) String

func (x *CreateIngressResponse) String() string

type CreateSecretRequest

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

func (*CreateSecretRequest) Descriptor deprecated

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

Deprecated: Use CreateSecretRequest.ProtoReflect.Descriptor instead.

func (*CreateSecretRequest) GetData

func (x *CreateSecretRequest) GetData() []byte

func (*CreateSecretRequest) GetName

func (x *CreateSecretRequest) GetName() string

func (*CreateSecretRequest) ProtoMessage

func (*CreateSecretRequest) ProtoMessage()

func (*CreateSecretRequest) ProtoReflect

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

func (*CreateSecretRequest) Reset

func (x *CreateSecretRequest) Reset()

func (*CreateSecretRequest) String

func (x *CreateSecretRequest) String() string

type CreateSecretResponse

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

func (*CreateSecretResponse) Descriptor deprecated

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

Deprecated: Use CreateSecretResponse.ProtoReflect.Descriptor instead.

func (*CreateSecretResponse) GetSecret

func (x *CreateSecretResponse) GetSecret() *Secret

func (*CreateSecretResponse) ProtoMessage

func (*CreateSecretResponse) ProtoMessage()

func (*CreateSecretResponse) ProtoReflect

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

func (*CreateSecretResponse) Reset

func (x *CreateSecretResponse) Reset()

func (*CreateSecretResponse) String

func (x *CreateSecretResponse) String() string

type CreateServiceRequest

type CreateServiceRequest struct {
	Name           string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image          string                `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Replicas       int32                 `protobuf:"varint,3,opt,name=replicas,proto3" json:"replicas,omitempty"`
	Mode           string                `protobuf:"bytes,4,opt,name=mode,proto3" json:"mode,omitempty"`
	DeployStrategy string                `protobuf:"bytes,5,opt,name=deploy_strategy,json=deployStrategy,proto3" json:"deploy_strategy,omitempty"`
	UpdateConfig   *UpdateConfig         `protobuf:"bytes,6,opt,name=update_config,json=updateConfig,proto3" json:"update_config,omitempty"`
	HealthCheck    *HealthCheck          `protobuf:"bytes,7,opt,name=health_check,json=healthCheck,proto3" json:"health_check,omitempty"`
	RestartPolicy  *RestartPolicy        `protobuf:"bytes,8,opt,name=restart_policy,json=restartPolicy,proto3" json:"restart_policy,omitempty"`
	Resources      *ResourceRequirements `protobuf:"bytes,9,opt,name=resources,proto3" json:"resources,omitempty"`
	Networks       []string              `protobuf:"bytes,10,rep,name=networks,proto3" json:"networks,omitempty"`
	Volumes        []*VolumeMount        `protobuf:"bytes,11,rep,name=volumes,proto3" json:"volumes,omitempty"`
	Env            map[string]string     `` /* 134-byte string literal not displayed */
	Command        []string              `protobuf:"bytes,13,rep,name=command,proto3" json:"command,omitempty"`
	Ports          []*PortMapping        `protobuf:"bytes,14,rep,name=ports,proto3" json:"ports,omitempty"`                                 // Published ports
	StopTimeout    int32                 `protobuf:"varint,15,opt,name=stop_timeout,json=stopTimeout,proto3" json:"stop_timeout,omitempty"` // Seconds to wait before force-killing (default: 10)
	// contains filtered or unexported fields
}

func (*CreateServiceRequest) Descriptor deprecated

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

Deprecated: Use CreateServiceRequest.ProtoReflect.Descriptor instead.

func (*CreateServiceRequest) GetCommand

func (x *CreateServiceRequest) GetCommand() []string

func (*CreateServiceRequest) GetDeployStrategy

func (x *CreateServiceRequest) GetDeployStrategy() string

func (*CreateServiceRequest) GetEnv

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

func (*CreateServiceRequest) GetHealthCheck

func (x *CreateServiceRequest) GetHealthCheck() *HealthCheck

func (*CreateServiceRequest) GetImage

func (x *CreateServiceRequest) GetImage() string

func (*CreateServiceRequest) GetMode

func (x *CreateServiceRequest) GetMode() string

func (*CreateServiceRequest) GetName

func (x *CreateServiceRequest) GetName() string

func (*CreateServiceRequest) GetNetworks

func (x *CreateServiceRequest) GetNetworks() []string

func (*CreateServiceRequest) GetPorts

func (x *CreateServiceRequest) GetPorts() []*PortMapping

func (*CreateServiceRequest) GetReplicas

func (x *CreateServiceRequest) GetReplicas() int32

func (*CreateServiceRequest) GetResources

func (x *CreateServiceRequest) GetResources() *ResourceRequirements

func (*CreateServiceRequest) GetRestartPolicy

func (x *CreateServiceRequest) GetRestartPolicy() *RestartPolicy

func (*CreateServiceRequest) GetStopTimeout

func (x *CreateServiceRequest) GetStopTimeout() int32

func (*CreateServiceRequest) GetUpdateConfig

func (x *CreateServiceRequest) GetUpdateConfig() *UpdateConfig

func (*CreateServiceRequest) GetVolumes

func (x *CreateServiceRequest) GetVolumes() []*VolumeMount

func (*CreateServiceRequest) ProtoMessage

func (*CreateServiceRequest) ProtoMessage()

func (*CreateServiceRequest) ProtoReflect

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

func (*CreateServiceRequest) Reset

func (x *CreateServiceRequest) Reset()

func (*CreateServiceRequest) String

func (x *CreateServiceRequest) String() string

type CreateServiceResponse

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

func (*CreateServiceResponse) Descriptor deprecated

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

Deprecated: Use CreateServiceResponse.ProtoReflect.Descriptor instead.

func (*CreateServiceResponse) GetService

func (x *CreateServiceResponse) GetService() *Service

func (*CreateServiceResponse) ProtoMessage

func (*CreateServiceResponse) ProtoMessage()

func (*CreateServiceResponse) ProtoReflect

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

func (*CreateServiceResponse) Reset

func (x *CreateServiceResponse) Reset()

func (*CreateServiceResponse) String

func (x *CreateServiceResponse) String() string

type CreateTLSCertificateRequest

type CreateTLSCertificateRequest struct {
	Name    string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Hosts   []string          `protobuf:"bytes,2,rep,name=hosts,proto3" json:"hosts,omitempty"`
	CertPem []byte            `protobuf:"bytes,3,opt,name=cert_pem,json=certPem,proto3" json:"cert_pem,omitempty"`
	KeyPem  []byte            `protobuf:"bytes,4,opt,name=key_pem,json=keyPem,proto3" json:"key_pem,omitempty"`
	Labels  map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateTLSCertificateRequest) Descriptor deprecated

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

Deprecated: Use CreateTLSCertificateRequest.ProtoReflect.Descriptor instead.

func (*CreateTLSCertificateRequest) GetCertPem

func (x *CreateTLSCertificateRequest) GetCertPem() []byte

func (*CreateTLSCertificateRequest) GetHosts

func (x *CreateTLSCertificateRequest) GetHosts() []string

func (*CreateTLSCertificateRequest) GetKeyPem

func (x *CreateTLSCertificateRequest) GetKeyPem() []byte

func (*CreateTLSCertificateRequest) GetLabels

func (x *CreateTLSCertificateRequest) GetLabels() map[string]string

func (*CreateTLSCertificateRequest) GetName

func (x *CreateTLSCertificateRequest) GetName() string

func (*CreateTLSCertificateRequest) ProtoMessage

func (*CreateTLSCertificateRequest) ProtoMessage()

func (*CreateTLSCertificateRequest) ProtoReflect

func (*CreateTLSCertificateRequest) Reset

func (x *CreateTLSCertificateRequest) Reset()

func (*CreateTLSCertificateRequest) String

func (x *CreateTLSCertificateRequest) String() string

type CreateTLSCertificateResponse

type CreateTLSCertificateResponse struct {
	Certificate *TLSCertificate `protobuf:"bytes,1,opt,name=certificate,proto3" json:"certificate,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTLSCertificateResponse) Descriptor deprecated

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

Deprecated: Use CreateTLSCertificateResponse.ProtoReflect.Descriptor instead.

func (*CreateTLSCertificateResponse) GetCertificate

func (x *CreateTLSCertificateResponse) GetCertificate() *TLSCertificate

func (*CreateTLSCertificateResponse) ProtoMessage

func (*CreateTLSCertificateResponse) ProtoMessage()

func (*CreateTLSCertificateResponse) ProtoReflect

func (*CreateTLSCertificateResponse) Reset

func (x *CreateTLSCertificateResponse) Reset()

func (*CreateTLSCertificateResponse) String

type CreateVolumeRequest

type CreateVolumeRequest struct {
	Name       string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Driver     string            `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	DriverOpts map[string]string `` /* 165-byte string literal not displayed */
	Labels     map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateVolumeRequest) Descriptor deprecated

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

Deprecated: Use CreateVolumeRequest.ProtoReflect.Descriptor instead.

func (*CreateVolumeRequest) GetDriver

func (x *CreateVolumeRequest) GetDriver() string

func (*CreateVolumeRequest) GetDriverOpts

func (x *CreateVolumeRequest) GetDriverOpts() map[string]string

func (*CreateVolumeRequest) GetLabels

func (x *CreateVolumeRequest) GetLabels() map[string]string

func (*CreateVolumeRequest) GetName

func (x *CreateVolumeRequest) GetName() string

func (*CreateVolumeRequest) ProtoMessage

func (*CreateVolumeRequest) ProtoMessage()

func (*CreateVolumeRequest) ProtoReflect

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

func (*CreateVolumeRequest) Reset

func (x *CreateVolumeRequest) Reset()

func (*CreateVolumeRequest) String

func (x *CreateVolumeRequest) String() string

type CreateVolumeResponse

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

func (*CreateVolumeResponse) Descriptor deprecated

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

Deprecated: Use CreateVolumeResponse.ProtoReflect.Descriptor instead.

func (*CreateVolumeResponse) GetVolume

func (x *CreateVolumeResponse) GetVolume() *Volume

func (*CreateVolumeResponse) ProtoMessage

func (*CreateVolumeResponse) ProtoMessage()

func (*CreateVolumeResponse) ProtoReflect

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

func (*CreateVolumeResponse) Reset

func (x *CreateVolumeResponse) Reset()

func (*CreateVolumeResponse) String

func (x *CreateVolumeResponse) String() string

type DeleteIngressRequest

type DeleteIngressRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Alternative to ID
	// contains filtered or unexported fields
}

func (*DeleteIngressRequest) Descriptor deprecated

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

Deprecated: Use DeleteIngressRequest.ProtoReflect.Descriptor instead.

func (*DeleteIngressRequest) GetId

func (x *DeleteIngressRequest) GetId() string

func (*DeleteIngressRequest) GetName

func (x *DeleteIngressRequest) GetName() string

func (*DeleteIngressRequest) ProtoMessage

func (*DeleteIngressRequest) ProtoMessage()

func (*DeleteIngressRequest) ProtoReflect

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

func (*DeleteIngressRequest) Reset

func (x *DeleteIngressRequest) Reset()

func (*DeleteIngressRequest) String

func (x *DeleteIngressRequest) String() string

type DeleteIngressResponse

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

func (*DeleteIngressResponse) Descriptor deprecated

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

Deprecated: Use DeleteIngressResponse.ProtoReflect.Descriptor instead.

func (*DeleteIngressResponse) GetStatus

func (x *DeleteIngressResponse) GetStatus() string

func (*DeleteIngressResponse) ProtoMessage

func (*DeleteIngressResponse) ProtoMessage()

func (*DeleteIngressResponse) ProtoReflect

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

func (*DeleteIngressResponse) Reset

func (x *DeleteIngressResponse) Reset()

func (*DeleteIngressResponse) String

func (x *DeleteIngressResponse) String() string

type DeleteSecretRequest

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

func (*DeleteSecretRequest) Descriptor deprecated

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

Deprecated: Use DeleteSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteSecretRequest) GetId

func (x *DeleteSecretRequest) GetId() string

func (*DeleteSecretRequest) ProtoMessage

func (*DeleteSecretRequest) ProtoMessage()

func (*DeleteSecretRequest) ProtoReflect

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

func (*DeleteSecretRequest) Reset

func (x *DeleteSecretRequest) Reset()

func (*DeleteSecretRequest) String

func (x *DeleteSecretRequest) String() string

type DeleteSecretResponse

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

func (*DeleteSecretResponse) Descriptor deprecated

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

Deprecated: Use DeleteSecretResponse.ProtoReflect.Descriptor instead.

func (*DeleteSecretResponse) GetStatus

func (x *DeleteSecretResponse) GetStatus() string

func (*DeleteSecretResponse) ProtoMessage

func (*DeleteSecretResponse) ProtoMessage()

func (*DeleteSecretResponse) ProtoReflect

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

func (*DeleteSecretResponse) Reset

func (x *DeleteSecretResponse) Reset()

func (*DeleteSecretResponse) String

func (x *DeleteSecretResponse) String() string

type DeleteServiceRequest

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

func (*DeleteServiceRequest) Descriptor deprecated

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

Deprecated: Use DeleteServiceRequest.ProtoReflect.Descriptor instead.

func (*DeleteServiceRequest) GetId

func (x *DeleteServiceRequest) GetId() string

func (*DeleteServiceRequest) ProtoMessage

func (*DeleteServiceRequest) ProtoMessage()

func (*DeleteServiceRequest) ProtoReflect

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

func (*DeleteServiceRequest) Reset

func (x *DeleteServiceRequest) Reset()

func (*DeleteServiceRequest) String

func (x *DeleteServiceRequest) String() string

type DeleteServiceResponse

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

func (*DeleteServiceResponse) Descriptor deprecated

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

Deprecated: Use DeleteServiceResponse.ProtoReflect.Descriptor instead.

func (*DeleteServiceResponse) GetStatus

func (x *DeleteServiceResponse) GetStatus() string

func (*DeleteServiceResponse) ProtoMessage

func (*DeleteServiceResponse) ProtoMessage()

func (*DeleteServiceResponse) ProtoReflect

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

func (*DeleteServiceResponse) Reset

func (x *DeleteServiceResponse) Reset()

func (*DeleteServiceResponse) String

func (x *DeleteServiceResponse) String() string

type DeleteTLSCertificateRequest

type DeleteTLSCertificateRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Can delete by ID or name
	// contains filtered or unexported fields
}

func (*DeleteTLSCertificateRequest) Descriptor deprecated

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

Deprecated: Use DeleteTLSCertificateRequest.ProtoReflect.Descriptor instead.

func (*DeleteTLSCertificateRequest) GetId

func (*DeleteTLSCertificateRequest) GetName

func (x *DeleteTLSCertificateRequest) GetName() string

func (*DeleteTLSCertificateRequest) ProtoMessage

func (*DeleteTLSCertificateRequest) ProtoMessage()

func (*DeleteTLSCertificateRequest) ProtoReflect

func (*DeleteTLSCertificateRequest) Reset

func (x *DeleteTLSCertificateRequest) Reset()

func (*DeleteTLSCertificateRequest) String

func (x *DeleteTLSCertificateRequest) String() string

type DeleteTLSCertificateResponse

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

func (*DeleteTLSCertificateResponse) Descriptor deprecated

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

Deprecated: Use DeleteTLSCertificateResponse.ProtoReflect.Descriptor instead.

func (*DeleteTLSCertificateResponse) GetStatus

func (x *DeleteTLSCertificateResponse) GetStatus() string

func (*DeleteTLSCertificateResponse) ProtoMessage

func (*DeleteTLSCertificateResponse) ProtoMessage()

func (*DeleteTLSCertificateResponse) ProtoReflect

func (*DeleteTLSCertificateResponse) Reset

func (x *DeleteTLSCertificateResponse) Reset()

func (*DeleteTLSCertificateResponse) String

type DeleteVolumeRequest

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

func (*DeleteVolumeRequest) Descriptor deprecated

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

Deprecated: Use DeleteVolumeRequest.ProtoReflect.Descriptor instead.

func (*DeleteVolumeRequest) GetId

func (x *DeleteVolumeRequest) GetId() string

func (*DeleteVolumeRequest) ProtoMessage

func (*DeleteVolumeRequest) ProtoMessage()

func (*DeleteVolumeRequest) ProtoReflect

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

func (*DeleteVolumeRequest) Reset

func (x *DeleteVolumeRequest) Reset()

func (*DeleteVolumeRequest) String

func (x *DeleteVolumeRequest) String() string

type DeleteVolumeResponse

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

func (*DeleteVolumeResponse) Descriptor deprecated

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

Deprecated: Use DeleteVolumeResponse.ProtoReflect.Descriptor instead.

func (*DeleteVolumeResponse) GetStatus

func (x *DeleteVolumeResponse) GetStatus() string

func (*DeleteVolumeResponse) ProtoMessage

func (*DeleteVolumeResponse) ProtoMessage()

func (*DeleteVolumeResponse) ProtoReflect

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

func (*DeleteVolumeResponse) Reset

func (x *DeleteVolumeResponse) Reset()

func (*DeleteVolumeResponse) String

func (x *DeleteVolumeResponse) String() string

type Event

type Event struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type      string                 `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Message   string                 `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	Metadata  map[string]string      `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

Event streaming messages

func (*Event) Descriptor deprecated

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetId

func (x *Event) GetId() string

func (*Event) GetMessage

func (x *Event) GetMessage() string

func (*Event) GetMetadata

func (x *Event) GetMetadata() map[string]string

func (*Event) GetTimestamp

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

func (*Event) GetType

func (x *Event) GetType() string

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type ExecHealthCheck

type ExecHealthCheck struct {
	Command []string `protobuf:"bytes,1,rep,name=command,proto3" json:"command,omitempty"` // Command to execute (e.g., ["pg_isready"])
	// contains filtered or unexported fields
}

func (*ExecHealthCheck) Descriptor deprecated

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

Deprecated: Use ExecHealthCheck.ProtoReflect.Descriptor instead.

func (*ExecHealthCheck) GetCommand

func (x *ExecHealthCheck) GetCommand() []string

func (*ExecHealthCheck) ProtoMessage

func (*ExecHealthCheck) ProtoMessage()

func (*ExecHealthCheck) ProtoReflect

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

func (*ExecHealthCheck) Reset

func (x *ExecHealthCheck) Reset()

func (*ExecHealthCheck) String

func (x *ExecHealthCheck) String() string

type GenerateJoinTokenRequest

type GenerateJoinTokenRequest struct {
	Role string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"` // "manager" or "worker"
	// contains filtered or unexported fields
}

Cluster messages

func (*GenerateJoinTokenRequest) Descriptor deprecated

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

Deprecated: Use GenerateJoinTokenRequest.ProtoReflect.Descriptor instead.

func (*GenerateJoinTokenRequest) GetRole

func (x *GenerateJoinTokenRequest) GetRole() string

func (*GenerateJoinTokenRequest) ProtoMessage

func (*GenerateJoinTokenRequest) ProtoMessage()

func (*GenerateJoinTokenRequest) ProtoReflect

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

func (*GenerateJoinTokenRequest) Reset

func (x *GenerateJoinTokenRequest) Reset()

func (*GenerateJoinTokenRequest) String

func (x *GenerateJoinTokenRequest) String() string

type GenerateJoinTokenResponse

type GenerateJoinTokenResponse struct {
	Token     string                 `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Role      string                 `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateJoinTokenResponse) Descriptor deprecated

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

Deprecated: Use GenerateJoinTokenResponse.ProtoReflect.Descriptor instead.

func (*GenerateJoinTokenResponse) GetExpiresAt

func (x *GenerateJoinTokenResponse) GetExpiresAt() *timestamppb.Timestamp

func (*GenerateJoinTokenResponse) GetRole

func (x *GenerateJoinTokenResponse) GetRole() string

func (*GenerateJoinTokenResponse) GetToken

func (x *GenerateJoinTokenResponse) GetToken() string

func (*GenerateJoinTokenResponse) ProtoMessage

func (*GenerateJoinTokenResponse) ProtoMessage()

func (*GenerateJoinTokenResponse) ProtoReflect

func (*GenerateJoinTokenResponse) Reset

func (x *GenerateJoinTokenResponse) Reset()

func (*GenerateJoinTokenResponse) String

func (x *GenerateJoinTokenResponse) String() string

type GetClusterInfoRequest

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

func (*GetClusterInfoRequest) Descriptor deprecated

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

Deprecated: Use GetClusterInfoRequest.ProtoReflect.Descriptor instead.

func (*GetClusterInfoRequest) ProtoMessage

func (*GetClusterInfoRequest) ProtoMessage()

func (*GetClusterInfoRequest) ProtoReflect

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

func (*GetClusterInfoRequest) Reset

func (x *GetClusterInfoRequest) Reset()

func (*GetClusterInfoRequest) String

func (x *GetClusterInfoRequest) String() string

type GetClusterInfoResponse

type GetClusterInfoResponse struct {
	LeaderId   string           `protobuf:"bytes,1,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"`
	LeaderAddr string           `protobuf:"bytes,2,opt,name=leader_addr,json=leaderAddr,proto3" json:"leader_addr,omitempty"`
	Servers    []*ClusterServer `protobuf:"bytes,3,rep,name=servers,proto3" json:"servers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterInfoResponse) Descriptor deprecated

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

Deprecated: Use GetClusterInfoResponse.ProtoReflect.Descriptor instead.

func (*GetClusterInfoResponse) GetLeaderAddr

func (x *GetClusterInfoResponse) GetLeaderAddr() string

func (*GetClusterInfoResponse) GetLeaderId

func (x *GetClusterInfoResponse) GetLeaderId() string

func (*GetClusterInfoResponse) GetServers

func (x *GetClusterInfoResponse) GetServers() []*ClusterServer

func (*GetClusterInfoResponse) ProtoMessage

func (*GetClusterInfoResponse) ProtoMessage()

func (*GetClusterInfoResponse) ProtoReflect

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

func (*GetClusterInfoResponse) Reset

func (x *GetClusterInfoResponse) Reset()

func (*GetClusterInfoResponse) String

func (x *GetClusterInfoResponse) String() string

type GetContainerRequest added in v1.1.1

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

func (*GetContainerRequest) Descriptor deprecated added in v1.1.1

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

Deprecated: Use GetContainerRequest.ProtoReflect.Descriptor instead.

func (*GetContainerRequest) GetId added in v1.1.1

func (x *GetContainerRequest) GetId() string

func (*GetContainerRequest) ProtoMessage added in v1.1.1

func (*GetContainerRequest) ProtoMessage()

func (*GetContainerRequest) ProtoReflect added in v1.1.1

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

func (*GetContainerRequest) Reset added in v1.1.1

func (x *GetContainerRequest) Reset()

func (*GetContainerRequest) String added in v1.1.1

func (x *GetContainerRequest) String() string

type GetContainerResponse added in v1.1.1

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

func (*GetContainerResponse) Descriptor deprecated added in v1.1.1

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

Deprecated: Use GetContainerResponse.ProtoReflect.Descriptor instead.

func (*GetContainerResponse) GetContainer added in v1.1.1

func (x *GetContainerResponse) GetContainer() *Container

func (*GetContainerResponse) ProtoMessage added in v1.1.1

func (*GetContainerResponse) ProtoMessage()

func (*GetContainerResponse) ProtoReflect added in v1.1.1

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

func (*GetContainerResponse) Reset added in v1.1.1

func (x *GetContainerResponse) Reset()

func (*GetContainerResponse) String added in v1.1.1

func (x *GetContainerResponse) String() string

type GetIngressRequest

type GetIngressRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Alternative to ID
	// contains filtered or unexported fields
}

func (*GetIngressRequest) Descriptor deprecated

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

Deprecated: Use GetIngressRequest.ProtoReflect.Descriptor instead.

func (*GetIngressRequest) GetId

func (x *GetIngressRequest) GetId() string

func (*GetIngressRequest) GetName

func (x *GetIngressRequest) GetName() string

func (*GetIngressRequest) ProtoMessage

func (*GetIngressRequest) ProtoMessage()

func (*GetIngressRequest) ProtoReflect

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

func (*GetIngressRequest) Reset

func (x *GetIngressRequest) Reset()

func (*GetIngressRequest) String

func (x *GetIngressRequest) String() string

type GetIngressResponse

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

func (*GetIngressResponse) Descriptor deprecated

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

Deprecated: Use GetIngressResponse.ProtoReflect.Descriptor instead.

func (*GetIngressResponse) GetIngress

func (x *GetIngressResponse) GetIngress() *Ingress

func (*GetIngressResponse) ProtoMessage

func (*GetIngressResponse) ProtoMessage()

func (*GetIngressResponse) ProtoReflect

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

func (*GetIngressResponse) Reset

func (x *GetIngressResponse) Reset()

func (*GetIngressResponse) String

func (x *GetIngressResponse) String() string

type GetNodeRequest

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

func (*GetNodeRequest) Descriptor deprecated

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

Deprecated: Use GetNodeRequest.ProtoReflect.Descriptor instead.

func (*GetNodeRequest) GetId

func (x *GetNodeRequest) GetId() string

func (*GetNodeRequest) ProtoMessage

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) ProtoReflect

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

func (*GetNodeRequest) Reset

func (x *GetNodeRequest) Reset()

func (*GetNodeRequest) String

func (x *GetNodeRequest) String() string

type GetNodeResponse

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

func (*GetNodeResponse) Descriptor deprecated

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

Deprecated: Use GetNodeResponse.ProtoReflect.Descriptor instead.

func (*GetNodeResponse) GetNode

func (x *GetNodeResponse) GetNode() *Node

func (*GetNodeResponse) ProtoMessage

func (*GetNodeResponse) ProtoMessage()

func (*GetNodeResponse) ProtoReflect

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

func (*GetNodeResponse) Reset

func (x *GetNodeResponse) Reset()

func (*GetNodeResponse) String

func (x *GetNodeResponse) String() string

type GetSecretByNameRequest

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

func (*GetSecretByNameRequest) Descriptor deprecated

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

Deprecated: Use GetSecretByNameRequest.ProtoReflect.Descriptor instead.

func (*GetSecretByNameRequest) GetName

func (x *GetSecretByNameRequest) GetName() string

func (*GetSecretByNameRequest) ProtoMessage

func (*GetSecretByNameRequest) ProtoMessage()

func (*GetSecretByNameRequest) ProtoReflect

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

func (*GetSecretByNameRequest) Reset

func (x *GetSecretByNameRequest) Reset()

func (*GetSecretByNameRequest) String

func (x *GetSecretByNameRequest) String() string

type GetSecretByNameResponse

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

func (*GetSecretByNameResponse) Descriptor deprecated

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

Deprecated: Use GetSecretByNameResponse.ProtoReflect.Descriptor instead.

func (*GetSecretByNameResponse) GetSecret

func (x *GetSecretByNameResponse) GetSecret() *Secret

func (*GetSecretByNameResponse) ProtoMessage

func (*GetSecretByNameResponse) ProtoMessage()

func (*GetSecretByNameResponse) ProtoReflect

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

func (*GetSecretByNameResponse) Reset

func (x *GetSecretByNameResponse) Reset()

func (*GetSecretByNameResponse) String

func (x *GetSecretByNameResponse) String() string

type GetServiceRequest

type GetServiceRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // can query by name or id
	// contains filtered or unexported fields
}

func (*GetServiceRequest) Descriptor deprecated

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

Deprecated: Use GetServiceRequest.ProtoReflect.Descriptor instead.

func (*GetServiceRequest) GetId

func (x *GetServiceRequest) GetId() string

func (*GetServiceRequest) GetName

func (x *GetServiceRequest) GetName() string

func (*GetServiceRequest) ProtoMessage

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) ProtoReflect

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

func (*GetServiceRequest) Reset

func (x *GetServiceRequest) Reset()

func (*GetServiceRequest) String

func (x *GetServiceRequest) String() string

type GetServiceResponse

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

func (*GetServiceResponse) Descriptor deprecated

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

Deprecated: Use GetServiceResponse.ProtoReflect.Descriptor instead.

func (*GetServiceResponse) GetService

func (x *GetServiceResponse) GetService() *Service

func (*GetServiceResponse) ProtoMessage

func (*GetServiceResponse) ProtoMessage()

func (*GetServiceResponse) ProtoReflect

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

func (*GetServiceResponse) Reset

func (x *GetServiceResponse) Reset()

func (*GetServiceResponse) String

func (x *GetServiceResponse) String() string

type GetTLSCertificateRequest

type GetTLSCertificateRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Can query by ID or name
	// contains filtered or unexported fields
}

func (*GetTLSCertificateRequest) Descriptor deprecated

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

Deprecated: Use GetTLSCertificateRequest.ProtoReflect.Descriptor instead.

func (*GetTLSCertificateRequest) GetId

func (x *GetTLSCertificateRequest) GetId() string

func (*GetTLSCertificateRequest) GetName

func (x *GetTLSCertificateRequest) GetName() string

func (*GetTLSCertificateRequest) ProtoMessage

func (*GetTLSCertificateRequest) ProtoMessage()

func (*GetTLSCertificateRequest) ProtoReflect

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

func (*GetTLSCertificateRequest) Reset

func (x *GetTLSCertificateRequest) Reset()

func (*GetTLSCertificateRequest) String

func (x *GetTLSCertificateRequest) String() string

type GetTLSCertificateResponse

type GetTLSCertificateResponse struct {
	Certificate *TLSCertificate `protobuf:"bytes,1,opt,name=certificate,proto3" json:"certificate,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTLSCertificateResponse) Descriptor deprecated

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

Deprecated: Use GetTLSCertificateResponse.ProtoReflect.Descriptor instead.

func (*GetTLSCertificateResponse) GetCertificate

func (x *GetTLSCertificateResponse) GetCertificate() *TLSCertificate

func (*GetTLSCertificateResponse) ProtoMessage

func (*GetTLSCertificateResponse) ProtoMessage()

func (*GetTLSCertificateResponse) ProtoReflect

func (*GetTLSCertificateResponse) Reset

func (x *GetTLSCertificateResponse) Reset()

func (*GetTLSCertificateResponse) String

func (x *GetTLSCertificateResponse) String() string

type GetVolumeByNameRequest

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

func (*GetVolumeByNameRequest) Descriptor deprecated

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

Deprecated: Use GetVolumeByNameRequest.ProtoReflect.Descriptor instead.

func (*GetVolumeByNameRequest) GetName

func (x *GetVolumeByNameRequest) GetName() string

func (*GetVolumeByNameRequest) ProtoMessage

func (*GetVolumeByNameRequest) ProtoMessage()

func (*GetVolumeByNameRequest) ProtoReflect

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

func (*GetVolumeByNameRequest) Reset

func (x *GetVolumeByNameRequest) Reset()

func (*GetVolumeByNameRequest) String

func (x *GetVolumeByNameRequest) String() string

type GetVolumeByNameResponse

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

func (*GetVolumeByNameResponse) Descriptor deprecated

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

Deprecated: Use GetVolumeByNameResponse.ProtoReflect.Descriptor instead.

func (*GetVolumeByNameResponse) GetVolume

func (x *GetVolumeByNameResponse) GetVolume() *Volume

func (*GetVolumeByNameResponse) ProtoMessage

func (*GetVolumeByNameResponse) ProtoMessage()

func (*GetVolumeByNameResponse) ProtoReflect

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

func (*GetVolumeByNameResponse) Reset

func (x *GetVolumeByNameResponse) Reset()

func (*GetVolumeByNameResponse) String

func (x *GetVolumeByNameResponse) String() string

type HTTPHealthCheck

type HTTPHealthCheck struct {
	Path          string    `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`                                           // HTTP path (e.g., "/health")
	Port          int32     `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`                                          // Container port
	Scheme        string    `protobuf:"bytes,3,opt,name=scheme,proto3" json:"scheme,omitempty"`                                       // "http" or "https" (default: "http")
	Headers       []*Header `protobuf:"bytes,4,rep,name=headers,proto3" json:"headers,omitempty"`                                     // Custom headers
	StatusCodeMin int32     `protobuf:"varint,5,opt,name=status_code_min,json=statusCodeMin,proto3" json:"status_code_min,omitempty"` // Min acceptable status (default: 200)
	StatusCodeMax int32     `protobuf:"varint,6,opt,name=status_code_max,json=statusCodeMax,proto3" json:"status_code_max,omitempty"` // Max acceptable status (default: 399)
	// contains filtered or unexported fields
}

func (*HTTPHealthCheck) Descriptor deprecated

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

Deprecated: Use HTTPHealthCheck.ProtoReflect.Descriptor instead.

func (*HTTPHealthCheck) GetHeaders

func (x *HTTPHealthCheck) GetHeaders() []*Header

func (*HTTPHealthCheck) GetPath

func (x *HTTPHealthCheck) GetPath() string

func (*HTTPHealthCheck) GetPort

func (x *HTTPHealthCheck) GetPort() int32

func (*HTTPHealthCheck) GetScheme

func (x *HTTPHealthCheck) GetScheme() string

func (*HTTPHealthCheck) GetStatusCodeMax

func (x *HTTPHealthCheck) GetStatusCodeMax() int32

func (*HTTPHealthCheck) GetStatusCodeMin

func (x *HTTPHealthCheck) GetStatusCodeMin() int32

func (*HTTPHealthCheck) ProtoMessage

func (*HTTPHealthCheck) ProtoMessage()

func (*HTTPHealthCheck) ProtoReflect

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

func (*HTTPHealthCheck) Reset

func (x *HTTPHealthCheck) Reset()

func (*HTTPHealthCheck) String

func (x *HTTPHealthCheck) String() string
type Header struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetKey

func (x *Header) GetKey() string

func (*Header) GetValue

func (x *Header) GetValue() string

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) ProtoReflect

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

func (*Header) Reset

func (x *Header) Reset()

func (*Header) String

func (x *Header) String() string

type HealthCheck

type HealthCheck struct {
	Type HealthCheck_Type `protobuf:"varint,1,opt,name=type,proto3,enum=warren.v1.HealthCheck_Type" json:"type,omitempty"`
	// Type-specific configurations
	Http *HTTPHealthCheck `protobuf:"bytes,2,opt,name=http,proto3" json:"http,omitempty"`
	Tcp  *TCPHealthCheck  `protobuf:"bytes,3,opt,name=tcp,proto3" json:"tcp,omitempty"`
	Exec *ExecHealthCheck `protobuf:"bytes,4,opt,name=exec,proto3" json:"exec,omitempty"`
	// Common configuration
	IntervalSeconds    int32 `protobuf:"varint,5,opt,name=interval_seconds,json=intervalSeconds,proto3" json:"interval_seconds,omitempty"`            // Time between checks (default: 30s)
	TimeoutSeconds     int32 `protobuf:"varint,6,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`               // Check timeout (default: 10s)
	Retries            int32 `protobuf:"varint,7,opt,name=retries,proto3" json:"retries,omitempty"`                                                   // Failures before unhealthy (default: 3)
	StartPeriodSeconds int32 `protobuf:"varint,8,opt,name=start_period_seconds,json=startPeriodSeconds,proto3" json:"start_period_seconds,omitempty"` // Grace period for startup (default: 0s)
	// contains filtered or unexported fields
}

func (*HealthCheck) Descriptor deprecated

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

Deprecated: Use HealthCheck.ProtoReflect.Descriptor instead.

func (*HealthCheck) GetExec

func (x *HealthCheck) GetExec() *ExecHealthCheck

func (*HealthCheck) GetHttp

func (x *HealthCheck) GetHttp() *HTTPHealthCheck

func (*HealthCheck) GetIntervalSeconds

func (x *HealthCheck) GetIntervalSeconds() int32

func (*HealthCheck) GetRetries

func (x *HealthCheck) GetRetries() int32

func (*HealthCheck) GetStartPeriodSeconds

func (x *HealthCheck) GetStartPeriodSeconds() int32

func (*HealthCheck) GetTcp

func (x *HealthCheck) GetTcp() *TCPHealthCheck

func (*HealthCheck) GetTimeoutSeconds

func (x *HealthCheck) GetTimeoutSeconds() int32

func (*HealthCheck) GetType

func (x *HealthCheck) GetType() HealthCheck_Type

func (*HealthCheck) ProtoMessage

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) ProtoReflect

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

func (*HealthCheck) Reset

func (x *HealthCheck) Reset()

func (*HealthCheck) String

func (x *HealthCheck) String() string

type HealthCheck_Type

type HealthCheck_Type int32

Type of health check

const (
	HealthCheck_HTTP HealthCheck_Type = 0
	HealthCheck_TCP  HealthCheck_Type = 1
	HealthCheck_EXEC HealthCheck_Type = 2
)

func (HealthCheck_Type) Descriptor

func (HealthCheck_Type) Enum

func (HealthCheck_Type) EnumDescriptor deprecated

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

Deprecated: Use HealthCheck_Type.Descriptor instead.

func (HealthCheck_Type) Number

func (HealthCheck_Type) String

func (x HealthCheck_Type) String() string

func (HealthCheck_Type) Type

type HeartbeatRequest

type HeartbeatRequest struct {
	NodeId             string             `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	AvailableResources *NodeResources     `protobuf:"bytes,2,opt,name=available_resources,json=availableResources,proto3" json:"available_resources,omitempty"`
	ContainerStatuses  []*ContainerStatus `protobuf:"bytes,3,rep,name=container_statuses,json=containerStatuses,proto3" json:"container_statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetAvailableResources

func (x *HeartbeatRequest) GetAvailableResources() *NodeResources

func (*HeartbeatRequest) GetContainerStatuses added in v1.1.1

func (x *HeartbeatRequest) GetContainerStatuses() []*ContainerStatus

func (*HeartbeatRequest) GetNodeId

func (x *HeartbeatRequest) GetNodeId() string

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 {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatResponse) Descriptor deprecated

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) GetStatus

func (x *HeartbeatResponse) GetStatus() string

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 Ingress

type Ingress struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Rules     []*IngressRule         `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"`
	Tls       *IngressTLS            `protobuf:"bytes,4,opt,name=tls,proto3" json:"tls,omitempty"`
	Labels    map[string]string      `` /* 139-byte string literal not displayed */
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Ingress messages

func (*Ingress) Descriptor deprecated

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

Deprecated: Use Ingress.ProtoReflect.Descriptor instead.

func (*Ingress) GetCreatedAt

func (x *Ingress) GetCreatedAt() *timestamppb.Timestamp

func (*Ingress) GetId

func (x *Ingress) GetId() string

func (*Ingress) GetLabels

func (x *Ingress) GetLabels() map[string]string

func (*Ingress) GetName

func (x *Ingress) GetName() string

func (*Ingress) GetRules

func (x *Ingress) GetRules() []*IngressRule

func (*Ingress) GetTls

func (x *Ingress) GetTls() *IngressTLS

func (*Ingress) GetUpdatedAt

func (x *Ingress) GetUpdatedAt() *timestamppb.Timestamp

func (*Ingress) ProtoMessage

func (*Ingress) ProtoMessage()

func (*Ingress) ProtoReflect

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

func (*Ingress) Reset

func (x *Ingress) Reset()

func (*Ingress) String

func (x *Ingress) String() string

type IngressBackend

type IngressBackend struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	Port        int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*IngressBackend) Descriptor deprecated

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

Deprecated: Use IngressBackend.ProtoReflect.Descriptor instead.

func (*IngressBackend) GetPort

func (x *IngressBackend) GetPort() int32

func (*IngressBackend) GetServiceName

func (x *IngressBackend) GetServiceName() string

func (*IngressBackend) ProtoMessage

func (*IngressBackend) ProtoMessage()

func (*IngressBackend) ProtoReflect

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

func (*IngressBackend) Reset

func (x *IngressBackend) Reset()

func (*IngressBackend) String

func (x *IngressBackend) String() string

type IngressPath

type IngressPath struct {
	Path     string          `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`                         // e.g., "/api", "/web"
	PathType string          `protobuf:"bytes,2,opt,name=path_type,json=pathType,proto3" json:"path_type,omitempty"` // "Prefix" or "Exact"
	Backend  *IngressBackend `protobuf:"bytes,3,opt,name=backend,proto3" json:"backend,omitempty"`
	// contains filtered or unexported fields
}

func (*IngressPath) Descriptor deprecated

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

Deprecated: Use IngressPath.ProtoReflect.Descriptor instead.

func (*IngressPath) GetBackend

func (x *IngressPath) GetBackend() *IngressBackend

func (*IngressPath) GetPath

func (x *IngressPath) GetPath() string

func (*IngressPath) GetPathType

func (x *IngressPath) GetPathType() string

func (*IngressPath) ProtoMessage

func (*IngressPath) ProtoMessage()

func (*IngressPath) ProtoReflect

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

func (*IngressPath) Reset

func (x *IngressPath) Reset()

func (*IngressPath) String

func (x *IngressPath) String() string

type IngressRule

type IngressRule struct {
	Host  string         `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // e.g., "api.example.com", "*.example.com"
	Paths []*IngressPath `protobuf:"bytes,2,rep,name=paths,proto3" json:"paths,omitempty"`
	// contains filtered or unexported fields
}

func (*IngressRule) Descriptor deprecated

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

Deprecated: Use IngressRule.ProtoReflect.Descriptor instead.

func (*IngressRule) GetHost

func (x *IngressRule) GetHost() string

func (*IngressRule) GetPaths

func (x *IngressRule) GetPaths() []*IngressPath

func (*IngressRule) ProtoMessage

func (*IngressRule) ProtoMessage()

func (*IngressRule) ProtoReflect

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

func (*IngressRule) Reset

func (x *IngressRule) Reset()

func (*IngressRule) String

func (x *IngressRule) String() string

type IngressTLS

type IngressTLS struct {
	Enabled    bool     `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	SecretName string   `protobuf:"bytes,2,opt,name=secret_name,json=secretName,proto3" json:"secret_name,omitempty"`
	Hosts      []string `protobuf:"bytes,3,rep,name=hosts,proto3" json:"hosts,omitempty"`
	AutoTls    bool     `protobuf:"varint,4,opt,name=auto_tls,json=autoTls,proto3" json:"auto_tls,omitempty"` // Enable Let's Encrypt
	Email      string   `protobuf:"bytes,5,opt,name=email,proto3" json:"email,omitempty"`                     // Email for Let's Encrypt
	// contains filtered or unexported fields
}

func (*IngressTLS) Descriptor deprecated

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

Deprecated: Use IngressTLS.ProtoReflect.Descriptor instead.

func (*IngressTLS) GetAutoTls

func (x *IngressTLS) GetAutoTls() bool

func (*IngressTLS) GetEmail

func (x *IngressTLS) GetEmail() string

func (*IngressTLS) GetEnabled

func (x *IngressTLS) GetEnabled() bool

func (*IngressTLS) GetHosts

func (x *IngressTLS) GetHosts() []string

func (*IngressTLS) GetSecretName

func (x *IngressTLS) GetSecretName() string

func (*IngressTLS) ProtoMessage

func (*IngressTLS) ProtoMessage()

func (*IngressTLS) ProtoReflect

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

func (*IngressTLS) Reset

func (x *IngressTLS) Reset()

func (*IngressTLS) String

func (x *IngressTLS) String() string

type JoinClusterRequest

type JoinClusterRequest struct {
	NodeId   string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	BindAddr string `protobuf:"bytes,2,opt,name=bind_addr,json=bindAddr,proto3" json:"bind_addr,omitempty"`
	Token    string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinClusterRequest) Descriptor deprecated

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

Deprecated: Use JoinClusterRequest.ProtoReflect.Descriptor instead.

func (*JoinClusterRequest) GetBindAddr

func (x *JoinClusterRequest) GetBindAddr() string

func (*JoinClusterRequest) GetNodeId

func (x *JoinClusterRequest) GetNodeId() string

func (*JoinClusterRequest) GetToken

func (x *JoinClusterRequest) GetToken() string

func (*JoinClusterRequest) ProtoMessage

func (*JoinClusterRequest) ProtoMessage()

func (*JoinClusterRequest) ProtoReflect

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

func (*JoinClusterRequest) Reset

func (x *JoinClusterRequest) Reset()

func (*JoinClusterRequest) String

func (x *JoinClusterRequest) String() string

type JoinClusterResponse

type JoinClusterResponse struct {
	Status     string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	LeaderAddr string `protobuf:"bytes,2,opt,name=leader_addr,json=leaderAddr,proto3" json:"leader_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinClusterResponse) Descriptor deprecated

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

Deprecated: Use JoinClusterResponse.ProtoReflect.Descriptor instead.

func (*JoinClusterResponse) GetLeaderAddr

func (x *JoinClusterResponse) GetLeaderAddr() string

func (*JoinClusterResponse) GetStatus

func (x *JoinClusterResponse) GetStatus() string

func (*JoinClusterResponse) ProtoMessage

func (*JoinClusterResponse) ProtoMessage()

func (*JoinClusterResponse) ProtoReflect

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

func (*JoinClusterResponse) Reset

func (x *JoinClusterResponse) Reset()

func (*JoinClusterResponse) String

func (x *JoinClusterResponse) String() string

type ListContainersRequest added in v1.1.1

type ListContainersRequest struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"` // optional filter
	NodeId    string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`          // optional filter
	// contains filtered or unexported fields
}

func (*ListContainersRequest) Descriptor deprecated added in v1.1.1

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

Deprecated: Use ListContainersRequest.ProtoReflect.Descriptor instead.

func (*ListContainersRequest) GetNodeId added in v1.1.1

func (x *ListContainersRequest) GetNodeId() string

func (*ListContainersRequest) GetServiceId added in v1.1.1

func (x *ListContainersRequest) GetServiceId() string

func (*ListContainersRequest) ProtoMessage added in v1.1.1

func (*ListContainersRequest) ProtoMessage()

func (*ListContainersRequest) ProtoReflect added in v1.1.1

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

func (*ListContainersRequest) Reset added in v1.1.1

func (x *ListContainersRequest) Reset()

func (*ListContainersRequest) String added in v1.1.1

func (x *ListContainersRequest) String() string

type ListContainersResponse added in v1.1.1

type ListContainersResponse struct {
	Containers []*Container `protobuf:"bytes,1,rep,name=containers,proto3" json:"containers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListContainersResponse) Descriptor deprecated added in v1.1.1

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

Deprecated: Use ListContainersResponse.ProtoReflect.Descriptor instead.

func (*ListContainersResponse) GetContainers added in v1.1.1

func (x *ListContainersResponse) GetContainers() []*Container

func (*ListContainersResponse) ProtoMessage added in v1.1.1

func (*ListContainersResponse) ProtoMessage()

func (*ListContainersResponse) ProtoReflect added in v1.1.1

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

func (*ListContainersResponse) Reset added in v1.1.1

func (x *ListContainersResponse) Reset()

func (*ListContainersResponse) String added in v1.1.1

func (x *ListContainersResponse) String() string

type ListIngressesRequest

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

func (*ListIngressesRequest) Descriptor deprecated

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

Deprecated: Use ListIngressesRequest.ProtoReflect.Descriptor instead.

func (*ListIngressesRequest) ProtoMessage

func (*ListIngressesRequest) ProtoMessage()

func (*ListIngressesRequest) ProtoReflect

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

func (*ListIngressesRequest) Reset

func (x *ListIngressesRequest) Reset()

func (*ListIngressesRequest) String

func (x *ListIngressesRequest) String() string

type ListIngressesResponse

type ListIngressesResponse struct {
	Ingresses []*Ingress `protobuf:"bytes,1,rep,name=ingresses,proto3" json:"ingresses,omitempty"`
	// contains filtered or unexported fields
}

func (*ListIngressesResponse) Descriptor deprecated

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

Deprecated: Use ListIngressesResponse.ProtoReflect.Descriptor instead.

func (*ListIngressesResponse) GetIngresses

func (x *ListIngressesResponse) GetIngresses() []*Ingress

func (*ListIngressesResponse) ProtoMessage

func (*ListIngressesResponse) ProtoMessage()

func (*ListIngressesResponse) ProtoReflect

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

func (*ListIngressesResponse) Reset

func (x *ListIngressesResponse) Reset()

func (*ListIngressesResponse) String

func (x *ListIngressesResponse) String() string

type ListNodesRequest

type ListNodesRequest struct {
	RoleFilter string `protobuf:"bytes,1,opt,name=role_filter,json=roleFilter,proto3" json:"role_filter,omitempty"` // optional: "manager" or "worker"
	// contains filtered or unexported fields
}

func (*ListNodesRequest) Descriptor deprecated

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

Deprecated: Use ListNodesRequest.ProtoReflect.Descriptor instead.

func (*ListNodesRequest) GetRoleFilter

func (x *ListNodesRequest) GetRoleFilter() string

func (*ListNodesRequest) ProtoMessage

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) ProtoReflect

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

func (*ListNodesRequest) Reset

func (x *ListNodesRequest) Reset()

func (*ListNodesRequest) String

func (x *ListNodesRequest) String() string

type ListNodesResponse

type ListNodesResponse struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodesResponse) Descriptor deprecated

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

Deprecated: Use ListNodesResponse.ProtoReflect.Descriptor instead.

func (*ListNodesResponse) GetNodes

func (x *ListNodesResponse) GetNodes() []*Node

func (*ListNodesResponse) ProtoMessage

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) ProtoReflect

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

func (*ListNodesResponse) Reset

func (x *ListNodesResponse) Reset()

func (*ListNodesResponse) String

func (x *ListNodesResponse) String() string

type ListSecretsRequest

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

func (*ListSecretsRequest) Descriptor deprecated

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

Deprecated: Use ListSecretsRequest.ProtoReflect.Descriptor instead.

func (*ListSecretsRequest) ProtoMessage

func (*ListSecretsRequest) ProtoMessage()

func (*ListSecretsRequest) ProtoReflect

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

func (*ListSecretsRequest) Reset

func (x *ListSecretsRequest) Reset()

func (*ListSecretsRequest) String

func (x *ListSecretsRequest) String() string

type ListSecretsResponse

type ListSecretsResponse struct {
	Secrets []*Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSecretsResponse) Descriptor deprecated

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

Deprecated: Use ListSecretsResponse.ProtoReflect.Descriptor instead.

func (*ListSecretsResponse) GetSecrets

func (x *ListSecretsResponse) GetSecrets() []*Secret

func (*ListSecretsResponse) ProtoMessage

func (*ListSecretsResponse) ProtoMessage()

func (*ListSecretsResponse) ProtoReflect

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

func (*ListSecretsResponse) Reset

func (x *ListSecretsResponse) Reset()

func (*ListSecretsResponse) String

func (x *ListSecretsResponse) String() string

type ListServicesRequest

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

func (*ListServicesRequest) Descriptor deprecated

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

Deprecated: Use ListServicesRequest.ProtoReflect.Descriptor instead.

func (*ListServicesRequest) ProtoMessage

func (*ListServicesRequest) ProtoMessage()

func (*ListServicesRequest) ProtoReflect

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

func (*ListServicesRequest) Reset

func (x *ListServicesRequest) Reset()

func (*ListServicesRequest) String

func (x *ListServicesRequest) String() string

type ListServicesResponse

type ListServicesResponse struct {
	Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*ListServicesResponse) Descriptor deprecated

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

Deprecated: Use ListServicesResponse.ProtoReflect.Descriptor instead.

func (*ListServicesResponse) GetServices

func (x *ListServicesResponse) GetServices() []*Service

func (*ListServicesResponse) ProtoMessage

func (*ListServicesResponse) ProtoMessage()

func (*ListServicesResponse) ProtoReflect

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

func (*ListServicesResponse) Reset

func (x *ListServicesResponse) Reset()

func (*ListServicesResponse) String

func (x *ListServicesResponse) String() string

type ListTLSCertificatesRequest

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

func (*ListTLSCertificatesRequest) Descriptor deprecated

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

Deprecated: Use ListTLSCertificatesRequest.ProtoReflect.Descriptor instead.

func (*ListTLSCertificatesRequest) ProtoMessage

func (*ListTLSCertificatesRequest) ProtoMessage()

func (*ListTLSCertificatesRequest) ProtoReflect

func (*ListTLSCertificatesRequest) Reset

func (x *ListTLSCertificatesRequest) Reset()

func (*ListTLSCertificatesRequest) String

func (x *ListTLSCertificatesRequest) String() string

type ListTLSCertificatesResponse

type ListTLSCertificatesResponse struct {
	Certificates []*TLSCertificate `protobuf:"bytes,1,rep,name=certificates,proto3" json:"certificates,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTLSCertificatesResponse) Descriptor deprecated

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

Deprecated: Use ListTLSCertificatesResponse.ProtoReflect.Descriptor instead.

func (*ListTLSCertificatesResponse) GetCertificates

func (x *ListTLSCertificatesResponse) GetCertificates() []*TLSCertificate

func (*ListTLSCertificatesResponse) ProtoMessage

func (*ListTLSCertificatesResponse) ProtoMessage()

func (*ListTLSCertificatesResponse) ProtoReflect

func (*ListTLSCertificatesResponse) Reset

func (x *ListTLSCertificatesResponse) Reset()

func (*ListTLSCertificatesResponse) String

func (x *ListTLSCertificatesResponse) String() string

type ListVolumesRequest

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

func (*ListVolumesRequest) Descriptor deprecated

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

Deprecated: Use ListVolumesRequest.ProtoReflect.Descriptor instead.

func (*ListVolumesRequest) ProtoMessage

func (*ListVolumesRequest) ProtoMessage()

func (*ListVolumesRequest) ProtoReflect

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

func (*ListVolumesRequest) Reset

func (x *ListVolumesRequest) Reset()

func (*ListVolumesRequest) String

func (x *ListVolumesRequest) String() string

type ListVolumesResponse

type ListVolumesResponse struct {
	Volumes []*Volume `protobuf:"bytes,1,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVolumesResponse) Descriptor deprecated

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

Deprecated: Use ListVolumesResponse.ProtoReflect.Descriptor instead.

func (*ListVolumesResponse) GetVolumes

func (x *ListVolumesResponse) GetVolumes() []*Volume

func (*ListVolumesResponse) ProtoMessage

func (*ListVolumesResponse) ProtoMessage()

func (*ListVolumesResponse) ProtoReflect

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

func (*ListVolumesResponse) Reset

func (x *ListVolumesResponse) Reset()

func (*ListVolumesResponse) String

func (x *ListVolumesResponse) String() string

type Node

type Node struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Role          string                 `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"` // "manager" or "worker"
	Address       string                 `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	OverlayIp     string                 `protobuf:"bytes,4,opt,name=overlay_ip,json=overlayIp,proto3" json:"overlay_ip,omitempty"`
	Resources     *NodeResources         `protobuf:"bytes,5,opt,name=resources,proto3" json:"resources,omitempty"`
	Status        string                 `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"` // "ready", "down", "unknown"
	LastHeartbeat *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_heartbeat,json=lastHeartbeat,proto3" json:"last_heartbeat,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Labels        map[string]string      `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

Node messages

func (*Node) Descriptor deprecated

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetAddress

func (x *Node) GetAddress() string

func (*Node) GetCreatedAt

func (x *Node) GetCreatedAt() *timestamppb.Timestamp

func (*Node) GetId

func (x *Node) GetId() string

func (*Node) GetLabels

func (x *Node) GetLabels() map[string]string

func (*Node) GetLastHeartbeat

func (x *Node) GetLastHeartbeat() *timestamppb.Timestamp

func (*Node) GetOverlayIp

func (x *Node) GetOverlayIp() string

func (*Node) GetResources

func (x *Node) GetResources() *NodeResources

func (*Node) GetRole

func (x *Node) GetRole() string

func (*Node) GetStatus

func (x *Node) GetStatus() string

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) ProtoReflect

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

func (*Node) Reset

func (x *Node) Reset()

func (*Node) String

func (x *Node) String() string

type NodeResources

type NodeResources struct {
	CpuCores    int64 `protobuf:"varint,1,opt,name=cpu_cores,json=cpuCores,proto3" json:"cpu_cores,omitempty"`
	MemoryBytes int64 `protobuf:"varint,2,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	DiskBytes   int64 `protobuf:"varint,3,opt,name=disk_bytes,json=diskBytes,proto3" json:"disk_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeResources) Descriptor deprecated

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

Deprecated: Use NodeResources.ProtoReflect.Descriptor instead.

func (*NodeResources) GetCpuCores

func (x *NodeResources) GetCpuCores() int64

func (*NodeResources) GetDiskBytes

func (x *NodeResources) GetDiskBytes() int64

func (*NodeResources) GetMemoryBytes

func (x *NodeResources) GetMemoryBytes() int64

func (*NodeResources) ProtoMessage

func (*NodeResources) ProtoMessage()

func (*NodeResources) ProtoReflect

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

func (*NodeResources) Reset

func (x *NodeResources) Reset()

func (*NodeResources) String

func (x *NodeResources) String() string

type PortMapping

type PortMapping struct {
	Name          string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                         // Optional port name
	ContainerPort int32                   `protobuf:"varint,2,opt,name=container_port,json=containerPort,proto3" json:"container_port,omitempty"` // Port inside container (target)
	HostPort      int32                   `protobuf:"varint,3,opt,name=host_port,json=hostPort,proto3" json:"host_port,omitempty"`                // Port on host/cluster (published)
	Protocol      string                  `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`                                 // "tcp" or "udp" (default: "tcp")
	PublishMode   PortMapping_PublishMode ``                                                                                                      // Publishing mode (default: HOST)
	/* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

func (x *PortMapping) GetHostPort() int32

func (*PortMapping) GetName

func (x *PortMapping) GetName() string

func (*PortMapping) GetProtocol

func (x *PortMapping) GetProtocol() string

func (*PortMapping) GetPublishMode

func (x *PortMapping) GetPublishMode() PortMapping_PublishMode

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 PortMapping_PublishMode

type PortMapping_PublishMode int32
const (
	PortMapping_HOST    PortMapping_PublishMode = 0 // Publish on node running the container
	PortMapping_INGRESS PortMapping_PublishMode = 1 // Publish on all nodes with routing mesh
)

func (PortMapping_PublishMode) Descriptor

func (PortMapping_PublishMode) Enum

func (PortMapping_PublishMode) EnumDescriptor deprecated

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

Deprecated: Use PortMapping_PublishMode.Descriptor instead.

func (PortMapping_PublishMode) Number

func (PortMapping_PublishMode) String

func (x PortMapping_PublishMode) String() string

func (PortMapping_PublishMode) Type

type RegisterNodeRequest

type RegisterNodeRequest struct {
	Id        string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Role      string            `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	Address   string            `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	Resources *NodeResources    `protobuf:"bytes,4,opt,name=resources,proto3" json:"resources,omitempty"`
	Labels    map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RegisterNodeRequest) Descriptor deprecated

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

Deprecated: Use RegisterNodeRequest.ProtoReflect.Descriptor instead.

func (*RegisterNodeRequest) GetAddress

func (x *RegisterNodeRequest) GetAddress() string

func (*RegisterNodeRequest) GetId

func (x *RegisterNodeRequest) GetId() string

func (*RegisterNodeRequest) GetLabels

func (x *RegisterNodeRequest) GetLabels() map[string]string

func (*RegisterNodeRequest) GetResources

func (x *RegisterNodeRequest) GetResources() *NodeResources

func (*RegisterNodeRequest) GetRole

func (x *RegisterNodeRequest) GetRole() string

func (*RegisterNodeRequest) ProtoMessage

func (*RegisterNodeRequest) ProtoMessage()

func (*RegisterNodeRequest) ProtoReflect

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

func (*RegisterNodeRequest) Reset

func (x *RegisterNodeRequest) Reset()

func (*RegisterNodeRequest) String

func (x *RegisterNodeRequest) String() string

type RegisterNodeResponse

type RegisterNodeResponse struct {
	Node      *Node  `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	OverlayIp string `protobuf:"bytes,2,opt,name=overlay_ip,json=overlayIp,proto3" json:"overlay_ip,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterNodeResponse) Descriptor deprecated

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

Deprecated: Use RegisterNodeResponse.ProtoReflect.Descriptor instead.

func (*RegisterNodeResponse) GetNode

func (x *RegisterNodeResponse) GetNode() *Node

func (*RegisterNodeResponse) GetOverlayIp

func (x *RegisterNodeResponse) GetOverlayIp() string

func (*RegisterNodeResponse) ProtoMessage

func (*RegisterNodeResponse) ProtoMessage()

func (*RegisterNodeResponse) ProtoReflect

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

func (*RegisterNodeResponse) Reset

func (x *RegisterNodeResponse) Reset()

func (*RegisterNodeResponse) String

func (x *RegisterNodeResponse) String() string

type RemoveNodeRequest

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

func (*RemoveNodeRequest) Descriptor deprecated

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

Deprecated: Use RemoveNodeRequest.ProtoReflect.Descriptor instead.

func (*RemoveNodeRequest) GetId

func (x *RemoveNodeRequest) GetId() string

func (*RemoveNodeRequest) ProtoMessage

func (*RemoveNodeRequest) ProtoMessage()

func (*RemoveNodeRequest) ProtoReflect

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

func (*RemoveNodeRequest) Reset

func (x *RemoveNodeRequest) Reset()

func (*RemoveNodeRequest) String

func (x *RemoveNodeRequest) String() string

type RemoveNodeResponse

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

func (*RemoveNodeResponse) Descriptor deprecated

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

Deprecated: Use RemoveNodeResponse.ProtoReflect.Descriptor instead.

func (*RemoveNodeResponse) GetStatus

func (x *RemoveNodeResponse) GetStatus() string

func (*RemoveNodeResponse) ProtoMessage

func (*RemoveNodeResponse) ProtoMessage()

func (*RemoveNodeResponse) ProtoReflect

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

func (*RemoveNodeResponse) Reset

func (x *RemoveNodeResponse) Reset()

func (*RemoveNodeResponse) String

func (x *RemoveNodeResponse) String() string

type ReportContainerHealthRequest added in v1.1.1

type ReportContainerHealthRequest struct {
	ContainerId          string                 `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Healthy              bool                   `protobuf:"varint,2,opt,name=healthy,proto3" json:"healthy,omitempty"`
	Message              string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	CheckedAt            *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=checked_at,json=checkedAt,proto3" json:"checked_at,omitempty"`
	ConsecutiveFailures  int32                  `protobuf:"varint,5,opt,name=consecutive_failures,json=consecutiveFailures,proto3" json:"consecutive_failures,omitempty"`
	ConsecutiveSuccesses int32                  `protobuf:"varint,6,opt,name=consecutive_successes,json=consecutiveSuccesses,proto3" json:"consecutive_successes,omitempty"`
	// contains filtered or unexported fields
}

Health check messages

func (*ReportContainerHealthRequest) Descriptor deprecated added in v1.1.1

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

Deprecated: Use ReportContainerHealthRequest.ProtoReflect.Descriptor instead.

func (*ReportContainerHealthRequest) GetCheckedAt added in v1.1.1

func (*ReportContainerHealthRequest) GetConsecutiveFailures added in v1.1.1

func (x *ReportContainerHealthRequest) GetConsecutiveFailures() int32

func (*ReportContainerHealthRequest) GetConsecutiveSuccesses added in v1.1.1

func (x *ReportContainerHealthRequest) GetConsecutiveSuccesses() int32

func (*ReportContainerHealthRequest) GetContainerId added in v1.1.1

func (x *ReportContainerHealthRequest) GetContainerId() string

func (*ReportContainerHealthRequest) GetHealthy added in v1.1.1

func (x *ReportContainerHealthRequest) GetHealthy() bool

func (*ReportContainerHealthRequest) GetMessage added in v1.1.1

func (x *ReportContainerHealthRequest) GetMessage() string

func (*ReportContainerHealthRequest) ProtoMessage added in v1.1.1

func (*ReportContainerHealthRequest) ProtoMessage()

func (*ReportContainerHealthRequest) ProtoReflect added in v1.1.1

func (*ReportContainerHealthRequest) Reset added in v1.1.1

func (x *ReportContainerHealthRequest) Reset()

func (*ReportContainerHealthRequest) String added in v1.1.1

type ReportContainerHealthResponse added in v1.1.1

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

func (*ReportContainerHealthResponse) Descriptor deprecated added in v1.1.1

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

Deprecated: Use ReportContainerHealthResponse.ProtoReflect.Descriptor instead.

func (*ReportContainerHealthResponse) GetStatus added in v1.1.1

func (x *ReportContainerHealthResponse) GetStatus() string

func (*ReportContainerHealthResponse) ProtoMessage added in v1.1.1

func (*ReportContainerHealthResponse) ProtoMessage()

func (*ReportContainerHealthResponse) ProtoReflect added in v1.1.1

func (*ReportContainerHealthResponse) Reset added in v1.1.1

func (x *ReportContainerHealthResponse) Reset()

func (*ReportContainerHealthResponse) String added in v1.1.1

type RequestCertificateRequest

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

Certificate messages

func (*RequestCertificateRequest) Descriptor deprecated

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

Deprecated: Use RequestCertificateRequest.ProtoReflect.Descriptor instead.

func (*RequestCertificateRequest) GetNodeId

func (x *RequestCertificateRequest) GetNodeId() string

func (*RequestCertificateRequest) GetToken

func (x *RequestCertificateRequest) GetToken() string

func (*RequestCertificateRequest) ProtoMessage

func (*RequestCertificateRequest) ProtoMessage()

func (*RequestCertificateRequest) ProtoReflect

func (*RequestCertificateRequest) Reset

func (x *RequestCertificateRequest) Reset()

func (*RequestCertificateRequest) String

func (x *RequestCertificateRequest) String() string

type RequestCertificateResponse

type RequestCertificateResponse struct {
	Certificate []byte `protobuf:"bytes,1,opt,name=certificate,proto3" json:"certificate,omitempty"`
	PrivateKey  []byte `protobuf:"bytes,2,opt,name=private_key,json=privateKey,proto3" json:"private_key,omitempty"`
	CaCert      []byte `protobuf:"bytes,3,opt,name=ca_cert,json=caCert,proto3" json:"ca_cert,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestCertificateResponse) Descriptor deprecated

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

Deprecated: Use RequestCertificateResponse.ProtoReflect.Descriptor instead.

func (*RequestCertificateResponse) GetCaCert

func (x *RequestCertificateResponse) GetCaCert() []byte

func (*RequestCertificateResponse) GetCertificate

func (x *RequestCertificateResponse) GetCertificate() []byte

func (*RequestCertificateResponse) GetPrivateKey

func (x *RequestCertificateResponse) GetPrivateKey() []byte

func (*RequestCertificateResponse) ProtoMessage

func (*RequestCertificateResponse) ProtoMessage()

func (*RequestCertificateResponse) ProtoReflect

func (*RequestCertificateResponse) Reset

func (x *RequestCertificateResponse) Reset()

func (*RequestCertificateResponse) String

func (x *RequestCertificateResponse) String() string

type ResourceRequirements

type ResourceRequirements struct {
	CpuShares              int64 `protobuf:"varint,1,opt,name=cpu_shares,json=cpuShares,proto3" json:"cpu_shares,omitempty"`
	MemoryBytes            int64 `protobuf:"varint,2,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	MemoryReservationBytes int64 `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResourceRequirements) Descriptor deprecated

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

Deprecated: Use ResourceRequirements.ProtoReflect.Descriptor instead.

func (*ResourceRequirements) GetCpuShares

func (x *ResourceRequirements) GetCpuShares() int64

func (*ResourceRequirements) GetMemoryBytes

func (x *ResourceRequirements) GetMemoryBytes() int64

func (*ResourceRequirements) GetMemoryReservationBytes

func (x *ResourceRequirements) GetMemoryReservationBytes() int64

func (*ResourceRequirements) ProtoMessage

func (*ResourceRequirements) ProtoMessage()

func (*ResourceRequirements) ProtoReflect

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

func (*ResourceRequirements) Reset

func (x *ResourceRequirements) Reset()

func (*ResourceRequirements) String

func (x *ResourceRequirements) String() string

type RestartPolicy

type RestartPolicy struct {
	Condition    string `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"` // "none", "on-failure", "any"
	MaxAttempts  int32  `protobuf:"varint,2,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	DelaySeconds int32  `protobuf:"varint,3,opt,name=delay_seconds,json=delaySeconds,proto3" json:"delay_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*RestartPolicy) Descriptor deprecated

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

Deprecated: Use RestartPolicy.ProtoReflect.Descriptor instead.

func (*RestartPolicy) GetCondition

func (x *RestartPolicy) GetCondition() string

func (*RestartPolicy) GetDelaySeconds

func (x *RestartPolicy) GetDelaySeconds() int32

func (*RestartPolicy) GetMaxAttempts

func (x *RestartPolicy) GetMaxAttempts() int32

func (*RestartPolicy) ProtoMessage

func (*RestartPolicy) ProtoMessage()

func (*RestartPolicy) ProtoReflect

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

func (*RestartPolicy) Reset

func (x *RestartPolicy) Reset()

func (*RestartPolicy) String

func (x *RestartPolicy) String() string

type RollbackServiceRequest added in v1.3.0

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

func (*RollbackServiceRequest) Descriptor deprecated added in v1.3.0

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

Deprecated: Use RollbackServiceRequest.ProtoReflect.Descriptor instead.

func (*RollbackServiceRequest) GetId added in v1.3.0

func (x *RollbackServiceRequest) GetId() string

func (*RollbackServiceRequest) ProtoMessage added in v1.3.0

func (*RollbackServiceRequest) ProtoMessage()

func (*RollbackServiceRequest) ProtoReflect added in v1.3.0

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

func (*RollbackServiceRequest) Reset added in v1.3.0

func (x *RollbackServiceRequest) Reset()

func (*RollbackServiceRequest) String added in v1.3.0

func (x *RollbackServiceRequest) String() string

type RollbackServiceResponse added in v1.3.0

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

func (*RollbackServiceResponse) Descriptor deprecated added in v1.3.0

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

Deprecated: Use RollbackServiceResponse.ProtoReflect.Descriptor instead.

func (*RollbackServiceResponse) GetStatus added in v1.3.0

func (x *RollbackServiceResponse) GetStatus() string

func (*RollbackServiceResponse) ProtoMessage added in v1.3.0

func (*RollbackServiceResponse) ProtoMessage()

func (*RollbackServiceResponse) ProtoReflect added in v1.3.0

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

func (*RollbackServiceResponse) Reset added in v1.3.0

func (x *RollbackServiceResponse) Reset()

func (*RollbackServiceResponse) String added in v1.3.0

func (x *RollbackServiceResponse) String() string

type Secret

type Secret struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Data      []byte                 `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // Encrypted data (only included in worker retrieval)
	// contains filtered or unexported fields
}

Secret messages

func (*Secret) Descriptor deprecated

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetCreatedAt

func (x *Secret) GetCreatedAt() *timestamppb.Timestamp

func (*Secret) GetData

func (x *Secret) GetData() []byte

func (*Secret) GetId

func (x *Secret) GetId() string

func (*Secret) GetName

func (x *Secret) GetName() string

func (*Secret) ProtoMessage

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect

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

func (*Secret) Reset

func (x *Secret) Reset()

func (*Secret) String

func (x *Secret) String() string

type Service

type Service struct {
	Id             string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name           string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Image          string                 `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	Replicas       int32                  `protobuf:"varint,4,opt,name=replicas,proto3" json:"replicas,omitempty"`
	Mode           string                 `protobuf:"bytes,5,opt,name=mode,proto3" json:"mode,omitempty"`                                           // "replicated" or "global"
	DeployStrategy string                 `protobuf:"bytes,6,opt,name=deploy_strategy,json=deployStrategy,proto3" json:"deploy_strategy,omitempty"` // "rolling", "blue-green", "canary"
	UpdateConfig   *UpdateConfig          `protobuf:"bytes,7,opt,name=update_config,json=updateConfig,proto3" json:"update_config,omitempty"`
	HealthCheck    *HealthCheck           `protobuf:"bytes,8,opt,name=health_check,json=healthCheck,proto3" json:"health_check,omitempty"`
	RestartPolicy  *RestartPolicy         `protobuf:"bytes,9,opt,name=restart_policy,json=restartPolicy,proto3" json:"restart_policy,omitempty"`
	Resources      *ResourceRequirements  `protobuf:"bytes,10,opt,name=resources,proto3" json:"resources,omitempty"`
	Networks       []string               `protobuf:"bytes,11,rep,name=networks,proto3" json:"networks,omitempty"`
	Volumes        []*VolumeMount         `protobuf:"bytes,12,rep,name=volumes,proto3" json:"volumes,omitempty"`
	Env            map[string]string      `` /* 134-byte string literal not displayed */
	Command        []string               `protobuf:"bytes,14,rep,name=command,proto3" json:"command,omitempty"`
	CreatedAt      *timestamppb.Timestamp `protobuf:"bytes,15,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt      *timestamppb.Timestamp `protobuf:"bytes,16,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Ports          []*PortMapping         `protobuf:"bytes,17,rep,name=ports,proto3" json:"ports,omitempty"`                                 // Published ports
	StopTimeout    int32                  `protobuf:"varint,18,opt,name=stop_timeout,json=stopTimeout,proto3" json:"stop_timeout,omitempty"` // Seconds to wait before force-killing (default: 10)
	// contains filtered or unexported fields
}

Service messages

func (*Service) Descriptor deprecated

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetCommand

func (x *Service) GetCommand() []string

func (*Service) GetCreatedAt

func (x *Service) GetCreatedAt() *timestamppb.Timestamp

func (*Service) GetDeployStrategy

func (x *Service) GetDeployStrategy() string

func (*Service) GetEnv

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

func (*Service) GetHealthCheck

func (x *Service) GetHealthCheck() *HealthCheck

func (*Service) GetId

func (x *Service) GetId() string

func (*Service) GetImage

func (x *Service) GetImage() string

func (*Service) GetMode

func (x *Service) GetMode() string

func (*Service) GetName

func (x *Service) GetName() string

func (*Service) GetNetworks

func (x *Service) GetNetworks() []string

func (*Service) GetPorts

func (x *Service) GetPorts() []*PortMapping

func (*Service) GetReplicas

func (x *Service) GetReplicas() int32

func (*Service) GetResources

func (x *Service) GetResources() *ResourceRequirements

func (*Service) GetRestartPolicy

func (x *Service) GetRestartPolicy() *RestartPolicy

func (*Service) GetStopTimeout

func (x *Service) GetStopTimeout() int32

func (*Service) GetUpdateConfig

func (x *Service) GetUpdateConfig() *UpdateConfig

func (*Service) GetUpdatedAt

func (x *Service) GetUpdatedAt() *timestamppb.Timestamp

func (*Service) GetVolumes

func (x *Service) GetVolumes() []*VolumeMount

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) ProtoReflect

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

func (*Service) Reset

func (x *Service) Reset()

func (*Service) String

func (x *Service) String() string

type StreamEventsRequest

type StreamEventsRequest struct {
	EventTypes []string `protobuf:"bytes,1,rep,name=event_types,json=eventTypes,proto3" json:"event_types,omitempty"` // Filter by event types (empty = all events)
	// contains filtered or unexported fields
}

func (*StreamEventsRequest) Descriptor deprecated

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

Deprecated: Use StreamEventsRequest.ProtoReflect.Descriptor instead.

func (*StreamEventsRequest) GetEventTypes

func (x *StreamEventsRequest) GetEventTypes() []string

func (*StreamEventsRequest) ProtoMessage

func (*StreamEventsRequest) ProtoMessage()

func (*StreamEventsRequest) ProtoReflect

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

func (*StreamEventsRequest) Reset

func (x *StreamEventsRequest) Reset()

func (*StreamEventsRequest) String

func (x *StreamEventsRequest) String() string

type TCPHealthCheck

type TCPHealthCheck struct {
	Port int32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"` // Container port to check
	// contains filtered or unexported fields
}

func (*TCPHealthCheck) Descriptor deprecated

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

Deprecated: Use TCPHealthCheck.ProtoReflect.Descriptor instead.

func (*TCPHealthCheck) GetPort

func (x *TCPHealthCheck) GetPort() int32

func (*TCPHealthCheck) ProtoMessage

func (*TCPHealthCheck) ProtoMessage()

func (*TCPHealthCheck) ProtoReflect

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

func (*TCPHealthCheck) Reset

func (x *TCPHealthCheck) Reset()

func (*TCPHealthCheck) String

func (x *TCPHealthCheck) String() string

type TLSCertificate

type TLSCertificate struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Hosts     []string               `protobuf:"bytes,3,rep,name=hosts,proto3" json:"hosts,omitempty"`
	CertPem   []byte                 `protobuf:"bytes,4,opt,name=cert_pem,json=certPem,proto3" json:"cert_pem,omitempty"`
	KeyPem    []byte                 `protobuf:"bytes,5,opt,name=key_pem,json=keyPem,proto3" json:"key_pem,omitempty"`
	Issuer    string                 `protobuf:"bytes,6,opt,name=issuer,proto3" json:"issuer,omitempty"`
	NotBefore *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=not_before,json=notBefore,proto3" json:"not_before,omitempty"`
	NotAfter  *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=not_after,json=notAfter,proto3" json:"not_after,omitempty"`
	AutoRenew bool                   `protobuf:"varint,9,opt,name=auto_renew,json=autoRenew,proto3" json:"auto_renew,omitempty"`
	Labels    map[string]string      `` /* 140-byte string literal not displayed */
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*TLSCertificate) Descriptor deprecated

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

Deprecated: Use TLSCertificate.ProtoReflect.Descriptor instead.

func (*TLSCertificate) GetAutoRenew

func (x *TLSCertificate) GetAutoRenew() bool

func (*TLSCertificate) GetCertPem

func (x *TLSCertificate) GetCertPem() []byte

func (*TLSCertificate) GetCreatedAt

func (x *TLSCertificate) GetCreatedAt() *timestamppb.Timestamp

func (*TLSCertificate) GetHosts

func (x *TLSCertificate) GetHosts() []string

func (*TLSCertificate) GetId

func (x *TLSCertificate) GetId() string

func (*TLSCertificate) GetIssuer

func (x *TLSCertificate) GetIssuer() string

func (*TLSCertificate) GetKeyPem

func (x *TLSCertificate) GetKeyPem() []byte

func (*TLSCertificate) GetLabels

func (x *TLSCertificate) GetLabels() map[string]string

func (*TLSCertificate) GetName

func (x *TLSCertificate) GetName() string

func (*TLSCertificate) GetNotAfter

func (x *TLSCertificate) GetNotAfter() *timestamppb.Timestamp

func (*TLSCertificate) GetNotBefore

func (x *TLSCertificate) GetNotBefore() *timestamppb.Timestamp

func (*TLSCertificate) GetUpdatedAt

func (x *TLSCertificate) GetUpdatedAt() *timestamppb.Timestamp

func (*TLSCertificate) ProtoMessage

func (*TLSCertificate) ProtoMessage()

func (*TLSCertificate) ProtoReflect

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

func (*TLSCertificate) Reset

func (x *TLSCertificate) Reset()

func (*TLSCertificate) String

func (x *TLSCertificate) String() string

type UnimplementedWarrenAPIServer

type UnimplementedWarrenAPIServer struct{}

UnimplementedWarrenAPIServer 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 (UnimplementedWarrenAPIServer) CreateIngress

func (UnimplementedWarrenAPIServer) CreateSecret

func (UnimplementedWarrenAPIServer) CreateService

func (UnimplementedWarrenAPIServer) CreateVolume

func (UnimplementedWarrenAPIServer) DeleteIngress

func (UnimplementedWarrenAPIServer) DeleteSecret

func (UnimplementedWarrenAPIServer) DeleteService

func (UnimplementedWarrenAPIServer) DeleteVolume

func (UnimplementedWarrenAPIServer) GenerateJoinToken

func (UnimplementedWarrenAPIServer) GetClusterInfo

func (UnimplementedWarrenAPIServer) GetContainer added in v1.1.1

func (UnimplementedWarrenAPIServer) GetIngress

func (UnimplementedWarrenAPIServer) GetNode

func (UnimplementedWarrenAPIServer) GetSecretByName

func (UnimplementedWarrenAPIServer) GetService

func (UnimplementedWarrenAPIServer) GetTLSCertificate

func (UnimplementedWarrenAPIServer) GetVolumeByName

func (UnimplementedWarrenAPIServer) Heartbeat

func (UnimplementedWarrenAPIServer) JoinCluster

func (UnimplementedWarrenAPIServer) ListContainers added in v1.1.1

func (UnimplementedWarrenAPIServer) ListIngresses

func (UnimplementedWarrenAPIServer) ListNodes

func (UnimplementedWarrenAPIServer) ListSecrets

func (UnimplementedWarrenAPIServer) ListServices

func (UnimplementedWarrenAPIServer) ListVolumes

func (UnimplementedWarrenAPIServer) RegisterNode

func (UnimplementedWarrenAPIServer) RemoveNode

func (UnimplementedWarrenAPIServer) ReportContainerHealth added in v1.1.1

func (UnimplementedWarrenAPIServer) RollbackService added in v1.3.0

func (UnimplementedWarrenAPIServer) StreamEvents

func (UnimplementedWarrenAPIServer) UpdateContainerStatus added in v1.1.1

func (UnimplementedWarrenAPIServer) UpdateIngress

func (UnimplementedWarrenAPIServer) UpdateService

func (UnimplementedWarrenAPIServer) UpdateServiceImage added in v1.3.0

func (UnimplementedWarrenAPIServer) WatchContainers added in v1.1.1

type UnsafeWarrenAPIServer

type UnsafeWarrenAPIServer interface {
	// contains filtered or unexported methods
}

UnsafeWarrenAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WarrenAPIServer will result in compilation errors.

type UpdateConfig

type UpdateConfig struct {
	Parallelism                   int32   `protobuf:"varint,1,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	DelaySeconds                  int32   `protobuf:"varint,2,opt,name=delay_seconds,json=delaySeconds,proto3" json:"delay_seconds,omitempty"`
	FailureAction                 string  `protobuf:"bytes,3,opt,name=failure_action,json=failureAction,proto3" json:"failure_action,omitempty"` // "pause", "continue", "rollback"
	MaxSurge                      int32   `protobuf:"varint,4,opt,name=max_surge,json=maxSurge,proto3" json:"max_surge,omitempty"`
	MaxUnavailable                int32   `protobuf:"varint,5,opt,name=max_unavailable,json=maxUnavailable,proto3" json:"max_unavailable,omitempty"`
	HealthCheckGracePeriodSeconds int32   `` /* 155-byte string literal not displayed */
	CanaryWeight                  int32   `protobuf:"varint,7,opt,name=canary_weight,json=canaryWeight,proto3" json:"canary_weight,omitempty"`
	CanarySteps                   []int32 `protobuf:"varint,8,rep,packed,name=canary_steps,json=canarySteps,proto3" json:"canary_steps,omitempty"`
	CanaryStabilityWindowSeconds  int32   `` /* 150-byte string literal not displayed */
	BlueGreenGracePeriodSeconds   int32   `` /* 150-byte string literal not displayed */
	AutoRollbackEnabled           bool    `protobuf:"varint,11,opt,name=auto_rollback_enabled,json=autoRollbackEnabled,proto3" json:"auto_rollback_enabled,omitempty"`
	FailureThresholdPercent       int32   `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateConfig) Descriptor deprecated

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

Deprecated: Use UpdateConfig.ProtoReflect.Descriptor instead.

func (*UpdateConfig) GetAutoRollbackEnabled added in v1.3.0

func (x *UpdateConfig) GetAutoRollbackEnabled() bool

func (*UpdateConfig) GetBlueGreenGracePeriodSeconds added in v1.3.0

func (x *UpdateConfig) GetBlueGreenGracePeriodSeconds() int32

func (*UpdateConfig) GetCanaryStabilityWindowSeconds added in v1.3.0

func (x *UpdateConfig) GetCanaryStabilityWindowSeconds() int32

func (*UpdateConfig) GetCanarySteps added in v1.3.0

func (x *UpdateConfig) GetCanarySteps() []int32

func (*UpdateConfig) GetCanaryWeight added in v1.3.0

func (x *UpdateConfig) GetCanaryWeight() int32

func (*UpdateConfig) GetDelaySeconds

func (x *UpdateConfig) GetDelaySeconds() int32

func (*UpdateConfig) GetFailureAction

func (x *UpdateConfig) GetFailureAction() string

func (*UpdateConfig) GetFailureThresholdPercent added in v1.3.0

func (x *UpdateConfig) GetFailureThresholdPercent() int32

func (*UpdateConfig) GetHealthCheckGracePeriodSeconds added in v1.3.0

func (x *UpdateConfig) GetHealthCheckGracePeriodSeconds() int32

func (*UpdateConfig) GetMaxSurge added in v1.3.0

func (x *UpdateConfig) GetMaxSurge() int32

func (*UpdateConfig) GetMaxUnavailable added in v1.3.0

func (x *UpdateConfig) GetMaxUnavailable() int32

func (*UpdateConfig) GetParallelism

func (x *UpdateConfig) GetParallelism() int32

func (*UpdateConfig) ProtoMessage

func (*UpdateConfig) ProtoMessage()

func (*UpdateConfig) ProtoReflect

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

func (*UpdateConfig) Reset

func (x *UpdateConfig) Reset()

func (*UpdateConfig) String

func (x *UpdateConfig) String() string

type UpdateContainerStatusRequest added in v1.1.1

type UpdateContainerStatusRequest struct {
	ContainerId        string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	NodeId             string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ActualState        string `protobuf:"bytes,3,opt,name=actual_state,json=actualState,proto3" json:"actual_state,omitempty"`
	RuntimeContainerId string `protobuf:"bytes,4,opt,name=runtime_container_id,json=runtimeContainerId,proto3" json:"runtime_container_id,omitempty"`
	Error              string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateContainerStatusRequest) Descriptor deprecated added in v1.1.1

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

Deprecated: Use UpdateContainerStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateContainerStatusRequest) GetActualState added in v1.1.1

func (x *UpdateContainerStatusRequest) GetActualState() string

func (*UpdateContainerStatusRequest) GetContainerId added in v1.1.1

func (x *UpdateContainerStatusRequest) GetContainerId() string

func (*UpdateContainerStatusRequest) GetError added in v1.1.1

func (x *UpdateContainerStatusRequest) GetError() string

func (*UpdateContainerStatusRequest) GetNodeId added in v1.1.1

func (x *UpdateContainerStatusRequest) GetNodeId() string

func (*UpdateContainerStatusRequest) GetRuntimeContainerId added in v1.1.1

func (x *UpdateContainerStatusRequest) GetRuntimeContainerId() string

func (*UpdateContainerStatusRequest) ProtoMessage added in v1.1.1

func (*UpdateContainerStatusRequest) ProtoMessage()

func (*UpdateContainerStatusRequest) ProtoReflect added in v1.1.1

func (*UpdateContainerStatusRequest) Reset added in v1.1.1

func (x *UpdateContainerStatusRequest) Reset()

func (*UpdateContainerStatusRequest) String added in v1.1.1

type UpdateContainerStatusResponse added in v1.1.1

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

func (*UpdateContainerStatusResponse) Descriptor deprecated added in v1.1.1

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

Deprecated: Use UpdateContainerStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdateContainerStatusResponse) GetStatus added in v1.1.1

func (x *UpdateContainerStatusResponse) GetStatus() string

func (*UpdateContainerStatusResponse) ProtoMessage added in v1.1.1

func (*UpdateContainerStatusResponse) ProtoMessage()

func (*UpdateContainerStatusResponse) ProtoReflect added in v1.1.1

func (*UpdateContainerStatusResponse) Reset added in v1.1.1

func (x *UpdateContainerStatusResponse) Reset()

func (*UpdateContainerStatusResponse) String added in v1.1.1

type UpdateIngressRequest

type UpdateIngressRequest struct {
	Id     string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name   string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Rules  []*IngressRule    `protobuf:"bytes,3,rep,name=rules,proto3" json:"rules,omitempty"`
	Tls    *IngressTLS       `protobuf:"bytes,4,opt,name=tls,proto3" json:"tls,omitempty"`
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateIngressRequest) Descriptor deprecated

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

Deprecated: Use UpdateIngressRequest.ProtoReflect.Descriptor instead.

func (*UpdateIngressRequest) GetId

func (x *UpdateIngressRequest) GetId() string

func (*UpdateIngressRequest) GetLabels

func (x *UpdateIngressRequest) GetLabels() map[string]string

func (*UpdateIngressRequest) GetName

func (x *UpdateIngressRequest) GetName() string

func (*UpdateIngressRequest) GetRules

func (x *UpdateIngressRequest) GetRules() []*IngressRule

func (*UpdateIngressRequest) GetTls

func (x *UpdateIngressRequest) GetTls() *IngressTLS

func (*UpdateIngressRequest) ProtoMessage

func (*UpdateIngressRequest) ProtoMessage()

func (*UpdateIngressRequest) ProtoReflect

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

func (*UpdateIngressRequest) Reset

func (x *UpdateIngressRequest) Reset()

func (*UpdateIngressRequest) String

func (x *UpdateIngressRequest) String() string

type UpdateIngressResponse

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

func (*UpdateIngressResponse) Descriptor deprecated

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

Deprecated: Use UpdateIngressResponse.ProtoReflect.Descriptor instead.

func (*UpdateIngressResponse) GetIngress

func (x *UpdateIngressResponse) GetIngress() *Ingress

func (*UpdateIngressResponse) ProtoMessage

func (*UpdateIngressResponse) ProtoMessage()

func (*UpdateIngressResponse) ProtoReflect

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

func (*UpdateIngressResponse) Reset

func (x *UpdateIngressResponse) Reset()

func (*UpdateIngressResponse) String

func (x *UpdateIngressResponse) String() string

type UpdateServiceImageRequest added in v1.3.0

type UpdateServiceImageRequest struct {
	Id           string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Image        string        `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Strategy     string        `protobuf:"bytes,3,opt,name=strategy,proto3" json:"strategy,omitempty"` // "rolling", "blue-green", "canary"
	UpdateConfig *UpdateConfig `protobuf:"bytes,4,opt,name=update_config,json=updateConfig,proto3" json:"update_config,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateServiceImageRequest) Descriptor deprecated added in v1.3.0

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

Deprecated: Use UpdateServiceImageRequest.ProtoReflect.Descriptor instead.

func (*UpdateServiceImageRequest) GetId added in v1.3.0

func (x *UpdateServiceImageRequest) GetId() string

func (*UpdateServiceImageRequest) GetImage added in v1.3.0

func (x *UpdateServiceImageRequest) GetImage() string

func (*UpdateServiceImageRequest) GetStrategy added in v1.3.0

func (x *UpdateServiceImageRequest) GetStrategy() string

func (*UpdateServiceImageRequest) GetUpdateConfig added in v1.3.0

func (x *UpdateServiceImageRequest) GetUpdateConfig() *UpdateConfig

func (*UpdateServiceImageRequest) ProtoMessage added in v1.3.0

func (*UpdateServiceImageRequest) ProtoMessage()

func (*UpdateServiceImageRequest) ProtoReflect added in v1.3.0

func (*UpdateServiceImageRequest) Reset added in v1.3.0

func (x *UpdateServiceImageRequest) Reset()

func (*UpdateServiceImageRequest) String added in v1.3.0

func (x *UpdateServiceImageRequest) String() string

type UpdateServiceImageResponse added in v1.3.0

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

func (*UpdateServiceImageResponse) Descriptor deprecated added in v1.3.0

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

Deprecated: Use UpdateServiceImageResponse.ProtoReflect.Descriptor instead.

func (*UpdateServiceImageResponse) GetStatus added in v1.3.0

func (x *UpdateServiceImageResponse) GetStatus() string

func (*UpdateServiceImageResponse) ProtoMessage added in v1.3.0

func (*UpdateServiceImageResponse) ProtoMessage()

func (*UpdateServiceImageResponse) ProtoReflect added in v1.3.0

func (*UpdateServiceImageResponse) Reset added in v1.3.0

func (x *UpdateServiceImageResponse) Reset()

func (*UpdateServiceImageResponse) String added in v1.3.0

func (x *UpdateServiceImageResponse) String() string

type UpdateServiceRequest

type UpdateServiceRequest struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Replicas int32             `protobuf:"varint,2,opt,name=replicas,proto3" json:"replicas,omitempty"`
	Image    string            `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	Env      map[string]string `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateServiceRequest) Descriptor deprecated

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

Deprecated: Use UpdateServiceRequest.ProtoReflect.Descriptor instead.

func (*UpdateServiceRequest) GetEnv

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

func (*UpdateServiceRequest) GetId

func (x *UpdateServiceRequest) GetId() string

func (*UpdateServiceRequest) GetImage

func (x *UpdateServiceRequest) GetImage() string

func (*UpdateServiceRequest) GetReplicas

func (x *UpdateServiceRequest) GetReplicas() int32

func (*UpdateServiceRequest) ProtoMessage

func (*UpdateServiceRequest) ProtoMessage()

func (*UpdateServiceRequest) ProtoReflect

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

func (*UpdateServiceRequest) Reset

func (x *UpdateServiceRequest) Reset()

func (*UpdateServiceRequest) String

func (x *UpdateServiceRequest) String() string

type UpdateServiceResponse

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

func (*UpdateServiceResponse) Descriptor deprecated

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

Deprecated: Use UpdateServiceResponse.ProtoReflect.Descriptor instead.

func (*UpdateServiceResponse) GetService

func (x *UpdateServiceResponse) GetService() *Service

func (*UpdateServiceResponse) ProtoMessage

func (*UpdateServiceResponse) ProtoMessage()

func (*UpdateServiceResponse) ProtoReflect

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

func (*UpdateServiceResponse) Reset

func (x *UpdateServiceResponse) Reset()

func (*UpdateServiceResponse) String

func (x *UpdateServiceResponse) String() string

type Volume

type Volume struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name       string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Driver     string                 `protobuf:"bytes,3,opt,name=driver,proto3" json:"driver,omitempty"`
	DriverOpts map[string]string      `` /* 165-byte string literal not displayed */
	Labels     map[string]string      `` /* 139-byte string literal not displayed */
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	NodeId     string                 `protobuf:"bytes,7,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`          // Node affinity for local volumes
	MountPath  string                 `protobuf:"bytes,8,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"` // Host mount path
	// contains filtered or unexported fields
}

Volume messages

func (*Volume) Descriptor deprecated

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

Deprecated: Use Volume.ProtoReflect.Descriptor instead.

func (*Volume) GetCreatedAt

func (x *Volume) GetCreatedAt() *timestamppb.Timestamp

func (*Volume) GetDriver

func (x *Volume) GetDriver() string

func (*Volume) GetDriverOpts

func (x *Volume) GetDriverOpts() map[string]string

func (*Volume) GetId

func (x *Volume) GetId() string

func (*Volume) GetLabels

func (x *Volume) GetLabels() map[string]string

func (*Volume) GetMountPath

func (x *Volume) GetMountPath() string

func (*Volume) GetName

func (x *Volume) GetName() string

func (*Volume) GetNodeId

func (x *Volume) GetNodeId() string

func (*Volume) ProtoMessage

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect

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

func (*Volume) Reset

func (x *Volume) Reset()

func (*Volume) String

func (x *Volume) String() string

type VolumeMount

type VolumeMount struct {
	Source   string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Target   string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	ReadOnly bool   `protobuf:"varint,3,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeMount) Descriptor deprecated

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

Deprecated: Use VolumeMount.ProtoReflect.Descriptor instead.

func (*VolumeMount) GetReadOnly

func (x *VolumeMount) GetReadOnly() bool

func (*VolumeMount) GetSource

func (x *VolumeMount) GetSource() string

func (*VolumeMount) GetTarget

func (x *VolumeMount) GetTarget() string

func (*VolumeMount) ProtoMessage

func (*VolumeMount) ProtoMessage()

func (*VolumeMount) ProtoReflect

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

func (*VolumeMount) Reset

func (x *VolumeMount) Reset()

func (*VolumeMount) String

func (x *VolumeMount) String() string

type WarrenAPIClient

type WarrenAPIClient interface {
	// Node operations
	RegisterNode(ctx context.Context, in *RegisterNodeRequest, opts ...grpc.CallOption) (*RegisterNodeResponse, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (*ListNodesResponse, error)
	GetNode(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*GetNodeResponse, error)
	RemoveNode(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error)
	// Service operations
	CreateService(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*CreateServiceResponse, error)
	UpdateService(ctx context.Context, in *UpdateServiceRequest, opts ...grpc.CallOption) (*UpdateServiceResponse, error)
	UpdateServiceImage(ctx context.Context, in *UpdateServiceImageRequest, opts ...grpc.CallOption) (*UpdateServiceImageResponse, error)
	RollbackService(ctx context.Context, in *RollbackServiceRequest, opts ...grpc.CallOption) (*RollbackServiceResponse, error)
	DeleteService(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*DeleteServiceResponse, error)
	GetService(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*GetServiceResponse, error)
	ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error)
	// Container operations
	UpdateContainerStatus(ctx context.Context, in *UpdateContainerStatusRequest, opts ...grpc.CallOption) (*UpdateContainerStatusResponse, error)
	ListContainers(ctx context.Context, in *ListContainersRequest, opts ...grpc.CallOption) (*ListContainersResponse, error)
	GetContainer(ctx context.Context, in *GetContainerRequest, opts ...grpc.CallOption) (*GetContainerResponse, error)
	// Container assignment stream (worker watches for assigned containers)
	WatchContainers(ctx context.Context, in *WatchContainersRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ContainerEvent], error)
	// Health check operations
	ReportContainerHealth(ctx context.Context, in *ReportContainerHealthRequest, opts ...grpc.CallOption) (*ReportContainerHealthResponse, error)
	// Secret operations
	CreateSecret(ctx context.Context, in *CreateSecretRequest, opts ...grpc.CallOption) (*CreateSecretResponse, error)
	GetSecretByName(ctx context.Context, in *GetSecretByNameRequest, opts ...grpc.CallOption) (*GetSecretByNameResponse, error)
	DeleteSecret(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*DeleteSecretResponse, error)
	ListSecrets(ctx context.Context, in *ListSecretsRequest, opts ...grpc.CallOption) (*ListSecretsResponse, error)
	// Volume operations
	CreateVolume(ctx context.Context, in *CreateVolumeRequest, opts ...grpc.CallOption) (*CreateVolumeResponse, error)
	GetVolumeByName(ctx context.Context, in *GetVolumeByNameRequest, opts ...grpc.CallOption) (*GetVolumeByNameResponse, error)
	DeleteVolume(ctx context.Context, in *DeleteVolumeRequest, opts ...grpc.CallOption) (*DeleteVolumeResponse, error)
	ListVolumes(ctx context.Context, in *ListVolumesRequest, opts ...grpc.CallOption) (*ListVolumesResponse, error)
	// Cluster operations
	GenerateJoinToken(ctx context.Context, in *GenerateJoinTokenRequest, opts ...grpc.CallOption) (*GenerateJoinTokenResponse, error)
	JoinCluster(ctx context.Context, in *JoinClusterRequest, opts ...grpc.CallOption) (*JoinClusterResponse, error)
	GetClusterInfo(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error)
	// Certificate operations
	RequestCertificate(ctx context.Context, in *RequestCertificateRequest, opts ...grpc.CallOption) (*RequestCertificateResponse, error)
	// Ingress operations
	CreateIngress(ctx context.Context, in *CreateIngressRequest, opts ...grpc.CallOption) (*CreateIngressResponse, error)
	UpdateIngress(ctx context.Context, in *UpdateIngressRequest, opts ...grpc.CallOption) (*UpdateIngressResponse, error)
	DeleteIngress(ctx context.Context, in *DeleteIngressRequest, opts ...grpc.CallOption) (*DeleteIngressResponse, error)
	GetIngress(ctx context.Context, in *GetIngressRequest, opts ...grpc.CallOption) (*GetIngressResponse, error)
	ListIngresses(ctx context.Context, in *ListIngressesRequest, opts ...grpc.CallOption) (*ListIngressesResponse, error)
	// TLS Certificate operations
	CreateTLSCertificate(ctx context.Context, in *CreateTLSCertificateRequest, opts ...grpc.CallOption) (*CreateTLSCertificateResponse, error)
	GetTLSCertificate(ctx context.Context, in *GetTLSCertificateRequest, opts ...grpc.CallOption) (*GetTLSCertificateResponse, error)
	ListTLSCertificates(ctx context.Context, in *ListTLSCertificatesRequest, opts ...grpc.CallOption) (*ListTLSCertificatesResponse, error)
	DeleteTLSCertificate(ctx context.Context, in *DeleteTLSCertificateRequest, opts ...grpc.CallOption) (*DeleteTLSCertificateResponse, error)
	// Event streaming
	StreamEvents(ctx context.Context, in *StreamEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Event], error)
}

WarrenAPIClient is the client API for WarrenAPI 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.

WarrenAPI defines the manager API for workers and CLI

func NewWarrenAPIClient

func NewWarrenAPIClient(cc grpc.ClientConnInterface) WarrenAPIClient

type WarrenAPIServer

type WarrenAPIServer interface {
	// Node operations
	RegisterNode(context.Context, *RegisterNodeRequest) (*RegisterNodeResponse, error)
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)
	GetNode(context.Context, *GetNodeRequest) (*GetNodeResponse, error)
	RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
	// Service operations
	CreateService(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)
	UpdateService(context.Context, *UpdateServiceRequest) (*UpdateServiceResponse, error)
	UpdateServiceImage(context.Context, *UpdateServiceImageRequest) (*UpdateServiceImageResponse, error)
	RollbackService(context.Context, *RollbackServiceRequest) (*RollbackServiceResponse, error)
	DeleteService(context.Context, *DeleteServiceRequest) (*DeleteServiceResponse, error)
	GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error)
	ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
	// Container operations
	UpdateContainerStatus(context.Context, *UpdateContainerStatusRequest) (*UpdateContainerStatusResponse, error)
	ListContainers(context.Context, *ListContainersRequest) (*ListContainersResponse, error)
	GetContainer(context.Context, *GetContainerRequest) (*GetContainerResponse, error)
	// Container assignment stream (worker watches for assigned containers)
	WatchContainers(*WatchContainersRequest, grpc.ServerStreamingServer[ContainerEvent]) error
	// Health check operations
	ReportContainerHealth(context.Context, *ReportContainerHealthRequest) (*ReportContainerHealthResponse, error)
	// Secret operations
	CreateSecret(context.Context, *CreateSecretRequest) (*CreateSecretResponse, error)
	GetSecretByName(context.Context, *GetSecretByNameRequest) (*GetSecretByNameResponse, error)
	DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, error)
	ListSecrets(context.Context, *ListSecretsRequest) (*ListSecretsResponse, error)
	// Volume operations
	CreateVolume(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)
	GetVolumeByName(context.Context, *GetVolumeByNameRequest) (*GetVolumeByNameResponse, error)
	DeleteVolume(context.Context, *DeleteVolumeRequest) (*DeleteVolumeResponse, error)
	ListVolumes(context.Context, *ListVolumesRequest) (*ListVolumesResponse, error)
	// Cluster operations
	GenerateJoinToken(context.Context, *GenerateJoinTokenRequest) (*GenerateJoinTokenResponse, error)
	JoinCluster(context.Context, *JoinClusterRequest) (*JoinClusterResponse, error)
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
	// Certificate operations
	RequestCertificate(context.Context, *RequestCertificateRequest) (*RequestCertificateResponse, error)
	// Ingress operations
	CreateIngress(context.Context, *CreateIngressRequest) (*CreateIngressResponse, error)
	UpdateIngress(context.Context, *UpdateIngressRequest) (*UpdateIngressResponse, error)
	DeleteIngress(context.Context, *DeleteIngressRequest) (*DeleteIngressResponse, error)
	GetIngress(context.Context, *GetIngressRequest) (*GetIngressResponse, error)
	ListIngresses(context.Context, *ListIngressesRequest) (*ListIngressesResponse, error)
	// TLS Certificate operations
	CreateTLSCertificate(context.Context, *CreateTLSCertificateRequest) (*CreateTLSCertificateResponse, error)
	GetTLSCertificate(context.Context, *GetTLSCertificateRequest) (*GetTLSCertificateResponse, error)
	ListTLSCertificates(context.Context, *ListTLSCertificatesRequest) (*ListTLSCertificatesResponse, error)
	DeleteTLSCertificate(context.Context, *DeleteTLSCertificateRequest) (*DeleteTLSCertificateResponse, error)
	// Event streaming
	StreamEvents(*StreamEventsRequest, grpc.ServerStreamingServer[Event]) error
	// contains filtered or unexported methods
}

WarrenAPIServer is the server API for WarrenAPI service. All implementations must embed UnimplementedWarrenAPIServer for forward compatibility.

WarrenAPI defines the manager API for workers and CLI

type WarrenAPI_StreamEventsClient

type WarrenAPI_StreamEventsClient = grpc.ServerStreamingClient[Event]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type WarrenAPI_StreamEventsServer

type WarrenAPI_StreamEventsServer = grpc.ServerStreamingServer[Event]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type WarrenAPI_WatchContainersClient added in v1.1.1

type WarrenAPI_WatchContainersClient = grpc.ServerStreamingClient[ContainerEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type WarrenAPI_WatchContainersServer added in v1.1.1

type WarrenAPI_WatchContainersServer = grpc.ServerStreamingServer[ContainerEvent]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type WatchContainersRequest added in v1.1.1

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

func (*WatchContainersRequest) Descriptor deprecated added in v1.1.1

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

Deprecated: Use WatchContainersRequest.ProtoReflect.Descriptor instead.

func (*WatchContainersRequest) GetNodeId added in v1.1.1

func (x *WatchContainersRequest) GetNodeId() string

func (*WatchContainersRequest) ProtoMessage added in v1.1.1

func (*WatchContainersRequest) ProtoMessage()

func (*WatchContainersRequest) ProtoReflect added in v1.1.1

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

func (*WatchContainersRequest) Reset added in v1.1.1

func (x *WatchContainersRequest) Reset()

func (*WatchContainersRequest) String added in v1.1.1

func (x *WatchContainersRequest) String() string

Jump to

Keyboard shortcuts

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