pb

package
v0.10.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
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"
)
View Source
const (
	OperatorService_SendAutoscalerEvent_FullMethodName = "/claudie.OperatorService/SendAutoscalerEvent"
)

Variables

View Source
var File_claudie_operator_proto protoreflect.FileDescriptor
View Source
var File_manager_proto protoreflect.FileDescriptor
View Source
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)

View Source
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 (*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 (*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 (*NodePoolUpdateTargetSizeRequest) Reset added in v0.10.0

func (*NodePoolUpdateTargetSizeRequest) String added in v0.10.0

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 (*NodePoolUpdateTargetSizeResponse) Reset added in v0.10.0

func (*NodePoolUpdateTargetSizeResponse) String added in v0.10.0

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 (*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 (*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) ListConfigs added in v0.9.0

func (UnimplementedManagerServiceServer) MarkForDeletion added in v0.9.0

func (UnimplementedManagerServiceServer) MarkNodeForDeletion added in v0.10.0

func (UnimplementedManagerServiceServer) NodePoolUpdateTargetSize added in v0.10.0

func (UnimplementedManagerServiceServer) UpsertManifest added in v0.9.0

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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