Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterManagerServiceServer(s grpc.ServiceRegistrar, srv ManagerServiceServer)
- func RegisterOperatorServiceServer(s grpc.ServiceRegistrar, srv OperatorServiceServer)
- type GetConfigRequest
- type GetConfigResponse
- func (*GetConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetConfigResponse) GetConfig() *spec.Config
- func (*GetConfigResponse) ProtoMessage()
- func (x *GetConfigResponse) ProtoReflect() protoreflect.Message
- func (x *GetConfigResponse) Reset()
- func (x *GetConfigResponse) String() string
- type ListConfigsRequest
- type ListConfigsResponse
- func (*ListConfigsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListConfigsResponse) GetConfigs() []*spec.Config
- func (*ListConfigsResponse) ProtoMessage()
- func (x *ListConfigsResponse) ProtoReflect() protoreflect.Message
- func (x *ListConfigsResponse) Reset()
- func (x *ListConfigsResponse) String() string
- type ManagerServiceClient
- type ManagerServiceServer
- type MarkForDeletionRequest
- func (*MarkForDeletionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MarkForDeletionRequest) GetName() string
- func (x *MarkForDeletionRequest) GetVersion() uint64
- func (*MarkForDeletionRequest) ProtoMessage()
- func (x *MarkForDeletionRequest) ProtoReflect() protoreflect.Message
- func (x *MarkForDeletionRequest) Reset()
- func (x *MarkForDeletionRequest) String() string
- type MarkForDeletionResponse
- func (*MarkForDeletionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MarkForDeletionResponse) GetName() string
- func (x *MarkForDeletionResponse) GetVersion() uint64
- func (*MarkForDeletionResponse) ProtoMessage()
- func (x *MarkForDeletionResponse) ProtoReflect() protoreflect.Message
- func (x *MarkForDeletionResponse) Reset()
- func (x *MarkForDeletionResponse) String() string
- type MarkNodeForDeletionRequest
- func (*MarkNodeForDeletionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MarkNodeForDeletionRequest) GetCluster() string
- func (x *MarkNodeForDeletionRequest) GetConfig() string
- func (x *MarkNodeForDeletionRequest) GetLoadbalancer() string
- func (x *MarkNodeForDeletionRequest) GetNode() string
- func (x *MarkNodeForDeletionRequest) GetNodepool() string
- func (x *MarkNodeForDeletionRequest) GetShouldDecrementDesiredCapacity() bool
- func (*MarkNodeForDeletionRequest) ProtoMessage()
- func (x *MarkNodeForDeletionRequest) ProtoReflect() protoreflect.Message
- func (x *MarkNodeForDeletionRequest) Reset()
- func (x *MarkNodeForDeletionRequest) String() string
- type MarkNodeForDeletionResponse
- func (*MarkNodeForDeletionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MarkNodeForDeletionResponse) GetTargetSize() int64
- func (*MarkNodeForDeletionResponse) ProtoMessage()
- func (x *MarkNodeForDeletionResponse) ProtoReflect() protoreflect.Message
- func (x *MarkNodeForDeletionResponse) Reset()
- func (x *MarkNodeForDeletionResponse) String() string
- type NodePoolUpdateTargetSizeRequest
- func (*NodePoolUpdateTargetSizeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NodePoolUpdateTargetSizeRequest) GetCluster() string
- func (x *NodePoolUpdateTargetSizeRequest) GetConfig() string
- func (x *NodePoolUpdateTargetSizeRequest) GetLoadbalancer() string
- func (x *NodePoolUpdateTargetSizeRequest) GetNodepool() string
- func (x *NodePoolUpdateTargetSizeRequest) GetTargetSize() int32
- func (*NodePoolUpdateTargetSizeRequest) ProtoMessage()
- func (x *NodePoolUpdateTargetSizeRequest) ProtoReflect() protoreflect.Message
- func (x *NodePoolUpdateTargetSizeRequest) Reset()
- func (x *NodePoolUpdateTargetSizeRequest) String() string
- type NodePoolUpdateTargetSizeResponse
- func (*NodePoolUpdateTargetSizeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NodePoolUpdateTargetSizeResponse) GetTargetSize() int32
- func (*NodePoolUpdateTargetSizeResponse) ProtoMessage()
- func (x *NodePoolUpdateTargetSizeResponse) ProtoReflect() protoreflect.Message
- func (x *NodePoolUpdateTargetSizeResponse) Reset()
- func (x *NodePoolUpdateTargetSizeResponse) String() string
- type OperatorServiceClient
- type OperatorServiceServer
- type SendAutoscalerEventRequest
- func (*SendAutoscalerEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendAutoscalerEventRequest) GetInputManifestName() string
- func (x *SendAutoscalerEventRequest) GetInputManifestNamespace() string
- func (*SendAutoscalerEventRequest) ProtoMessage()
- func (x *SendAutoscalerEventRequest) ProtoReflect() protoreflect.Message
- func (x *SendAutoscalerEventRequest) Reset()
- func (x *SendAutoscalerEventRequest) String() string
- type SendAutoscalerEventResponse
- type UnimplementedManagerServiceServer
- func (UnimplementedManagerServiceServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
- func (UnimplementedManagerServiceServer) ListConfigs(context.Context, *ListConfigsRequest) (*ListConfigsResponse, error)
- func (UnimplementedManagerServiceServer) MarkForDeletion(context.Context, *MarkForDeletionRequest) (*MarkForDeletionResponse, error)
- func (UnimplementedManagerServiceServer) MarkNodeForDeletion(context.Context, *MarkNodeForDeletionRequest) (*MarkNodeForDeletionResponse, error)
- func (UnimplementedManagerServiceServer) NodePoolUpdateTargetSize(context.Context, *NodePoolUpdateTargetSizeRequest) (*NodePoolUpdateTargetSizeResponse, error)
- func (UnimplementedManagerServiceServer) UpsertManifest(context.Context, *UpsertManifestRequest) (*UpsertManifestResponse, error)
- type UnimplementedOperatorServiceServer
- type UnsafeManagerServiceServer
- type UnsafeOperatorServiceServer
- type UpsertManifestRequest
- func (*UpsertManifestRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpsertManifestRequest) GetK8SCtx() *spec.KubernetesContext
- func (x *UpsertManifestRequest) GetManifest() *spec.Manifest
- func (x *UpsertManifestRequest) GetName() string
- func (*UpsertManifestRequest) ProtoMessage()
- func (x *UpsertManifestRequest) ProtoReflect() protoreflect.Message
- func (x *UpsertManifestRequest) Reset()
- func (x *UpsertManifestRequest) String() string
- type UpsertManifestResponse
- func (*UpsertManifestResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpsertManifestResponse) GetName() string
- func (x *UpsertManifestResponse) GetVersion() uint64
- func (*UpsertManifestResponse) ProtoMessage()
- func (x *UpsertManifestResponse) ProtoReflect() protoreflect.Message
- func (x *UpsertManifestResponse) Reset()
- func (x *UpsertManifestResponse) String() string
Constants ¶
const ( ManagerService_UpsertManifest_FullMethodName = "/claudie.ManagerService/UpsertManifest" ManagerService_MarkForDeletion_FullMethodName = "/claudie.ManagerService/MarkForDeletion" ManagerService_MarkNodeForDeletion_FullMethodName = "/claudie.ManagerService/MarkNodeForDeletion" ManagerService_ListConfigs_FullMethodName = "/claudie.ManagerService/ListConfigs" ManagerService_GetConfig_FullMethodName = "/claudie.ManagerService/GetConfig" ManagerService_NodePoolUpdateTargetSize_FullMethodName = "/claudie.ManagerService/NodePoolUpdateTargetSize" )
const (
OperatorService_SendAutoscalerEvent_FullMethodName = "/claudie.OperatorService/SendAutoscalerEvent"
)
Variables ¶
var File_claudie_operator_proto protoreflect.FileDescriptor
var File_manager_proto protoreflect.FileDescriptor
var ManagerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "claudie.ManagerService", HandlerType: (*ManagerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UpsertManifest", Handler: _ManagerService_UpsertManifest_Handler, }, { MethodName: "MarkForDeletion", Handler: _ManagerService_MarkForDeletion_Handler, }, { MethodName: "MarkNodeForDeletion", Handler: _ManagerService_MarkNodeForDeletion_Handler, }, { MethodName: "ListConfigs", Handler: _ManagerService_ListConfigs_Handler, }, { MethodName: "GetConfig", Handler: _ManagerService_GetConfig_Handler, }, { MethodName: "NodePoolUpdateTargetSize", Handler: _ManagerService_NodePoolUpdateTargetSize_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "manager.proto", }
ManagerService_ServiceDesc is the grpc.ServiceDesc for ManagerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var OperatorService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "claudie.OperatorService", HandlerType: (*OperatorServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SendAutoscalerEvent", Handler: _OperatorService_SendAutoscalerEvent_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "claudie-operator.proto", }
OperatorService_ServiceDesc is the grpc.ServiceDesc for OperatorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterManagerServiceServer ¶ added in v0.9.0
func RegisterManagerServiceServer(s grpc.ServiceRegistrar, srv ManagerServiceServer)
func RegisterOperatorServiceServer ¶ added in v0.4.1
func RegisterOperatorServiceServer(s grpc.ServiceRegistrar, srv OperatorServiceServer)
Types ¶
type GetConfigRequest ¶
type GetConfigRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetConfigRequest) Descriptor
deprecated
func (*GetConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.
func (*GetConfigRequest) GetName ¶ added in v0.9.0
func (x *GetConfigRequest) GetName() string
func (*GetConfigRequest) ProtoMessage ¶
func (*GetConfigRequest) ProtoMessage()
func (*GetConfigRequest) ProtoReflect ¶
func (x *GetConfigRequest) ProtoReflect() protoreflect.Message
func (*GetConfigRequest) Reset ¶
func (x *GetConfigRequest) Reset()
func (*GetConfigRequest) String ¶
func (x *GetConfigRequest) String() string
type GetConfigResponse ¶
type GetConfigResponse struct {
Config *spec.Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*GetConfigResponse) Descriptor
deprecated
func (*GetConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetConfigResponse.ProtoReflect.Descriptor instead.
func (*GetConfigResponse) GetConfig ¶
func (x *GetConfigResponse) GetConfig() *spec.Config
func (*GetConfigResponse) ProtoMessage ¶
func (*GetConfigResponse) ProtoMessage()
func (*GetConfigResponse) ProtoReflect ¶
func (x *GetConfigResponse) ProtoReflect() protoreflect.Message
func (*GetConfigResponse) Reset ¶
func (x *GetConfigResponse) Reset()
func (*GetConfigResponse) String ¶
func (x *GetConfigResponse) String() string
type ListConfigsRequest ¶ added in v0.10.0
type ListConfigsRequest struct {
// contains filtered or unexported fields
}
func (*ListConfigsRequest) Descriptor
deprecated
added in
v0.10.0
func (*ListConfigsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListConfigsRequest.ProtoReflect.Descriptor instead.
func (*ListConfigsRequest) ProtoMessage ¶ added in v0.10.0
func (*ListConfigsRequest) ProtoMessage()
func (*ListConfigsRequest) ProtoReflect ¶ added in v0.10.0
func (x *ListConfigsRequest) ProtoReflect() protoreflect.Message
func (*ListConfigsRequest) Reset ¶ added in v0.10.0
func (x *ListConfigsRequest) Reset()
func (*ListConfigsRequest) String ¶ added in v0.10.0
func (x *ListConfigsRequest) String() string
type ListConfigsResponse ¶ added in v0.10.0
type ListConfigsResponse struct {
Configs []*spec.Config `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
// contains filtered or unexported fields
}
func (*ListConfigsResponse) Descriptor
deprecated
added in
v0.10.0
func (*ListConfigsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListConfigsResponse.ProtoReflect.Descriptor instead.
func (*ListConfigsResponse) GetConfigs ¶ added in v0.10.0
func (x *ListConfigsResponse) GetConfigs() []*spec.Config
func (*ListConfigsResponse) ProtoMessage ¶ added in v0.10.0
func (*ListConfigsResponse) ProtoMessage()
func (*ListConfigsResponse) ProtoReflect ¶ added in v0.10.0
func (x *ListConfigsResponse) ProtoReflect() protoreflect.Message
func (*ListConfigsResponse) Reset ¶ added in v0.10.0
func (x *ListConfigsResponse) Reset()
func (*ListConfigsResponse) String ¶ added in v0.10.0
func (x *ListConfigsResponse) String() string
type ManagerServiceClient ¶ added in v0.9.0
type ManagerServiceClient interface {
// UpsertManifest will process the request by either creating a new configuration for the
// given input manifest or updating an existing one.
UpsertManifest(ctx context.Context, in *UpsertManifestRequest, opts ...grpc.CallOption) (*UpsertManifestResponse, error)
// MarkForDeletion will mark the requested configuration to be deleted. Once the
// manager determines the configuration can be deleted it will be deleted.
MarkForDeletion(ctx context.Context, in *MarkForDeletionRequest, opts ...grpc.CallOption) (*MarkForDeletionResponse, error)
// MarkNodeForDeletion will mark the request node for deletion. The node itself
// is not immediately deleted and the Manager service itself will decide when
// the approriate time for deletion will be.
MarkNodeForDeletion(ctx context.Context, in *MarkNodeForDeletionRequest, opts ...grpc.CallOption) (*MarkNodeForDeletionResponse, error)
// ListConfigs will list all stored configuration that the manager manages.
ListConfigs(ctx context.Context, in *ListConfigsRequest, opts ...grpc.CallOption) (*ListConfigsResponse, error)
// GetConfig will retrieve the requested configuration by name.
GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
// NodePoolUpdateTargetSize updates the target size of the nodepool.
NodePoolUpdateTargetSize(ctx context.Context, in *NodePoolUpdateTargetSizeRequest, opts ...grpc.CallOption) (*NodePoolUpdateTargetSizeResponse, error)
}
ManagerServiceClient is the client API for ManagerService 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.
func NewManagerServiceClient ¶ added in v0.9.0
func NewManagerServiceClient(cc grpc.ClientConnInterface) ManagerServiceClient
type ManagerServiceServer ¶ added in v0.9.0
type ManagerServiceServer interface {
// UpsertManifest will process the request by either creating a new configuration for the
// given input manifest or updating an existing one.
UpsertManifest(context.Context, *UpsertManifestRequest) (*UpsertManifestResponse, error)
// MarkForDeletion will mark the requested configuration to be deleted. Once the
// manager determines the configuration can be deleted it will be deleted.
MarkForDeletion(context.Context, *MarkForDeletionRequest) (*MarkForDeletionResponse, error)
// MarkNodeForDeletion will mark the request node for deletion. The node itself
// is not immediately deleted and the Manager service itself will decide when
// the approriate time for deletion will be.
MarkNodeForDeletion(context.Context, *MarkNodeForDeletionRequest) (*MarkNodeForDeletionResponse, error)
// ListConfigs will list all stored configuration that the manager manages.
ListConfigs(context.Context, *ListConfigsRequest) (*ListConfigsResponse, error)
// GetConfig will retrieve the requested configuration by name.
GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
// NodePoolUpdateTargetSize updates the target size of the nodepool.
NodePoolUpdateTargetSize(context.Context, *NodePoolUpdateTargetSizeRequest) (*NodePoolUpdateTargetSizeResponse, error)
// contains filtered or unexported methods
}
ManagerServiceServer is the server API for ManagerService service. All implementations must embed UnimplementedManagerServiceServer for forward compatibility.
type MarkForDeletionRequest ¶ added in v0.9.0
type MarkForDeletionRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*MarkForDeletionRequest) Descriptor
deprecated
added in
v0.9.0
func (*MarkForDeletionRequest) Descriptor() ([]byte, []int)
Deprecated: Use MarkForDeletionRequest.ProtoReflect.Descriptor instead.
func (*MarkForDeletionRequest) GetName ¶ added in v0.9.0
func (x *MarkForDeletionRequest) GetName() string
func (*MarkForDeletionRequest) GetVersion ¶ added in v0.9.0
func (x *MarkForDeletionRequest) GetVersion() uint64
func (*MarkForDeletionRequest) ProtoMessage ¶ added in v0.9.0
func (*MarkForDeletionRequest) ProtoMessage()
func (*MarkForDeletionRequest) ProtoReflect ¶ added in v0.9.0
func (x *MarkForDeletionRequest) ProtoReflect() protoreflect.Message
func (*MarkForDeletionRequest) Reset ¶ added in v0.9.0
func (x *MarkForDeletionRequest) Reset()
func (*MarkForDeletionRequest) String ¶ added in v0.9.0
func (x *MarkForDeletionRequest) String() string
type MarkForDeletionResponse ¶ added in v0.9.0
type MarkForDeletionResponse struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*MarkForDeletionResponse) Descriptor
deprecated
added in
v0.9.0
func (*MarkForDeletionResponse) Descriptor() ([]byte, []int)
Deprecated: Use MarkForDeletionResponse.ProtoReflect.Descriptor instead.
func (*MarkForDeletionResponse) GetName ¶ added in v0.9.0
func (x *MarkForDeletionResponse) GetName() string
func (*MarkForDeletionResponse) GetVersion ¶ added in v0.9.0
func (x *MarkForDeletionResponse) GetVersion() uint64
func (*MarkForDeletionResponse) ProtoMessage ¶ added in v0.9.0
func (*MarkForDeletionResponse) ProtoMessage()
func (*MarkForDeletionResponse) ProtoReflect ¶ added in v0.9.0
func (x *MarkForDeletionResponse) ProtoReflect() protoreflect.Message
func (*MarkForDeletionResponse) Reset ¶ added in v0.9.0
func (x *MarkForDeletionResponse) Reset()
func (*MarkForDeletionResponse) String ¶ added in v0.9.0
func (x *MarkForDeletionResponse) String() string
type MarkNodeForDeletionRequest ¶ added in v0.10.0
type MarkNodeForDeletionRequest struct {
Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
Nodepool string `protobuf:"bytes,3,opt,name=nodepool,proto3" json:"nodepool,omitempty"`
Node string `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`
// If set the node will be searched for in this
// specified loadbalanacer. The passed in [Cluster]
// specifies the kuberentes cluster, but loadbalancers
// are attached to the kubernetes cluster thus the search
// requires the kubernetes cluster id but makes the loadbalancer
// id optional.
Loadbalancer *string `protobuf:"bytes,5,opt,name=loadbalancer,proto3,oneof" json:"loadbalancer,omitempty"`
// This flag only has effect with autoscaled dynamic nodepools,
// if any other nodepool is detected and this parameter is set
// it will be ignored.
//
// Why only for autoscaled nodepools ?
//
// Dynamic and Static nodepools have a fixed desired capacity that
// does not change until explicitly changed in the InputManifest.
// So even if this Api endpoint would allow to decrease the capacity
// for these nodepools on the next iteration of the reconciliation
// loop it would be overwritten by the desired count and effectively
// result in a Noop.
//
// Autoscaled nodepools work within a range of nodes [Min, Max] and
// works with two counters for nodes, 'count' which is the current number
// of nodes within the nodepool and 'targetSize' which is the Target Size
// within [Min, Max] that the NodePool should have. This parameter is
// externally managed, i.e. the desired state does not come from the
// InputManifest, for autoscaled nodepools and thus is also made
// available via this parameter.
//
// This parameter adjusts the 'targetSize' which will result of downscaling.
ShouldDecrementDesiredCapacity *bool `protobuf:"varint,6,opt,name=shouldDecrementDesiredCapacity,proto3,oneof" json:"shouldDecrementDesiredCapacity,omitempty"`
// contains filtered or unexported fields
}
func (*MarkNodeForDeletionRequest) Descriptor
deprecated
added in
v0.10.0
func (*MarkNodeForDeletionRequest) Descriptor() ([]byte, []int)
Deprecated: Use MarkNodeForDeletionRequest.ProtoReflect.Descriptor instead.
func (*MarkNodeForDeletionRequest) GetCluster ¶ added in v0.10.0
func (x *MarkNodeForDeletionRequest) GetCluster() string
func (*MarkNodeForDeletionRequest) GetConfig ¶ added in v0.10.0
func (x *MarkNodeForDeletionRequest) GetConfig() string
func (*MarkNodeForDeletionRequest) GetLoadbalancer ¶ added in v0.10.0
func (x *MarkNodeForDeletionRequest) GetLoadbalancer() string
func (*MarkNodeForDeletionRequest) GetNode ¶ added in v0.10.0
func (x *MarkNodeForDeletionRequest) GetNode() string
func (*MarkNodeForDeletionRequest) GetNodepool ¶ added in v0.10.0
func (x *MarkNodeForDeletionRequest) GetNodepool() string
func (*MarkNodeForDeletionRequest) GetShouldDecrementDesiredCapacity ¶ added in v0.10.0
func (x *MarkNodeForDeletionRequest) GetShouldDecrementDesiredCapacity() bool
func (*MarkNodeForDeletionRequest) ProtoMessage ¶ added in v0.10.0
func (*MarkNodeForDeletionRequest) ProtoMessage()
func (*MarkNodeForDeletionRequest) ProtoReflect ¶ added in v0.10.0
func (x *MarkNodeForDeletionRequest) ProtoReflect() protoreflect.Message
func (*MarkNodeForDeletionRequest) Reset ¶ added in v0.10.0
func (x *MarkNodeForDeletionRequest) Reset()
func (*MarkNodeForDeletionRequest) String ¶ added in v0.10.0
func (x *MarkNodeForDeletionRequest) String() string
type MarkNodeForDeletionResponse ¶ added in v0.10.0
type MarkNodeForDeletionResponse struct {
// The new updated target size.
TargetSize int64 `protobuf:"varint,1,opt,name=targetSize,proto3" json:"targetSize,omitempty"`
// contains filtered or unexported fields
}
func (*MarkNodeForDeletionResponse) Descriptor
deprecated
added in
v0.10.0
func (*MarkNodeForDeletionResponse) Descriptor() ([]byte, []int)
Deprecated: Use MarkNodeForDeletionResponse.ProtoReflect.Descriptor instead.
func (*MarkNodeForDeletionResponse) GetTargetSize ¶ added in v0.10.0
func (x *MarkNodeForDeletionResponse) GetTargetSize() int64
func (*MarkNodeForDeletionResponse) ProtoMessage ¶ added in v0.10.0
func (*MarkNodeForDeletionResponse) ProtoMessage()
func (*MarkNodeForDeletionResponse) ProtoReflect ¶ added in v0.10.0
func (x *MarkNodeForDeletionResponse) ProtoReflect() protoreflect.Message
func (*MarkNodeForDeletionResponse) Reset ¶ added in v0.10.0
func (x *MarkNodeForDeletionResponse) Reset()
func (*MarkNodeForDeletionResponse) String ¶ added in v0.10.0
func (x *MarkNodeForDeletionResponse) String() string
type NodePoolUpdateTargetSizeRequest ¶ added in v0.10.0
type NodePoolUpdateTargetSizeRequest struct {
Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
Nodepool string `protobuf:"bytes,3,opt,name=nodepool,proto3" json:"nodepool,omitempty"`
// If set the node will be searched for in this
// specified loadbalanacer. The passed in [Cluster]
// specifies the kuberentes cluster, but loadbalancers
// are attached to the kubernetes cluster thus the search
// requires the kubernetes cluster id but makes the loadbalancer
// id optional.
Loadbalancer *string `protobuf:"bytes,4,opt,name=loadbalancer,proto3,oneof" json:"loadbalancer,omitempty"`
// Specifies the target size of the nodepool.
//
// For Dynamic and static nodepools this request or value
// will be ignored
//
// Why ?
//
// If this request would change the targetSize it would be
// overwritten on the next reconciliation loop by the desired
// state from the InputManifest which would result in a Noop.
//
// Only for autoscaled nodepools this will have an effect, which
// effectively sets the TargetSize within the [Min, Max] range of
// the autoscaled nodepool.
TargetSize int32 `protobuf:"varint,5,opt,name=targetSize,proto3" json:"targetSize,omitempty"`
// contains filtered or unexported fields
}
func (*NodePoolUpdateTargetSizeRequest) Descriptor
deprecated
added in
v0.10.0
func (*NodePoolUpdateTargetSizeRequest) Descriptor() ([]byte, []int)
Deprecated: Use NodePoolUpdateTargetSizeRequest.ProtoReflect.Descriptor instead.
func (*NodePoolUpdateTargetSizeRequest) GetCluster ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeRequest) GetCluster() string
func (*NodePoolUpdateTargetSizeRequest) GetConfig ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeRequest) GetConfig() string
func (*NodePoolUpdateTargetSizeRequest) GetLoadbalancer ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeRequest) GetLoadbalancer() string
func (*NodePoolUpdateTargetSizeRequest) GetNodepool ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeRequest) GetNodepool() string
func (*NodePoolUpdateTargetSizeRequest) GetTargetSize ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeRequest) GetTargetSize() int32
func (*NodePoolUpdateTargetSizeRequest) ProtoMessage ¶ added in v0.10.0
func (*NodePoolUpdateTargetSizeRequest) ProtoMessage()
func (*NodePoolUpdateTargetSizeRequest) ProtoReflect ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeRequest) ProtoReflect() protoreflect.Message
func (*NodePoolUpdateTargetSizeRequest) Reset ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeRequest) Reset()
func (*NodePoolUpdateTargetSizeRequest) String ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeRequest) String() string
type NodePoolUpdateTargetSizeResponse ¶ added in v0.10.0
type NodePoolUpdateTargetSizeResponse struct {
// The new updated target size.
TargetSize int32 `protobuf:"varint,1,opt,name=targetSize,proto3" json:"targetSize,omitempty"`
// contains filtered or unexported fields
}
func (*NodePoolUpdateTargetSizeResponse) Descriptor
deprecated
added in
v0.10.0
func (*NodePoolUpdateTargetSizeResponse) Descriptor() ([]byte, []int)
Deprecated: Use NodePoolUpdateTargetSizeResponse.ProtoReflect.Descriptor instead.
func (*NodePoolUpdateTargetSizeResponse) GetTargetSize ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeResponse) GetTargetSize() int32
func (*NodePoolUpdateTargetSizeResponse) ProtoMessage ¶ added in v0.10.0
func (*NodePoolUpdateTargetSizeResponse) ProtoMessage()
func (*NodePoolUpdateTargetSizeResponse) ProtoReflect ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeResponse) ProtoReflect() protoreflect.Message
func (*NodePoolUpdateTargetSizeResponse) Reset ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeResponse) Reset()
func (*NodePoolUpdateTargetSizeResponse) String ¶ added in v0.10.0
func (x *NodePoolUpdateTargetSizeResponse) String() string
type OperatorServiceClient ¶ added in v0.4.1
type OperatorServiceClient interface {
// SendAutoscalerEvent sends events to claudie-operator when a scale up/down occurs
SendAutoscalerEvent(ctx context.Context, in *SendAutoscalerEventRequest, opts ...grpc.CallOption) (*SendAutoscalerEventResponse, error)
}
OperatorServiceClient is the client API for OperatorService 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.
func NewOperatorServiceClient ¶ added in v0.4.1
func NewOperatorServiceClient(cc grpc.ClientConnInterface) OperatorServiceClient
type OperatorServiceServer ¶ added in v0.4.1
type OperatorServiceServer interface {
// SendAutoscalerEvent sends events to claudie-operator when a scale up/down occurs
SendAutoscalerEvent(context.Context, *SendAutoscalerEventRequest) (*SendAutoscalerEventResponse, error)
// contains filtered or unexported methods
}
OperatorServiceServer is the server API for OperatorService service. All implementations must embed UnimplementedOperatorServiceServer for forward compatibility.
type SendAutoscalerEventRequest ¶ added in v0.4.1
type SendAutoscalerEventRequest struct {
InputManifestName string `protobuf:"bytes,1,opt,name=InputManifestName,proto3" json:"InputManifestName,omitempty"`
InputManifestNamespace string `protobuf:"bytes,2,opt,name=InputManifestNamespace,proto3" json:"InputManifestNamespace,omitempty"`
// contains filtered or unexported fields
}
func (*SendAutoscalerEventRequest) Descriptor
deprecated
added in
v0.4.1
func (*SendAutoscalerEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendAutoscalerEventRequest.ProtoReflect.Descriptor instead.
func (*SendAutoscalerEventRequest) GetInputManifestName ¶ added in v0.4.1
func (x *SendAutoscalerEventRequest) GetInputManifestName() string
func (*SendAutoscalerEventRequest) GetInputManifestNamespace ¶ added in v0.4.1
func (x *SendAutoscalerEventRequest) GetInputManifestNamespace() string
func (*SendAutoscalerEventRequest) ProtoMessage ¶ added in v0.4.1
func (*SendAutoscalerEventRequest) ProtoMessage()
func (*SendAutoscalerEventRequest) ProtoReflect ¶ added in v0.4.1
func (x *SendAutoscalerEventRequest) ProtoReflect() protoreflect.Message
func (*SendAutoscalerEventRequest) Reset ¶ added in v0.4.1
func (x *SendAutoscalerEventRequest) Reset()
func (*SendAutoscalerEventRequest) String ¶ added in v0.4.1
func (x *SendAutoscalerEventRequest) String() string
type SendAutoscalerEventResponse ¶ added in v0.4.1
type SendAutoscalerEventResponse struct {
// contains filtered or unexported fields
}
func (*SendAutoscalerEventResponse) Descriptor
deprecated
added in
v0.4.1
func (*SendAutoscalerEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use SendAutoscalerEventResponse.ProtoReflect.Descriptor instead.
func (*SendAutoscalerEventResponse) ProtoMessage ¶ added in v0.4.1
func (*SendAutoscalerEventResponse) ProtoMessage()
func (*SendAutoscalerEventResponse) ProtoReflect ¶ added in v0.4.1
func (x *SendAutoscalerEventResponse) ProtoReflect() protoreflect.Message
func (*SendAutoscalerEventResponse) Reset ¶ added in v0.4.1
func (x *SendAutoscalerEventResponse) Reset()
func (*SendAutoscalerEventResponse) String ¶ added in v0.4.1
func (x *SendAutoscalerEventResponse) String() string
type UnimplementedManagerServiceServer ¶ added in v0.9.0
type UnimplementedManagerServiceServer struct{}
UnimplementedManagerServiceServer 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 (UnimplementedManagerServiceServer) GetConfig ¶ added in v0.9.0
func (UnimplementedManagerServiceServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
func (UnimplementedManagerServiceServer) ListConfigs ¶ added in v0.9.0
func (UnimplementedManagerServiceServer) ListConfigs(context.Context, *ListConfigsRequest) (*ListConfigsResponse, error)
func (UnimplementedManagerServiceServer) MarkForDeletion ¶ added in v0.9.0
func (UnimplementedManagerServiceServer) MarkForDeletion(context.Context, *MarkForDeletionRequest) (*MarkForDeletionResponse, error)
func (UnimplementedManagerServiceServer) MarkNodeForDeletion ¶ added in v0.10.0
func (UnimplementedManagerServiceServer) MarkNodeForDeletion(context.Context, *MarkNodeForDeletionRequest) (*MarkNodeForDeletionResponse, error)
func (UnimplementedManagerServiceServer) NodePoolUpdateTargetSize ¶ added in v0.10.0
func (UnimplementedManagerServiceServer) NodePoolUpdateTargetSize(context.Context, *NodePoolUpdateTargetSizeRequest) (*NodePoolUpdateTargetSizeResponse, error)
func (UnimplementedManagerServiceServer) UpsertManifest ¶ added in v0.9.0
func (UnimplementedManagerServiceServer) UpsertManifest(context.Context, *UpsertManifestRequest) (*UpsertManifestResponse, error)
type UnimplementedOperatorServiceServer ¶ added in v0.4.1
type UnimplementedOperatorServiceServer struct{}
UnimplementedOperatorServiceServer 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 (UnimplementedOperatorServiceServer) SendAutoscalerEvent ¶ added in v0.4.1
func (UnimplementedOperatorServiceServer) SendAutoscalerEvent(context.Context, *SendAutoscalerEventRequest) (*SendAutoscalerEventResponse, error)
type UnsafeManagerServiceServer ¶ added in v0.9.0
type UnsafeManagerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeManagerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManagerServiceServer will result in compilation errors.
type UnsafeOperatorServiceServer ¶ added in v0.4.1
type UnsafeOperatorServiceServer interface {
// contains filtered or unexported methods
}
UnsafeOperatorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OperatorServiceServer will result in compilation errors.
type UpsertManifestRequest ¶ added in v0.9.0
type UpsertManifestRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
K8SCtx *spec.KubernetesContext `protobuf:"bytes,2,opt,name=k8sCtx,proto3" json:"k8sCtx,omitempty"`
Manifest *spec.Manifest `protobuf:"bytes,3,opt,name=manifest,proto3" json:"manifest,omitempty"`
// contains filtered or unexported fields
}
func (*UpsertManifestRequest) Descriptor
deprecated
added in
v0.9.0
func (*UpsertManifestRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpsertManifestRequest.ProtoReflect.Descriptor instead.
func (*UpsertManifestRequest) GetK8SCtx ¶ added in v0.9.0
func (x *UpsertManifestRequest) GetK8SCtx() *spec.KubernetesContext
func (*UpsertManifestRequest) GetManifest ¶ added in v0.9.0
func (x *UpsertManifestRequest) GetManifest() *spec.Manifest
func (*UpsertManifestRequest) GetName ¶ added in v0.9.0
func (x *UpsertManifestRequest) GetName() string
func (*UpsertManifestRequest) ProtoMessage ¶ added in v0.9.0
func (*UpsertManifestRequest) ProtoMessage()
func (*UpsertManifestRequest) ProtoReflect ¶ added in v0.9.0
func (x *UpsertManifestRequest) ProtoReflect() protoreflect.Message
func (*UpsertManifestRequest) Reset ¶ added in v0.9.0
func (x *UpsertManifestRequest) Reset()
func (*UpsertManifestRequest) String ¶ added in v0.9.0
func (x *UpsertManifestRequest) String() string
type UpsertManifestResponse ¶ added in v0.9.0
type UpsertManifestResponse struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*UpsertManifestResponse) Descriptor
deprecated
added in
v0.9.0
func (*UpsertManifestResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpsertManifestResponse.ProtoReflect.Descriptor instead.
func (*UpsertManifestResponse) GetName ¶ added in v0.9.0
func (x *UpsertManifestResponse) GetName() string
func (*UpsertManifestResponse) GetVersion ¶ added in v0.9.0
func (x *UpsertManifestResponse) GetVersion() uint64
func (*UpsertManifestResponse) ProtoMessage ¶ added in v0.9.0
func (*UpsertManifestResponse) ProtoMessage()
func (*UpsertManifestResponse) ProtoReflect ¶ added in v0.9.0
func (x *UpsertManifestResponse) ProtoReflect() protoreflect.Message
func (*UpsertManifestResponse) Reset ¶ added in v0.9.0
func (x *UpsertManifestResponse) Reset()
func (*UpsertManifestResponse) String ¶ added in v0.9.0
func (x *UpsertManifestResponse) String() string