Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterWarrenAPIServer(s grpc.ServiceRegistrar, srv WarrenAPIServer)
- type ClusterServer
- func (*ClusterServer) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterServer) GetAddress() string
- func (x *ClusterServer) GetId() string
- func (x *ClusterServer) GetSuffrage() string
- func (*ClusterServer) ProtoMessage()
- func (x *ClusterServer) ProtoReflect() protoreflect.Message
- func (x *ClusterServer) Reset()
- func (x *ClusterServer) String() string
- type Container
- func (*Container) Descriptor() ([]byte, []int)deprecated
- func (x *Container) GetActualState() string
- func (x *Container) GetCommand() []string
- func (x *Container) GetCreatedAt() *timestamppb.Timestamp
- func (x *Container) GetDesiredState() string
- func (x *Container) GetEnv() map[string]string
- func (x *Container) GetError() string
- func (x *Container) GetHealthCheck() *HealthCheck
- func (x *Container) GetId() string
- func (x *Container) GetImage() string
- func (x *Container) GetNodeId() string
- func (x *Container) GetResources() *ResourceRequirements
- func (x *Container) GetRestartPolicy() *RestartPolicy
- func (x *Container) GetRuntimeContainerId() string
- func (x *Container) GetSecrets() []string
- func (x *Container) GetServiceId() string
- func (x *Container) GetServiceName() string
- func (x *Container) GetStopTimeout() int32
- func (x *Container) GetUpdatedAt() *timestamppb.Timestamp
- func (x *Container) GetVolumes() []*VolumeMount
- func (*Container) ProtoMessage()
- func (x *Container) ProtoReflect() protoreflect.Message
- func (x *Container) Reset()
- func (x *Container) String() string
- type ContainerEvent
- func (*ContainerEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerEvent) GetContainer() *Container
- func (x *ContainerEvent) GetType() string
- func (*ContainerEvent) ProtoMessage()
- func (x *ContainerEvent) ProtoReflect() protoreflect.Message
- func (x *ContainerEvent) Reset()
- func (x *ContainerEvent) String() string
- type ContainerStatus
- func (*ContainerStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerStatus) GetActualState() string
- func (x *ContainerStatus) GetContainerId() string
- func (x *ContainerStatus) GetError() string
- func (x *ContainerStatus) GetRuntimeContainerId() string
- func (*ContainerStatus) ProtoMessage()
- func (x *ContainerStatus) ProtoReflect() protoreflect.Message
- func (x *ContainerStatus) Reset()
- func (x *ContainerStatus) String() string
- type CreateIngressRequest
- func (*CreateIngressRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateIngressRequest) GetLabels() map[string]string
- func (x *CreateIngressRequest) GetName() string
- func (x *CreateIngressRequest) GetRules() []*IngressRule
- func (x *CreateIngressRequest) GetTls() *IngressTLS
- func (*CreateIngressRequest) ProtoMessage()
- func (x *CreateIngressRequest) ProtoReflect() protoreflect.Message
- func (x *CreateIngressRequest) Reset()
- func (x *CreateIngressRequest) String() string
- type CreateIngressResponse
- func (*CreateIngressResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateIngressResponse) GetIngress() *Ingress
- func (*CreateIngressResponse) ProtoMessage()
- func (x *CreateIngressResponse) ProtoReflect() protoreflect.Message
- func (x *CreateIngressResponse) Reset()
- func (x *CreateIngressResponse) String() string
- type CreateSecretRequest
- func (*CreateSecretRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSecretRequest) GetData() []byte
- func (x *CreateSecretRequest) GetName() string
- func (*CreateSecretRequest) ProtoMessage()
- func (x *CreateSecretRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSecretRequest) Reset()
- func (x *CreateSecretRequest) String() string
- type CreateSecretResponse
- func (*CreateSecretResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSecretResponse) GetSecret() *Secret
- func (*CreateSecretResponse) ProtoMessage()
- func (x *CreateSecretResponse) ProtoReflect() protoreflect.Message
- func (x *CreateSecretResponse) Reset()
- func (x *CreateSecretResponse) String() string
- type CreateServiceRequest
- func (*CreateServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateServiceRequest) GetCommand() []string
- func (x *CreateServiceRequest) GetDeployStrategy() string
- func (x *CreateServiceRequest) GetEnv() map[string]string
- func (x *CreateServiceRequest) GetHealthCheck() *HealthCheck
- func (x *CreateServiceRequest) GetImage() string
- func (x *CreateServiceRequest) GetMode() string
- func (x *CreateServiceRequest) GetName() string
- func (x *CreateServiceRequest) GetNetworks() []string
- func (x *CreateServiceRequest) GetPorts() []*PortMapping
- func (x *CreateServiceRequest) GetReplicas() int32
- func (x *CreateServiceRequest) GetResources() *ResourceRequirements
- func (x *CreateServiceRequest) GetRestartPolicy() *RestartPolicy
- func (x *CreateServiceRequest) GetStopTimeout() int32
- func (x *CreateServiceRequest) GetUpdateConfig() *UpdateConfig
- func (x *CreateServiceRequest) GetVolumes() []*VolumeMount
- func (*CreateServiceRequest) ProtoMessage()
- func (x *CreateServiceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateServiceRequest) Reset()
- func (x *CreateServiceRequest) String() string
- type CreateServiceResponse
- func (*CreateServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateServiceResponse) GetService() *Service
- func (*CreateServiceResponse) ProtoMessage()
- func (x *CreateServiceResponse) ProtoReflect() protoreflect.Message
- func (x *CreateServiceResponse) Reset()
- func (x *CreateServiceResponse) String() string
- type CreateTLSCertificateRequest
- func (*CreateTLSCertificateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTLSCertificateRequest) GetCertPem() []byte
- func (x *CreateTLSCertificateRequest) GetHosts() []string
- func (x *CreateTLSCertificateRequest) GetKeyPem() []byte
- func (x *CreateTLSCertificateRequest) GetLabels() map[string]string
- func (x *CreateTLSCertificateRequest) GetName() string
- func (*CreateTLSCertificateRequest) ProtoMessage()
- func (x *CreateTLSCertificateRequest) ProtoReflect() protoreflect.Message
- func (x *CreateTLSCertificateRequest) Reset()
- func (x *CreateTLSCertificateRequest) String() string
- type CreateTLSCertificateResponse
- func (*CreateTLSCertificateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTLSCertificateResponse) GetCertificate() *TLSCertificate
- func (*CreateTLSCertificateResponse) ProtoMessage()
- func (x *CreateTLSCertificateResponse) ProtoReflect() protoreflect.Message
- func (x *CreateTLSCertificateResponse) Reset()
- func (x *CreateTLSCertificateResponse) String() string
- type CreateVolumeRequest
- func (*CreateVolumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateVolumeRequest) GetDriver() string
- func (x *CreateVolumeRequest) GetDriverOpts() map[string]string
- func (x *CreateVolumeRequest) GetLabels() map[string]string
- func (x *CreateVolumeRequest) GetName() string
- func (*CreateVolumeRequest) ProtoMessage()
- func (x *CreateVolumeRequest) ProtoReflect() protoreflect.Message
- func (x *CreateVolumeRequest) Reset()
- func (x *CreateVolumeRequest) String() string
- type CreateVolumeResponse
- func (*CreateVolumeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateVolumeResponse) GetVolume() *Volume
- func (*CreateVolumeResponse) ProtoMessage()
- func (x *CreateVolumeResponse) ProtoReflect() protoreflect.Message
- func (x *CreateVolumeResponse) Reset()
- func (x *CreateVolumeResponse) String() string
- type DeleteIngressRequest
- func (*DeleteIngressRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteIngressRequest) GetId() string
- func (x *DeleteIngressRequest) GetName() string
- func (*DeleteIngressRequest) ProtoMessage()
- func (x *DeleteIngressRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteIngressRequest) Reset()
- func (x *DeleteIngressRequest) String() string
- type DeleteIngressResponse
- func (*DeleteIngressResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteIngressResponse) GetStatus() string
- func (*DeleteIngressResponse) ProtoMessage()
- func (x *DeleteIngressResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteIngressResponse) Reset()
- func (x *DeleteIngressResponse) String() string
- type DeleteSecretRequest
- func (*DeleteSecretRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSecretRequest) GetId() string
- func (*DeleteSecretRequest) ProtoMessage()
- func (x *DeleteSecretRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSecretRequest) Reset()
- func (x *DeleteSecretRequest) String() string
- type DeleteSecretResponse
- func (*DeleteSecretResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSecretResponse) GetStatus() string
- func (*DeleteSecretResponse) ProtoMessage()
- func (x *DeleteSecretResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteSecretResponse) Reset()
- func (x *DeleteSecretResponse) String() string
- type DeleteServiceRequest
- func (*DeleteServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteServiceRequest) GetId() string
- func (*DeleteServiceRequest) ProtoMessage()
- func (x *DeleteServiceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteServiceRequest) Reset()
- func (x *DeleteServiceRequest) String() string
- type DeleteServiceResponse
- func (*DeleteServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteServiceResponse) GetStatus() string
- func (*DeleteServiceResponse) ProtoMessage()
- func (x *DeleteServiceResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteServiceResponse) Reset()
- func (x *DeleteServiceResponse) String() string
- type DeleteTLSCertificateRequest
- func (*DeleteTLSCertificateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteTLSCertificateRequest) GetId() string
- func (x *DeleteTLSCertificateRequest) GetName() string
- func (*DeleteTLSCertificateRequest) ProtoMessage()
- func (x *DeleteTLSCertificateRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteTLSCertificateRequest) Reset()
- func (x *DeleteTLSCertificateRequest) String() string
- type DeleteTLSCertificateResponse
- func (*DeleteTLSCertificateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteTLSCertificateResponse) GetStatus() string
- func (*DeleteTLSCertificateResponse) ProtoMessage()
- func (x *DeleteTLSCertificateResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteTLSCertificateResponse) Reset()
- func (x *DeleteTLSCertificateResponse) String() string
- type DeleteVolumeRequest
- func (*DeleteVolumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteVolumeRequest) GetId() string
- func (*DeleteVolumeRequest) ProtoMessage()
- func (x *DeleteVolumeRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteVolumeRequest) Reset()
- func (x *DeleteVolumeRequest) String() string
- type DeleteVolumeResponse
- func (*DeleteVolumeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteVolumeResponse) GetStatus() string
- func (*DeleteVolumeResponse) ProtoMessage()
- func (x *DeleteVolumeResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteVolumeResponse) Reset()
- func (x *DeleteVolumeResponse) String() string
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetId() string
- func (x *Event) GetMessage() string
- func (x *Event) GetMetadata() map[string]string
- func (x *Event) GetTimestamp() *timestamppb.Timestamp
- func (x *Event) GetType() string
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type ExecHealthCheck
- type GenerateJoinTokenRequest
- func (*GenerateJoinTokenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GenerateJoinTokenRequest) GetRole() string
- func (*GenerateJoinTokenRequest) ProtoMessage()
- func (x *GenerateJoinTokenRequest) ProtoReflect() protoreflect.Message
- func (x *GenerateJoinTokenRequest) Reset()
- func (x *GenerateJoinTokenRequest) String() string
- type GenerateJoinTokenResponse
- func (*GenerateJoinTokenResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GenerateJoinTokenResponse) GetExpiresAt() *timestamppb.Timestamp
- func (x *GenerateJoinTokenResponse) GetRole() string
- func (x *GenerateJoinTokenResponse) GetToken() string
- func (*GenerateJoinTokenResponse) ProtoMessage()
- func (x *GenerateJoinTokenResponse) ProtoReflect() protoreflect.Message
- func (x *GenerateJoinTokenResponse) Reset()
- func (x *GenerateJoinTokenResponse) String() string
- type GetClusterInfoRequest
- type GetClusterInfoResponse
- func (*GetClusterInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetClusterInfoResponse) GetLeaderAddr() string
- func (x *GetClusterInfoResponse) GetLeaderId() string
- func (x *GetClusterInfoResponse) GetServers() []*ClusterServer
- func (*GetClusterInfoResponse) ProtoMessage()
- func (x *GetClusterInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetClusterInfoResponse) Reset()
- func (x *GetClusterInfoResponse) String() string
- type GetContainerRequest
- func (*GetContainerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetContainerRequest) GetId() string
- func (*GetContainerRequest) ProtoMessage()
- func (x *GetContainerRequest) ProtoReflect() protoreflect.Message
- func (x *GetContainerRequest) Reset()
- func (x *GetContainerRequest) String() string
- type GetContainerResponse
- func (*GetContainerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetContainerResponse) GetContainer() *Container
- func (*GetContainerResponse) ProtoMessage()
- func (x *GetContainerResponse) ProtoReflect() protoreflect.Message
- func (x *GetContainerResponse) Reset()
- func (x *GetContainerResponse) String() string
- type GetIngressRequest
- func (*GetIngressRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetIngressRequest) GetId() string
- func (x *GetIngressRequest) GetName() string
- func (*GetIngressRequest) ProtoMessage()
- func (x *GetIngressRequest) ProtoReflect() protoreflect.Message
- func (x *GetIngressRequest) Reset()
- func (x *GetIngressRequest) String() string
- type GetIngressResponse
- func (*GetIngressResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetIngressResponse) GetIngress() *Ingress
- func (*GetIngressResponse) ProtoMessage()
- func (x *GetIngressResponse) ProtoReflect() protoreflect.Message
- func (x *GetIngressResponse) Reset()
- func (x *GetIngressResponse) String() string
- type GetNodeRequest
- type GetNodeResponse
- type GetSecretByNameRequest
- func (*GetSecretByNameRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSecretByNameRequest) GetName() string
- func (*GetSecretByNameRequest) ProtoMessage()
- func (x *GetSecretByNameRequest) ProtoReflect() protoreflect.Message
- func (x *GetSecretByNameRequest) Reset()
- func (x *GetSecretByNameRequest) String() string
- type GetSecretByNameResponse
- func (*GetSecretByNameResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSecretByNameResponse) GetSecret() *Secret
- func (*GetSecretByNameResponse) ProtoMessage()
- func (x *GetSecretByNameResponse) ProtoReflect() protoreflect.Message
- func (x *GetSecretByNameResponse) Reset()
- func (x *GetSecretByNameResponse) String() string
- type GetServiceRequest
- func (*GetServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetServiceRequest) GetId() string
- func (x *GetServiceRequest) GetName() string
- func (*GetServiceRequest) ProtoMessage()
- func (x *GetServiceRequest) ProtoReflect() protoreflect.Message
- func (x *GetServiceRequest) Reset()
- func (x *GetServiceRequest) String() string
- type GetServiceResponse
- func (*GetServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetServiceResponse) GetService() *Service
- func (*GetServiceResponse) ProtoMessage()
- func (x *GetServiceResponse) ProtoReflect() protoreflect.Message
- func (x *GetServiceResponse) Reset()
- func (x *GetServiceResponse) String() string
- type GetTLSCertificateRequest
- func (*GetTLSCertificateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTLSCertificateRequest) GetId() string
- func (x *GetTLSCertificateRequest) GetName() string
- func (*GetTLSCertificateRequest) ProtoMessage()
- func (x *GetTLSCertificateRequest) ProtoReflect() protoreflect.Message
- func (x *GetTLSCertificateRequest) Reset()
- func (x *GetTLSCertificateRequest) String() string
- type GetTLSCertificateResponse
- func (*GetTLSCertificateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTLSCertificateResponse) GetCertificate() *TLSCertificate
- func (*GetTLSCertificateResponse) ProtoMessage()
- func (x *GetTLSCertificateResponse) ProtoReflect() protoreflect.Message
- func (x *GetTLSCertificateResponse) Reset()
- func (x *GetTLSCertificateResponse) String() string
- type GetVolumeByNameRequest
- func (*GetVolumeByNameRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetVolumeByNameRequest) GetName() string
- func (*GetVolumeByNameRequest) ProtoMessage()
- func (x *GetVolumeByNameRequest) ProtoReflect() protoreflect.Message
- func (x *GetVolumeByNameRequest) Reset()
- func (x *GetVolumeByNameRequest) String() string
- type GetVolumeByNameResponse
- func (*GetVolumeByNameResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetVolumeByNameResponse) GetVolume() *Volume
- func (*GetVolumeByNameResponse) ProtoMessage()
- func (x *GetVolumeByNameResponse) ProtoReflect() protoreflect.Message
- func (x *GetVolumeByNameResponse) Reset()
- func (x *GetVolumeByNameResponse) String() string
- type HTTPHealthCheck
- func (*HTTPHealthCheck) Descriptor() ([]byte, []int)deprecated
- func (x *HTTPHealthCheck) GetHeaders() []*Header
- func (x *HTTPHealthCheck) GetPath() string
- func (x *HTTPHealthCheck) GetPort() int32
- func (x *HTTPHealthCheck) GetScheme() string
- func (x *HTTPHealthCheck) GetStatusCodeMax() int32
- func (x *HTTPHealthCheck) GetStatusCodeMin() int32
- func (*HTTPHealthCheck) ProtoMessage()
- func (x *HTTPHealthCheck) ProtoReflect() protoreflect.Message
- func (x *HTTPHealthCheck) Reset()
- func (x *HTTPHealthCheck) String() string
- type Header
- type HealthCheck
- func (*HealthCheck) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheck) GetExec() *ExecHealthCheck
- func (x *HealthCheck) GetHttp() *HTTPHealthCheck
- func (x *HealthCheck) GetIntervalSeconds() int32
- func (x *HealthCheck) GetRetries() int32
- func (x *HealthCheck) GetStartPeriodSeconds() int32
- func (x *HealthCheck) GetTcp() *TCPHealthCheck
- func (x *HealthCheck) GetTimeoutSeconds() int32
- func (x *HealthCheck) GetType() HealthCheck_Type
- func (*HealthCheck) ProtoMessage()
- func (x *HealthCheck) ProtoReflect() protoreflect.Message
- func (x *HealthCheck) Reset()
- func (x *HealthCheck) String() string
- type HealthCheck_Type
- func (HealthCheck_Type) Descriptor() protoreflect.EnumDescriptor
- func (x HealthCheck_Type) Enum() *HealthCheck_Type
- func (HealthCheck_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x HealthCheck_Type) Number() protoreflect.EnumNumber
- func (x HealthCheck_Type) String() string
- func (HealthCheck_Type) Type() protoreflect.EnumType
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatRequest) GetAvailableResources() *NodeResources
- func (x *HeartbeatRequest) GetContainerStatuses() []*ContainerStatus
- func (x *HeartbeatRequest) GetNodeId() string
- func (*HeartbeatRequest) ProtoMessage()
- func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
- func (x *HeartbeatRequest) Reset()
- func (x *HeartbeatRequest) String() string
- type HeartbeatResponse
- type Ingress
- func (*Ingress) Descriptor() ([]byte, []int)deprecated
- func (x *Ingress) GetCreatedAt() *timestamppb.Timestamp
- func (x *Ingress) GetId() string
- func (x *Ingress) GetLabels() map[string]string
- func (x *Ingress) GetName() string
- func (x *Ingress) GetRules() []*IngressRule
- func (x *Ingress) GetTls() *IngressTLS
- func (x *Ingress) GetUpdatedAt() *timestamppb.Timestamp
- func (*Ingress) ProtoMessage()
- func (x *Ingress) ProtoReflect() protoreflect.Message
- func (x *Ingress) Reset()
- func (x *Ingress) String() string
- type IngressBackend
- func (*IngressBackend) Descriptor() ([]byte, []int)deprecated
- func (x *IngressBackend) GetPort() int32
- func (x *IngressBackend) GetServiceName() string
- func (*IngressBackend) ProtoMessage()
- func (x *IngressBackend) ProtoReflect() protoreflect.Message
- func (x *IngressBackend) Reset()
- func (x *IngressBackend) String() string
- type IngressPath
- func (*IngressPath) Descriptor() ([]byte, []int)deprecated
- func (x *IngressPath) GetBackend() *IngressBackend
- func (x *IngressPath) GetPath() string
- func (x *IngressPath) GetPathType() string
- func (*IngressPath) ProtoMessage()
- func (x *IngressPath) ProtoReflect() protoreflect.Message
- func (x *IngressPath) Reset()
- func (x *IngressPath) String() string
- type IngressRule
- func (*IngressRule) Descriptor() ([]byte, []int)deprecated
- func (x *IngressRule) GetHost() string
- func (x *IngressRule) GetPaths() []*IngressPath
- func (*IngressRule) ProtoMessage()
- func (x *IngressRule) ProtoReflect() protoreflect.Message
- func (x *IngressRule) Reset()
- func (x *IngressRule) String() string
- type IngressTLS
- func (*IngressTLS) Descriptor() ([]byte, []int)deprecated
- func (x *IngressTLS) GetAutoTls() bool
- func (x *IngressTLS) GetEmail() string
- func (x *IngressTLS) GetEnabled() bool
- func (x *IngressTLS) GetHosts() []string
- func (x *IngressTLS) GetSecretName() string
- func (*IngressTLS) ProtoMessage()
- func (x *IngressTLS) ProtoReflect() protoreflect.Message
- func (x *IngressTLS) Reset()
- func (x *IngressTLS) String() string
- type JoinClusterRequest
- func (*JoinClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JoinClusterRequest) GetBindAddr() string
- func (x *JoinClusterRequest) GetNodeId() string
- func (x *JoinClusterRequest) GetToken() string
- func (*JoinClusterRequest) ProtoMessage()
- func (x *JoinClusterRequest) ProtoReflect() protoreflect.Message
- func (x *JoinClusterRequest) Reset()
- func (x *JoinClusterRequest) String() string
- type JoinClusterResponse
- func (*JoinClusterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JoinClusterResponse) GetLeaderAddr() string
- func (x *JoinClusterResponse) GetStatus() string
- func (*JoinClusterResponse) ProtoMessage()
- func (x *JoinClusterResponse) ProtoReflect() protoreflect.Message
- func (x *JoinClusterResponse) Reset()
- func (x *JoinClusterResponse) String() string
- type ListContainersRequest
- func (*ListContainersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListContainersRequest) GetNodeId() string
- func (x *ListContainersRequest) GetServiceId() string
- func (*ListContainersRequest) ProtoMessage()
- func (x *ListContainersRequest) ProtoReflect() protoreflect.Message
- func (x *ListContainersRequest) Reset()
- func (x *ListContainersRequest) String() string
- type ListContainersResponse
- func (*ListContainersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListContainersResponse) GetContainers() []*Container
- func (*ListContainersResponse) ProtoMessage()
- func (x *ListContainersResponse) ProtoReflect() protoreflect.Message
- func (x *ListContainersResponse) Reset()
- func (x *ListContainersResponse) String() string
- type ListIngressesRequest
- type ListIngressesResponse
- func (*ListIngressesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListIngressesResponse) GetIngresses() []*Ingress
- func (*ListIngressesResponse) ProtoMessage()
- func (x *ListIngressesResponse) ProtoReflect() protoreflect.Message
- func (x *ListIngressesResponse) Reset()
- func (x *ListIngressesResponse) String() string
- type ListNodesRequest
- type ListNodesResponse
- type ListSecretsRequest
- type ListSecretsResponse
- func (*ListSecretsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSecretsResponse) GetSecrets() []*Secret
- func (*ListSecretsResponse) ProtoMessage()
- func (x *ListSecretsResponse) ProtoReflect() protoreflect.Message
- func (x *ListSecretsResponse) Reset()
- func (x *ListSecretsResponse) String() string
- type ListServicesRequest
- type ListServicesResponse
- func (*ListServicesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListServicesResponse) GetServices() []*Service
- func (*ListServicesResponse) ProtoMessage()
- func (x *ListServicesResponse) ProtoReflect() protoreflect.Message
- func (x *ListServicesResponse) Reset()
- func (x *ListServicesResponse) String() string
- type ListTLSCertificatesRequest
- type ListTLSCertificatesResponse
- func (*ListTLSCertificatesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListTLSCertificatesResponse) GetCertificates() []*TLSCertificate
- func (*ListTLSCertificatesResponse) ProtoMessage()
- func (x *ListTLSCertificatesResponse) ProtoReflect() protoreflect.Message
- func (x *ListTLSCertificatesResponse) Reset()
- func (x *ListTLSCertificatesResponse) String() string
- type ListVolumesRequest
- type ListVolumesResponse
- func (*ListVolumesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListVolumesResponse) GetVolumes() []*Volume
- func (*ListVolumesResponse) ProtoMessage()
- func (x *ListVolumesResponse) ProtoReflect() protoreflect.Message
- func (x *ListVolumesResponse) Reset()
- func (x *ListVolumesResponse) String() string
- type Node
- func (*Node) Descriptor() ([]byte, []int)deprecated
- func (x *Node) GetAddress() string
- func (x *Node) GetCreatedAt() *timestamppb.Timestamp
- func (x *Node) GetId() string
- func (x *Node) GetLabels() map[string]string
- func (x *Node) GetLastHeartbeat() *timestamppb.Timestamp
- func (x *Node) GetOverlayIp() string
- func (x *Node) GetResources() *NodeResources
- func (x *Node) GetRole() string
- func (x *Node) GetStatus() string
- func (*Node) ProtoMessage()
- func (x *Node) ProtoReflect() protoreflect.Message
- func (x *Node) Reset()
- func (x *Node) String() string
- type NodeResources
- func (*NodeResources) Descriptor() ([]byte, []int)deprecated
- func (x *NodeResources) GetCpuCores() int64
- func (x *NodeResources) GetDiskBytes() int64
- func (x *NodeResources) GetMemoryBytes() int64
- func (*NodeResources) ProtoMessage()
- func (x *NodeResources) ProtoReflect() protoreflect.Message
- func (x *NodeResources) Reset()
- func (x *NodeResources) String() string
- type PortMapping
- func (*PortMapping) Descriptor() ([]byte, []int)deprecated
- func (x *PortMapping) GetContainerPort() int32
- func (x *PortMapping) GetHostPort() int32
- func (x *PortMapping) GetName() string
- func (x *PortMapping) GetProtocol() string
- func (x *PortMapping) GetPublishMode() PortMapping_PublishMode
- func (*PortMapping) ProtoMessage()
- func (x *PortMapping) ProtoReflect() protoreflect.Message
- func (x *PortMapping) Reset()
- func (x *PortMapping) String() string
- type PortMapping_PublishMode
- func (PortMapping_PublishMode) Descriptor() protoreflect.EnumDescriptor
- func (x PortMapping_PublishMode) Enum() *PortMapping_PublishMode
- func (PortMapping_PublishMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x PortMapping_PublishMode) Number() protoreflect.EnumNumber
- func (x PortMapping_PublishMode) String() string
- func (PortMapping_PublishMode) Type() protoreflect.EnumType
- type RegisterNodeRequest
- func (*RegisterNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterNodeRequest) GetAddress() string
- func (x *RegisterNodeRequest) GetId() string
- func (x *RegisterNodeRequest) GetLabels() map[string]string
- func (x *RegisterNodeRequest) GetResources() *NodeResources
- func (x *RegisterNodeRequest) GetRole() string
- func (*RegisterNodeRequest) ProtoMessage()
- func (x *RegisterNodeRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterNodeRequest) Reset()
- func (x *RegisterNodeRequest) String() string
- type RegisterNodeResponse
- func (*RegisterNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterNodeResponse) GetNode() *Node
- func (x *RegisterNodeResponse) GetOverlayIp() string
- func (*RegisterNodeResponse) ProtoMessage()
- func (x *RegisterNodeResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterNodeResponse) Reset()
- func (x *RegisterNodeResponse) String() string
- type RemoveNodeRequest
- type RemoveNodeResponse
- func (*RemoveNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveNodeResponse) GetStatus() string
- func (*RemoveNodeResponse) ProtoMessage()
- func (x *RemoveNodeResponse) ProtoReflect() protoreflect.Message
- func (x *RemoveNodeResponse) Reset()
- func (x *RemoveNodeResponse) String() string
- type ReportContainerHealthRequest
- func (*ReportContainerHealthRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReportContainerHealthRequest) GetCheckedAt() *timestamppb.Timestamp
- func (x *ReportContainerHealthRequest) GetConsecutiveFailures() int32
- func (x *ReportContainerHealthRequest) GetConsecutiveSuccesses() int32
- func (x *ReportContainerHealthRequest) GetContainerId() string
- func (x *ReportContainerHealthRequest) GetHealthy() bool
- func (x *ReportContainerHealthRequest) GetMessage() string
- func (*ReportContainerHealthRequest) ProtoMessage()
- func (x *ReportContainerHealthRequest) ProtoReflect() protoreflect.Message
- func (x *ReportContainerHealthRequest) Reset()
- func (x *ReportContainerHealthRequest) String() string
- type ReportContainerHealthResponse
- func (*ReportContainerHealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReportContainerHealthResponse) GetStatus() string
- func (*ReportContainerHealthResponse) ProtoMessage()
- func (x *ReportContainerHealthResponse) ProtoReflect() protoreflect.Message
- func (x *ReportContainerHealthResponse) Reset()
- func (x *ReportContainerHealthResponse) String() string
- type RequestCertificateRequest
- func (*RequestCertificateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RequestCertificateRequest) GetNodeId() string
- func (x *RequestCertificateRequest) GetToken() string
- func (*RequestCertificateRequest) ProtoMessage()
- func (x *RequestCertificateRequest) ProtoReflect() protoreflect.Message
- func (x *RequestCertificateRequest) Reset()
- func (x *RequestCertificateRequest) String() string
- type RequestCertificateResponse
- func (*RequestCertificateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RequestCertificateResponse) GetCaCert() []byte
- func (x *RequestCertificateResponse) GetCertificate() []byte
- func (x *RequestCertificateResponse) GetPrivateKey() []byte
- func (*RequestCertificateResponse) ProtoMessage()
- func (x *RequestCertificateResponse) ProtoReflect() protoreflect.Message
- func (x *RequestCertificateResponse) Reset()
- func (x *RequestCertificateResponse) String() string
- type ResourceRequirements
- func (*ResourceRequirements) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceRequirements) GetCpuShares() int64
- func (x *ResourceRequirements) GetMemoryBytes() int64
- func (x *ResourceRequirements) GetMemoryReservationBytes() int64
- func (*ResourceRequirements) ProtoMessage()
- func (x *ResourceRequirements) ProtoReflect() protoreflect.Message
- func (x *ResourceRequirements) Reset()
- func (x *ResourceRequirements) String() string
- type RestartPolicy
- func (*RestartPolicy) Descriptor() ([]byte, []int)deprecated
- func (x *RestartPolicy) GetCondition() string
- func (x *RestartPolicy) GetDelaySeconds() int32
- func (x *RestartPolicy) GetMaxAttempts() int32
- func (*RestartPolicy) ProtoMessage()
- func (x *RestartPolicy) ProtoReflect() protoreflect.Message
- func (x *RestartPolicy) Reset()
- func (x *RestartPolicy) String() string
- type RollbackServiceRequest
- func (*RollbackServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RollbackServiceRequest) GetId() string
- func (*RollbackServiceRequest) ProtoMessage()
- func (x *RollbackServiceRequest) ProtoReflect() protoreflect.Message
- func (x *RollbackServiceRequest) Reset()
- func (x *RollbackServiceRequest) String() string
- type RollbackServiceResponse
- func (*RollbackServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RollbackServiceResponse) GetStatus() string
- func (*RollbackServiceResponse) ProtoMessage()
- func (x *RollbackServiceResponse) ProtoReflect() protoreflect.Message
- func (x *RollbackServiceResponse) Reset()
- func (x *RollbackServiceResponse) String() string
- type Secret
- func (*Secret) Descriptor() ([]byte, []int)deprecated
- func (x *Secret) GetCreatedAt() *timestamppb.Timestamp
- func (x *Secret) GetData() []byte
- func (x *Secret) GetId() string
- func (x *Secret) GetName() string
- func (*Secret) ProtoMessage()
- func (x *Secret) ProtoReflect() protoreflect.Message
- func (x *Secret) Reset()
- func (x *Secret) String() string
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetCommand() []string
- func (x *Service) GetCreatedAt() *timestamppb.Timestamp
- func (x *Service) GetDeployStrategy() string
- func (x *Service) GetEnv() map[string]string
- func (x *Service) GetHealthCheck() *HealthCheck
- func (x *Service) GetId() string
- func (x *Service) GetImage() string
- func (x *Service) GetMode() string
- func (x *Service) GetName() string
- func (x *Service) GetNetworks() []string
- func (x *Service) GetPorts() []*PortMapping
- func (x *Service) GetReplicas() int32
- func (x *Service) GetResources() *ResourceRequirements
- func (x *Service) GetRestartPolicy() *RestartPolicy
- func (x *Service) GetStopTimeout() int32
- func (x *Service) GetUpdateConfig() *UpdateConfig
- func (x *Service) GetUpdatedAt() *timestamppb.Timestamp
- func (x *Service) GetVolumes() []*VolumeMount
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- type StreamEventsRequest
- func (*StreamEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamEventsRequest) GetEventTypes() []string
- func (*StreamEventsRequest) ProtoMessage()
- func (x *StreamEventsRequest) ProtoReflect() protoreflect.Message
- func (x *StreamEventsRequest) Reset()
- func (x *StreamEventsRequest) String() string
- type TCPHealthCheck
- type TLSCertificate
- func (*TLSCertificate) Descriptor() ([]byte, []int)deprecated
- func (x *TLSCertificate) GetAutoRenew() bool
- func (x *TLSCertificate) GetCertPem() []byte
- func (x *TLSCertificate) GetCreatedAt() *timestamppb.Timestamp
- func (x *TLSCertificate) GetHosts() []string
- func (x *TLSCertificate) GetId() string
- func (x *TLSCertificate) GetIssuer() string
- func (x *TLSCertificate) GetKeyPem() []byte
- func (x *TLSCertificate) GetLabels() map[string]string
- func (x *TLSCertificate) GetName() string
- func (x *TLSCertificate) GetNotAfter() *timestamppb.Timestamp
- func (x *TLSCertificate) GetNotBefore() *timestamppb.Timestamp
- func (x *TLSCertificate) GetUpdatedAt() *timestamppb.Timestamp
- func (*TLSCertificate) ProtoMessage()
- func (x *TLSCertificate) ProtoReflect() protoreflect.Message
- func (x *TLSCertificate) Reset()
- func (x *TLSCertificate) String() string
- type UnimplementedWarrenAPIServer
- func (UnimplementedWarrenAPIServer) CreateIngress(context.Context, *CreateIngressRequest) (*CreateIngressResponse, error)
- func (UnimplementedWarrenAPIServer) CreateSecret(context.Context, *CreateSecretRequest) (*CreateSecretResponse, error)
- func (UnimplementedWarrenAPIServer) CreateService(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)
- func (UnimplementedWarrenAPIServer) CreateTLSCertificate(context.Context, *CreateTLSCertificateRequest) (*CreateTLSCertificateResponse, error)
- func (UnimplementedWarrenAPIServer) CreateVolume(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)
- func (UnimplementedWarrenAPIServer) DeleteIngress(context.Context, *DeleteIngressRequest) (*DeleteIngressResponse, error)
- func (UnimplementedWarrenAPIServer) DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, error)
- func (UnimplementedWarrenAPIServer) DeleteService(context.Context, *DeleteServiceRequest) (*DeleteServiceResponse, error)
- func (UnimplementedWarrenAPIServer) DeleteTLSCertificate(context.Context, *DeleteTLSCertificateRequest) (*DeleteTLSCertificateResponse, error)
- func (UnimplementedWarrenAPIServer) DeleteVolume(context.Context, *DeleteVolumeRequest) (*DeleteVolumeResponse, error)
- func (UnimplementedWarrenAPIServer) GenerateJoinToken(context.Context, *GenerateJoinTokenRequest) (*GenerateJoinTokenResponse, error)
- func (UnimplementedWarrenAPIServer) GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
- func (UnimplementedWarrenAPIServer) GetContainer(context.Context, *GetContainerRequest) (*GetContainerResponse, error)
- func (UnimplementedWarrenAPIServer) GetIngress(context.Context, *GetIngressRequest) (*GetIngressResponse, error)
- func (UnimplementedWarrenAPIServer) GetNode(context.Context, *GetNodeRequest) (*GetNodeResponse, error)
- func (UnimplementedWarrenAPIServer) GetSecretByName(context.Context, *GetSecretByNameRequest) (*GetSecretByNameResponse, error)
- func (UnimplementedWarrenAPIServer) GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error)
- func (UnimplementedWarrenAPIServer) GetTLSCertificate(context.Context, *GetTLSCertificateRequest) (*GetTLSCertificateResponse, error)
- func (UnimplementedWarrenAPIServer) GetVolumeByName(context.Context, *GetVolumeByNameRequest) (*GetVolumeByNameResponse, error)
- func (UnimplementedWarrenAPIServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
- func (UnimplementedWarrenAPIServer) JoinCluster(context.Context, *JoinClusterRequest) (*JoinClusterResponse, error)
- func (UnimplementedWarrenAPIServer) ListContainers(context.Context, *ListContainersRequest) (*ListContainersResponse, error)
- func (UnimplementedWarrenAPIServer) ListIngresses(context.Context, *ListIngressesRequest) (*ListIngressesResponse, error)
- func (UnimplementedWarrenAPIServer) ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)
- func (UnimplementedWarrenAPIServer) ListSecrets(context.Context, *ListSecretsRequest) (*ListSecretsResponse, error)
- func (UnimplementedWarrenAPIServer) ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
- func (UnimplementedWarrenAPIServer) ListTLSCertificates(context.Context, *ListTLSCertificatesRequest) (*ListTLSCertificatesResponse, error)
- func (UnimplementedWarrenAPIServer) ListVolumes(context.Context, *ListVolumesRequest) (*ListVolumesResponse, error)
- func (UnimplementedWarrenAPIServer) RegisterNode(context.Context, *RegisterNodeRequest) (*RegisterNodeResponse, error)
- func (UnimplementedWarrenAPIServer) RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
- func (UnimplementedWarrenAPIServer) ReportContainerHealth(context.Context, *ReportContainerHealthRequest) (*ReportContainerHealthResponse, error)
- func (UnimplementedWarrenAPIServer) RequestCertificate(context.Context, *RequestCertificateRequest) (*RequestCertificateResponse, error)
- func (UnimplementedWarrenAPIServer) RollbackService(context.Context, *RollbackServiceRequest) (*RollbackServiceResponse, error)
- func (UnimplementedWarrenAPIServer) StreamEvents(*StreamEventsRequest, grpc.ServerStreamingServer[Event]) error
- func (UnimplementedWarrenAPIServer) UpdateContainerStatus(context.Context, *UpdateContainerStatusRequest) (*UpdateContainerStatusResponse, error)
- func (UnimplementedWarrenAPIServer) UpdateIngress(context.Context, *UpdateIngressRequest) (*UpdateIngressResponse, error)
- func (UnimplementedWarrenAPIServer) UpdateService(context.Context, *UpdateServiceRequest) (*UpdateServiceResponse, error)
- func (UnimplementedWarrenAPIServer) UpdateServiceImage(context.Context, *UpdateServiceImageRequest) (*UpdateServiceImageResponse, error)
- func (UnimplementedWarrenAPIServer) WatchContainers(*WatchContainersRequest, grpc.ServerStreamingServer[ContainerEvent]) error
- type UnsafeWarrenAPIServer
- type UpdateConfig
- func (*UpdateConfig) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateConfig) GetAutoRollbackEnabled() bool
- func (x *UpdateConfig) GetBlueGreenGracePeriodSeconds() int32
- func (x *UpdateConfig) GetCanaryStabilityWindowSeconds() int32
- func (x *UpdateConfig) GetCanarySteps() []int32
- func (x *UpdateConfig) GetCanaryWeight() int32
- func (x *UpdateConfig) GetDelaySeconds() int32
- func (x *UpdateConfig) GetFailureAction() string
- func (x *UpdateConfig) GetFailureThresholdPercent() int32
- func (x *UpdateConfig) GetHealthCheckGracePeriodSeconds() int32
- func (x *UpdateConfig) GetMaxSurge() int32
- func (x *UpdateConfig) GetMaxUnavailable() int32
- func (x *UpdateConfig) GetParallelism() int32
- func (*UpdateConfig) ProtoMessage()
- func (x *UpdateConfig) ProtoReflect() protoreflect.Message
- func (x *UpdateConfig) Reset()
- func (x *UpdateConfig) String() string
- type UpdateContainerStatusRequest
- func (*UpdateContainerStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateContainerStatusRequest) GetActualState() string
- func (x *UpdateContainerStatusRequest) GetContainerId() string
- func (x *UpdateContainerStatusRequest) GetError() string
- func (x *UpdateContainerStatusRequest) GetNodeId() string
- func (x *UpdateContainerStatusRequest) GetRuntimeContainerId() string
- func (*UpdateContainerStatusRequest) ProtoMessage()
- func (x *UpdateContainerStatusRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateContainerStatusRequest) Reset()
- func (x *UpdateContainerStatusRequest) String() string
- type UpdateContainerStatusResponse
- func (*UpdateContainerStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateContainerStatusResponse) GetStatus() string
- func (*UpdateContainerStatusResponse) ProtoMessage()
- func (x *UpdateContainerStatusResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateContainerStatusResponse) Reset()
- func (x *UpdateContainerStatusResponse) String() string
- type UpdateIngressRequest
- func (*UpdateIngressRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateIngressRequest) GetId() string
- func (x *UpdateIngressRequest) GetLabels() map[string]string
- func (x *UpdateIngressRequest) GetName() string
- func (x *UpdateIngressRequest) GetRules() []*IngressRule
- func (x *UpdateIngressRequest) GetTls() *IngressTLS
- func (*UpdateIngressRequest) ProtoMessage()
- func (x *UpdateIngressRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateIngressRequest) Reset()
- func (x *UpdateIngressRequest) String() string
- type UpdateIngressResponse
- func (*UpdateIngressResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateIngressResponse) GetIngress() *Ingress
- func (*UpdateIngressResponse) ProtoMessage()
- func (x *UpdateIngressResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateIngressResponse) Reset()
- func (x *UpdateIngressResponse) String() string
- type UpdateServiceImageRequest
- func (*UpdateServiceImageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateServiceImageRequest) GetId() string
- func (x *UpdateServiceImageRequest) GetImage() string
- func (x *UpdateServiceImageRequest) GetStrategy() string
- func (x *UpdateServiceImageRequest) GetUpdateConfig() *UpdateConfig
- func (*UpdateServiceImageRequest) ProtoMessage()
- func (x *UpdateServiceImageRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateServiceImageRequest) Reset()
- func (x *UpdateServiceImageRequest) String() string
- type UpdateServiceImageResponse
- func (*UpdateServiceImageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateServiceImageResponse) GetStatus() string
- func (*UpdateServiceImageResponse) ProtoMessage()
- func (x *UpdateServiceImageResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateServiceImageResponse) Reset()
- func (x *UpdateServiceImageResponse) String() string
- type UpdateServiceRequest
- func (*UpdateServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateServiceRequest) GetEnv() map[string]string
- func (x *UpdateServiceRequest) GetId() string
- func (x *UpdateServiceRequest) GetImage() string
- func (x *UpdateServiceRequest) GetReplicas() int32
- func (*UpdateServiceRequest) ProtoMessage()
- func (x *UpdateServiceRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateServiceRequest) Reset()
- func (x *UpdateServiceRequest) String() string
- type UpdateServiceResponse
- func (*UpdateServiceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateServiceResponse) GetService() *Service
- func (*UpdateServiceResponse) ProtoMessage()
- func (x *UpdateServiceResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateServiceResponse) Reset()
- func (x *UpdateServiceResponse) String() string
- type Volume
- func (*Volume) Descriptor() ([]byte, []int)deprecated
- func (x *Volume) GetCreatedAt() *timestamppb.Timestamp
- func (x *Volume) GetDriver() string
- func (x *Volume) GetDriverOpts() map[string]string
- func (x *Volume) GetId() string
- func (x *Volume) GetLabels() map[string]string
- func (x *Volume) GetMountPath() string
- func (x *Volume) GetName() string
- func (x *Volume) GetNodeId() string
- func (*Volume) ProtoMessage()
- func (x *Volume) ProtoReflect() protoreflect.Message
- func (x *Volume) Reset()
- func (x *Volume) String() string
- type VolumeMount
- func (*VolumeMount) Descriptor() ([]byte, []int)deprecated
- func (x *VolumeMount) GetReadOnly() bool
- func (x *VolumeMount) GetSource() string
- func (x *VolumeMount) GetTarget() string
- func (*VolumeMount) ProtoMessage()
- func (x *VolumeMount) ProtoReflect() protoreflect.Message
- func (x *VolumeMount) Reset()
- func (x *VolumeMount) String() string
- type WarrenAPIClient
- type WarrenAPIServer
- type WarrenAPI_StreamEventsClient
- type WarrenAPI_StreamEventsServer
- type WarrenAPI_WatchContainersClient
- type WarrenAPI_WatchContainersServer
- type WatchContainersRequest
- func (*WatchContainersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchContainersRequest) GetNodeId() string
- func (*WatchContainersRequest) ProtoMessage()
- func (x *WatchContainersRequest) ProtoReflect() protoreflect.Message
- func (x *WatchContainersRequest) Reset()
- func (x *WatchContainersRequest) String() string
Constants ¶
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 ¶
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.
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.
var File_api_proto_warren_proto protoreflect.FileDescriptor
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) GetActualState ¶ added in v1.1.1
func (*Container) GetCommand ¶ added in v1.1.1
func (*Container) GetCreatedAt ¶ added in v1.1.1
func (x *Container) GetCreatedAt() *timestamppb.Timestamp
func (*Container) GetDesiredState ¶ added in v1.1.1
func (*Container) GetHealthCheck ¶ added in v1.1.1
func (x *Container) GetHealthCheck() *HealthCheck
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 (*Container) GetSecrets ¶ added in v1.1.1
func (*Container) GetServiceId ¶ added in v1.1.1
func (*Container) GetServiceName ¶ added in v1.1.1
func (*Container) GetStopTimeout ¶ added in v1.1.1
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
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 (x *CreateTLSCertificateRequest) ProtoReflect() protoreflect.Message
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 (x *CreateTLSCertificateResponse) ProtoReflect() protoreflect.Message
func (*CreateTLSCertificateResponse) Reset ¶
func (x *CreateTLSCertificateResponse) Reset()
func (*CreateTLSCertificateResponse) String ¶
func (x *CreateTLSCertificateResponse) String() 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 (x *DeleteTLSCertificateRequest) GetId() string
func (*DeleteTLSCertificateRequest) GetName ¶
func (x *DeleteTLSCertificateRequest) GetName() string
func (*DeleteTLSCertificateRequest) ProtoMessage ¶
func (*DeleteTLSCertificateRequest) ProtoMessage()
func (*DeleteTLSCertificateRequest) ProtoReflect ¶
func (x *DeleteTLSCertificateRequest) ProtoReflect() protoreflect.Message
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 (x *DeleteTLSCertificateResponse) ProtoReflect() protoreflect.Message
func (*DeleteTLSCertificateResponse) Reset ¶
func (x *DeleteTLSCertificateResponse) Reset()
func (*DeleteTLSCertificateResponse) String ¶
func (x *DeleteTLSCertificateResponse) String() 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) GetMessage ¶
func (*Event) GetMetadata ¶
func (*Event) GetTimestamp ¶
func (x *Event) GetTimestamp() *timestamppb.Timestamp
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
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 (x *GenerateJoinTokenResponse) ProtoReflect() protoreflect.Message
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 (x *GetTLSCertificateResponse) ProtoReflect() protoreflect.Message
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 ¶
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) ProtoMessage ¶
func (*Header) ProtoMessage()
func (*Header) ProtoReflect ¶
func (x *Header) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
func (HealthCheck_Type) Enum ¶
func (x HealthCheck_Type) Enum() *HealthCheck_Type
func (HealthCheck_Type) EnumDescriptor
deprecated
func (HealthCheck_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use HealthCheck_Type.Descriptor instead.
func (HealthCheck_Type) Number ¶
func (x HealthCheck_Type) Number() protoreflect.EnumNumber
func (HealthCheck_Type) String ¶
func (x HealthCheck_Type) String() string
func (HealthCheck_Type) Type ¶
func (HealthCheck_Type) Type() protoreflect.EnumType
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) GetCreatedAt ¶
func (x *Ingress) GetCreatedAt() *timestamppb.Timestamp
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
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 (x *ListTLSCertificatesRequest) ProtoReflect() protoreflect.Message
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 (x *ListTLSCertificatesResponse) ProtoReflect() protoreflect.Message
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) GetAddress ¶
func (*Node) GetCreatedAt ¶
func (x *Node) GetCreatedAt() *timestamppb.Timestamp
func (*Node) GetLastHeartbeat ¶
func (x *Node) GetLastHeartbeat() *timestamppb.Timestamp
func (*Node) GetOverlayIp ¶
func (*Node) GetResources ¶
func (x *Node) GetResources() *NodeResources
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
func (PortMapping_PublishMode) Enum ¶
func (x PortMapping_PublishMode) Enum() *PortMapping_PublishMode
func (PortMapping_PublishMode) EnumDescriptor
deprecated
func (PortMapping_PublishMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use PortMapping_PublishMode.Descriptor instead.
func (PortMapping_PublishMode) Number ¶
func (x PortMapping_PublishMode) Number() protoreflect.EnumNumber
func (PortMapping_PublishMode) String ¶
func (x PortMapping_PublishMode) String() string
func (PortMapping_PublishMode) Type ¶
func (PortMapping_PublishMode) Type() protoreflect.EnumType
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 (x *ReportContainerHealthRequest) GetCheckedAt() *timestamppb.Timestamp
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 (x *ReportContainerHealthRequest) ProtoReflect() protoreflect.Message
func (*ReportContainerHealthRequest) Reset ¶ added in v1.1.1
func (x *ReportContainerHealthRequest) Reset()
func (*ReportContainerHealthRequest) String ¶ added in v1.1.1
func (x *ReportContainerHealthRequest) String() string
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 (x *ReportContainerHealthResponse) ProtoReflect() protoreflect.Message
func (*ReportContainerHealthResponse) Reset ¶ added in v1.1.1
func (x *ReportContainerHealthResponse) Reset()
func (*ReportContainerHealthResponse) String ¶ added in v1.1.1
func (x *ReportContainerHealthResponse) String() string
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 (x *RequestCertificateRequest) ProtoReflect() protoreflect.Message
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 (x *RequestCertificateResponse) ProtoReflect() protoreflect.Message
func (*RequestCertificateResponse) Reset ¶
func (x *RequestCertificateResponse) Reset()
func (*RequestCertificateResponse) String ¶
func (x *RequestCertificateResponse) String() string
type ResourceRequirements ¶
type ResourceRequirements struct {
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) GetCreatedAt ¶
func (x *Secret) GetCreatedAt() *timestamppb.Timestamp
func (*Secret) ProtoMessage ¶
func (*Secret) ProtoMessage()
func (*Secret) ProtoReflect ¶
func (x *Secret) ProtoReflect() protoreflect.Message
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) GetCommand ¶
func (*Service) GetCreatedAt ¶
func (x *Service) GetCreatedAt() *timestamppb.Timestamp
func (*Service) GetDeployStrategy ¶
func (*Service) GetHealthCheck ¶
func (x *Service) GetHealthCheck() *HealthCheck
func (*Service) GetNetworks ¶
func (*Service) GetPorts ¶
func (x *Service) GetPorts() []*PortMapping
func (*Service) GetReplicas ¶
func (*Service) GetResources ¶
func (x *Service) GetResources() *ResourceRequirements
func (*Service) GetRestartPolicy ¶
func (x *Service) GetRestartPolicy() *RestartPolicy
func (*Service) GetStopTimeout ¶
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
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) CreateIngress(context.Context, *CreateIngressRequest) (*CreateIngressResponse, error)
func (UnimplementedWarrenAPIServer) CreateSecret ¶
func (UnimplementedWarrenAPIServer) CreateSecret(context.Context, *CreateSecretRequest) (*CreateSecretResponse, error)
func (UnimplementedWarrenAPIServer) CreateService ¶
func (UnimplementedWarrenAPIServer) CreateService(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)
func (UnimplementedWarrenAPIServer) CreateTLSCertificate ¶
func (UnimplementedWarrenAPIServer) CreateTLSCertificate(context.Context, *CreateTLSCertificateRequest) (*CreateTLSCertificateResponse, error)
func (UnimplementedWarrenAPIServer) CreateVolume ¶
func (UnimplementedWarrenAPIServer) CreateVolume(context.Context, *CreateVolumeRequest) (*CreateVolumeResponse, error)
func (UnimplementedWarrenAPIServer) DeleteIngress ¶
func (UnimplementedWarrenAPIServer) DeleteIngress(context.Context, *DeleteIngressRequest) (*DeleteIngressResponse, error)
func (UnimplementedWarrenAPIServer) DeleteSecret ¶
func (UnimplementedWarrenAPIServer) DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, error)
func (UnimplementedWarrenAPIServer) DeleteService ¶
func (UnimplementedWarrenAPIServer) DeleteService(context.Context, *DeleteServiceRequest) (*DeleteServiceResponse, error)
func (UnimplementedWarrenAPIServer) DeleteTLSCertificate ¶
func (UnimplementedWarrenAPIServer) DeleteTLSCertificate(context.Context, *DeleteTLSCertificateRequest) (*DeleteTLSCertificateResponse, error)
func (UnimplementedWarrenAPIServer) DeleteVolume ¶
func (UnimplementedWarrenAPIServer) DeleteVolume(context.Context, *DeleteVolumeRequest) (*DeleteVolumeResponse, error)
func (UnimplementedWarrenAPIServer) GenerateJoinToken ¶
func (UnimplementedWarrenAPIServer) GenerateJoinToken(context.Context, *GenerateJoinTokenRequest) (*GenerateJoinTokenResponse, error)
func (UnimplementedWarrenAPIServer) GetClusterInfo ¶
func (UnimplementedWarrenAPIServer) GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
func (UnimplementedWarrenAPIServer) GetContainer ¶ added in v1.1.1
func (UnimplementedWarrenAPIServer) GetContainer(context.Context, *GetContainerRequest) (*GetContainerResponse, error)
func (UnimplementedWarrenAPIServer) GetIngress ¶
func (UnimplementedWarrenAPIServer) GetIngress(context.Context, *GetIngressRequest) (*GetIngressResponse, error)
func (UnimplementedWarrenAPIServer) GetNode ¶
func (UnimplementedWarrenAPIServer) GetNode(context.Context, *GetNodeRequest) (*GetNodeResponse, error)
func (UnimplementedWarrenAPIServer) GetSecretByName ¶
func (UnimplementedWarrenAPIServer) GetSecretByName(context.Context, *GetSecretByNameRequest) (*GetSecretByNameResponse, error)
func (UnimplementedWarrenAPIServer) GetService ¶
func (UnimplementedWarrenAPIServer) GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error)
func (UnimplementedWarrenAPIServer) GetTLSCertificate ¶
func (UnimplementedWarrenAPIServer) GetTLSCertificate(context.Context, *GetTLSCertificateRequest) (*GetTLSCertificateResponse, error)
func (UnimplementedWarrenAPIServer) GetVolumeByName ¶
func (UnimplementedWarrenAPIServer) GetVolumeByName(context.Context, *GetVolumeByNameRequest) (*GetVolumeByNameResponse, error)
func (UnimplementedWarrenAPIServer) Heartbeat ¶
func (UnimplementedWarrenAPIServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
func (UnimplementedWarrenAPIServer) JoinCluster ¶
func (UnimplementedWarrenAPIServer) JoinCluster(context.Context, *JoinClusterRequest) (*JoinClusterResponse, error)
func (UnimplementedWarrenAPIServer) ListContainers ¶ added in v1.1.1
func (UnimplementedWarrenAPIServer) ListContainers(context.Context, *ListContainersRequest) (*ListContainersResponse, error)
func (UnimplementedWarrenAPIServer) ListIngresses ¶
func (UnimplementedWarrenAPIServer) ListIngresses(context.Context, *ListIngressesRequest) (*ListIngressesResponse, error)
func (UnimplementedWarrenAPIServer) ListNodes ¶
func (UnimplementedWarrenAPIServer) ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)
func (UnimplementedWarrenAPIServer) ListSecrets ¶
func (UnimplementedWarrenAPIServer) ListSecrets(context.Context, *ListSecretsRequest) (*ListSecretsResponse, error)
func (UnimplementedWarrenAPIServer) ListServices ¶
func (UnimplementedWarrenAPIServer) ListServices(context.Context, *ListServicesRequest) (*ListServicesResponse, error)
func (UnimplementedWarrenAPIServer) ListTLSCertificates ¶
func (UnimplementedWarrenAPIServer) ListTLSCertificates(context.Context, *ListTLSCertificatesRequest) (*ListTLSCertificatesResponse, error)
func (UnimplementedWarrenAPIServer) ListVolumes ¶
func (UnimplementedWarrenAPIServer) ListVolumes(context.Context, *ListVolumesRequest) (*ListVolumesResponse, error)
func (UnimplementedWarrenAPIServer) RegisterNode ¶
func (UnimplementedWarrenAPIServer) RegisterNode(context.Context, *RegisterNodeRequest) (*RegisterNodeResponse, error)
func (UnimplementedWarrenAPIServer) RemoveNode ¶
func (UnimplementedWarrenAPIServer) RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
func (UnimplementedWarrenAPIServer) ReportContainerHealth ¶ added in v1.1.1
func (UnimplementedWarrenAPIServer) ReportContainerHealth(context.Context, *ReportContainerHealthRequest) (*ReportContainerHealthResponse, error)
func (UnimplementedWarrenAPIServer) RequestCertificate ¶
func (UnimplementedWarrenAPIServer) RequestCertificate(context.Context, *RequestCertificateRequest) (*RequestCertificateResponse, error)
func (UnimplementedWarrenAPIServer) RollbackService ¶ added in v1.3.0
func (UnimplementedWarrenAPIServer) RollbackService(context.Context, *RollbackServiceRequest) (*RollbackServiceResponse, error)
func (UnimplementedWarrenAPIServer) StreamEvents ¶
func (UnimplementedWarrenAPIServer) StreamEvents(*StreamEventsRequest, grpc.ServerStreamingServer[Event]) error
func (UnimplementedWarrenAPIServer) UpdateContainerStatus ¶ added in v1.1.1
func (UnimplementedWarrenAPIServer) UpdateContainerStatus(context.Context, *UpdateContainerStatusRequest) (*UpdateContainerStatusResponse, error)
func (UnimplementedWarrenAPIServer) UpdateIngress ¶
func (UnimplementedWarrenAPIServer) UpdateIngress(context.Context, *UpdateIngressRequest) (*UpdateIngressResponse, error)
func (UnimplementedWarrenAPIServer) UpdateService ¶
func (UnimplementedWarrenAPIServer) UpdateService(context.Context, *UpdateServiceRequest) (*UpdateServiceResponse, error)
func (UnimplementedWarrenAPIServer) UpdateServiceImage ¶ added in v1.3.0
func (UnimplementedWarrenAPIServer) UpdateServiceImage(context.Context, *UpdateServiceImageRequest) (*UpdateServiceImageResponse, error)
func (UnimplementedWarrenAPIServer) WatchContainers ¶ added in v1.1.1
func (UnimplementedWarrenAPIServer) WatchContainers(*WatchContainersRequest, grpc.ServerStreamingServer[ContainerEvent]) error
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"`
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 (x *UpdateContainerStatusRequest) ProtoReflect() protoreflect.Message
func (*UpdateContainerStatusRequest) Reset ¶ added in v1.1.1
func (x *UpdateContainerStatusRequest) Reset()
func (*UpdateContainerStatusRequest) String ¶ added in v1.1.1
func (x *UpdateContainerStatusRequest) String() string
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 (x *UpdateContainerStatusResponse) ProtoReflect() protoreflect.Message
func (*UpdateContainerStatusResponse) Reset ¶ added in v1.1.1
func (x *UpdateContainerStatusResponse) Reset()
func (*UpdateContainerStatusResponse) String ¶ added in v1.1.1
func (x *UpdateContainerStatusResponse) String() string
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 (x *UpdateServiceImageRequest) ProtoReflect() protoreflect.Message
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 (x *UpdateServiceImageResponse) ProtoReflect() protoreflect.Message
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) GetCreatedAt ¶
func (x *Volume) GetCreatedAt() *timestamppb.Timestamp
func (*Volume) GetDriverOpts ¶
func (*Volume) GetMountPath ¶
func (*Volume) ProtoMessage ¶
func (*Volume) ProtoMessage()
func (*Volume) ProtoReflect ¶
func (x *Volume) ProtoReflect() protoreflect.Message
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