v1

package
v0.0.0-...-2c33cfd Latest Latest
Warning

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

 Go to latest Published: Feb 11, 2025 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClusterService_Get_FullMethodName       = "/nebius.mk8s.v1.ClusterService/Get"
	ClusterService_GetByName_FullMethodName = "/nebius.mk8s.v1.ClusterService/GetByName"
	ClusterService_List_FullMethodName      = "/nebius.mk8s.v1.ClusterService/List"
	ClusterService_Create_FullMethodName    = "/nebius.mk8s.v1.ClusterService/Create"
	ClusterService_Update_FullMethodName    = "/nebius.mk8s.v1.ClusterService/Update"
	ClusterService_Delete_FullMethodName    = "/nebius.mk8s.v1.ClusterService/Delete"
)
View Source 
const (
	NodeGroupService_Get_FullMethodName       = "/nebius.mk8s.v1.NodeGroupService/Get"
	NodeGroupService_GetByName_FullMethodName = "/nebius.mk8s.v1.NodeGroupService/GetByName"
	NodeGroupService_List_FullMethodName      = "/nebius.mk8s.v1.NodeGroupService/List"
	NodeGroupService_Create_FullMethodName    = "/nebius.mk8s.v1.NodeGroupService/Create"
	NodeGroupService_Update_FullMethodName    = "/nebius.mk8s.v1.NodeGroupService/Update"
	NodeGroupService_Delete_FullMethodName    = "/nebius.mk8s.v1.NodeGroupService/Delete"
	NodeGroupService_Upgrade_FullMethodName   = "/nebius.mk8s.v1.NodeGroupService/Upgrade"
)

Variables

View Source 
var (
	ClusterStatus_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PROVISIONING",
		2: "RUNNING",
		3: "DELETING",
	}
	ClusterStatus_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PROVISIONING":      1,
		"RUNNING":           2,
		"DELETING":          3,
	}
)

Enum value maps for ClusterStatus_State.

View Source 
var (
	DiskSpec_DiskType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "NETWORK_SSD",
		2: "NETWORK_HDD",
		3: "NETWORK_SSD_IO_M3",
		4: "NETWORK_SSD_NON_REPLICATED",
	}
	DiskSpec_DiskType_value = map[string]int32{
		"UNSPECIFIED":                0,
		"NETWORK_SSD":                1,
		"NETWORK_HDD":                2,
		"NETWORK_SSD_IO_M3":          3,
		"NETWORK_SSD_NON_REPLICATED": 4,
	}
)

Enum value maps for DiskSpec_DiskType.

View Source 
var (
	AttachedFilesystemSpec_AttachMode_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "READ_ONLY",
		2: "READ_WRITE",
	}
	AttachedFilesystemSpec_AttachMode_value = map[string]int32{
		"UNSPECIFIED": 0,
		"READ_ONLY":   1,
		"READ_WRITE":  2,
	}
)

Enum value maps for AttachedFilesystemSpec_AttachMode.

View Source 
var (
	NodeTaint_Effect_name = map[int32]string{
		0: "EFFECT_UNSPECIFIED",
		1: "NO_EXECUTE",
		2: "NO_SCHEDULE",
		3: "PREFER_NO_SCHEDULE",
	}
	NodeTaint_Effect_value = map[string]int32{
		"EFFECT_UNSPECIFIED": 0,
		"NO_EXECUTE":         1,
		"NO_SCHEDULE":        2,
		"PREFER_NO_SCHEDULE": 3,
	}
)

Enum value maps for NodeTaint_Effect.

View Source 
var (
	NodeGroupStatus_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PROVISIONING",
		2: "RUNNING",
		3: "DELETING",
	}
	NodeGroupStatus_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PROVISIONING":      1,
		"RUNNING":           2,
		"DELETING":          3,
	}
)

Enum value maps for NodeGroupStatus_State.

View Source 
var ClusterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nebius.mk8s.v1.ClusterService",
	HandlerType: (*ClusterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _ClusterService_Get_Handler,
		},
		{
			MethodName: "GetByName",
			Handler:    _ClusterService_GetByName_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ClusterService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _ClusterService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _ClusterService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ClusterService_Delete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nebius/mk8s/v1/cluster_service.proto",
}

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

View Source 
var File_nebius_mk8s_v1_cluster_proto protoreflect.FileDescriptor
View Source 
var File_nebius_mk8s_v1_cluster_service_proto protoreflect.FileDescriptor
View Source 
var File_nebius_mk8s_v1_instance_template_proto protoreflect.FileDescriptor
View Source 
var File_nebius_mk8s_v1_node_group_proto protoreflect.FileDescriptor
View Source 
var File_nebius_mk8s_v1_node_group_service_proto protoreflect.FileDescriptor
View Source 
var File_nebius_mk8s_v1_progress_data_proto protoreflect.FileDescriptor
View Source 
var NodeGroupService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nebius.mk8s.v1.NodeGroupService",
	HandlerType: (*NodeGroupServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _NodeGroupService_Get_Handler,
		},
		{
			MethodName: "GetByName",
			Handler:    _NodeGroupService_GetByName_Handler,
		},
		{
			MethodName: "List",
			Handler:    _NodeGroupService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _NodeGroupService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _NodeGroupService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _NodeGroupService_Delete_Handler,
		},
		{
			MethodName: "Upgrade",
			Handler:    _NodeGroupService_Upgrade_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nebius/mk8s/v1/node_group_service.proto",
}

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

Functions

func RegisterClusterServiceServer 

func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)

func RegisterNodeGroupServiceServer 

func RegisterNodeGroupServiceServer(s grpc.ServiceRegistrar, srv NodeGroupServiceServer)

Types

type AttachedFilesystemSpec 

type AttachedFilesystemSpec struct {
	AttachMode AttachedFilesystemSpec_AttachMode `` /* 146-byte string literal not displayed */
	// Specifies the user-defined identifier, allowing to use it as a device in mount command.
	MountTag string `protobuf:"bytes,2,opt,name=mount_tag,json=mountTag,proto3" json:"mount_tag,omitempty"`
	// Types that are assignable to Type:
	//
	//	*AttachedFilesystemSpec_ExistingFilesystem
	Type isAttachedFilesystemSpec_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*AttachedFilesystemSpec) Descriptor deprecated 

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

Deprecated: Use AttachedFilesystemSpec.ProtoReflect.Descriptor instead.

func (*AttachedFilesystemSpec) GetAttachMode 

func (x *AttachedFilesystemSpec) GetAttachMode() AttachedFilesystemSpec_AttachMode

func (*AttachedFilesystemSpec) GetExistingFilesystem 

func (x *AttachedFilesystemSpec) GetExistingFilesystem() *ExistingFilesystem

func (*AttachedFilesystemSpec) GetMountTag 

func (x *AttachedFilesystemSpec) GetMountTag() string

func (*AttachedFilesystemSpec) GetType 

func (m *AttachedFilesystemSpec) GetType() isAttachedFilesystemSpec_Type

func (*AttachedFilesystemSpec) ProtoMessage 

func (*AttachedFilesystemSpec) ProtoMessage()

func (*AttachedFilesystemSpec) ProtoReflect 

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

func (*AttachedFilesystemSpec) Reset 

func (x *AttachedFilesystemSpec) Reset()

func (*AttachedFilesystemSpec) String 

func (x *AttachedFilesystemSpec) String() string

type AttachedFilesystemSpec_AttachMode 

type AttachedFilesystemSpec_AttachMode int32
const (
	AttachedFilesystemSpec_UNSPECIFIED AttachedFilesystemSpec_AttachMode = 0
	AttachedFilesystemSpec_READ_ONLY   AttachedFilesystemSpec_AttachMode = 1
	AttachedFilesystemSpec_READ_WRITE  AttachedFilesystemSpec_AttachMode = 2
)

func (AttachedFilesystemSpec_AttachMode) Descriptor 

func (AttachedFilesystemSpec_AttachMode) Descriptor() protoreflect.EnumDescriptor

func (AttachedFilesystemSpec_AttachMode) Enum 

func (x AttachedFilesystemSpec_AttachMode) Enum() *AttachedFilesystemSpec_AttachMode

func (AttachedFilesystemSpec_AttachMode) EnumDescriptor deprecated 

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

Deprecated: Use AttachedFilesystemSpec_AttachMode.Descriptor instead.

func (AttachedFilesystemSpec_AttachMode) Number 

func (x AttachedFilesystemSpec_AttachMode) Number() protoreflect.EnumNumber

func (AttachedFilesystemSpec_AttachMode) String 

func (x AttachedFilesystemSpec_AttachMode) String() string

func (AttachedFilesystemSpec_AttachMode) Type 

func (AttachedFilesystemSpec_AttachMode) Type() protoreflect.EnumType

type AttachedFilesystemSpec_ExistingFilesystem 

type AttachedFilesystemSpec_ExistingFilesystem struct {
	ExistingFilesystem *ExistingFilesystem `protobuf:"bytes,3,opt,name=existing_filesystem,json=existingFilesystem,proto3,oneof"`
}

type Cluster 

type Cluster struct {
	Metadata *v1.ResourceMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec     *ClusterSpec         `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	Status   *ClusterStatus       `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetMetadata 

func (x *Cluster) GetMetadata() *v1.ResourceMetadata

func (*Cluster) GetSpec 

func (x *Cluster) GetSpec() *ClusterSpec

func (*Cluster) GetStatus 

func (x *Cluster) GetStatus() *ClusterStatus

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

type ClusterServiceClient 

type ClusterServiceClient interface {
	Get(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
	GetByName(ctx context.Context, in *v1.GetByNameRequest, opts ...grpc.CallOption) (*Cluster, error)
	List(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	Create(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	Update(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	Delete(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error)
}

ClusterServiceClient is the client API for ClusterService 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 NewClusterServiceClient 

func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient

type ClusterServiceServer 

type ClusterServiceServer interface {
	Get(context.Context, *GetClusterRequest) (*Cluster, error)
	GetByName(context.Context, *v1.GetByNameRequest) (*Cluster, error)
	List(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	Create(context.Context, *CreateClusterRequest) (*v1.Operation, error)
	Update(context.Context, *UpdateClusterRequest) (*v1.Operation, error)
	Delete(context.Context, *DeleteClusterRequest) (*v1.Operation, error)
}

ClusterServiceServer is the server API for ClusterService service. All implementations should embed UnimplementedClusterServiceServer for forward compatibility

type ClusterSpec 

type ClusterSpec struct {
	ControlPlane *ControlPlaneSpec `protobuf:"bytes,2,opt,name=control_plane,json=controlPlane,proto3" json:"control_plane,omitempty"`
	// Defines kubernetes network configuration, like IP allocation.
	KubeNetwork *KubeNetworkSpec `protobuf:"bytes,3,opt,name=kube_network,json=kubeNetwork,proto3" json:"kube_network,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterSpec) Descriptor deprecated 

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

Deprecated: Use ClusterSpec.ProtoReflect.Descriptor instead.

func (*ClusterSpec) GetControlPlane 

func (x *ClusterSpec) GetControlPlane() *ControlPlaneSpec

func (*ClusterSpec) GetKubeNetwork 

func (x *ClusterSpec) GetKubeNetwork() *KubeNetworkSpec

func (*ClusterSpec) ProtoMessage 

func (*ClusterSpec) ProtoMessage()

func (*ClusterSpec) ProtoReflect 

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

func (*ClusterSpec) Reset 

func (x *ClusterSpec) Reset()

func (*ClusterSpec) String 

func (x *ClusterSpec) String() string

type ClusterStatus 

type ClusterStatus struct {
	State        ClusterStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=nebius.mk8s.v1.ClusterStatus_State" json:"state,omitempty"`
	ControlPlane *ControlPlaneStatus `protobuf:"bytes,2,opt,name=control_plane,json=controlPlane,proto3" json:"control_plane,omitempty"`
	// Show that changes are in flight
	Reconciling bool `protobuf:"varint,100,opt,name=reconciling,proto3" json:"reconciling,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterStatus) Descriptor deprecated 

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

Deprecated: Use ClusterStatus.ProtoReflect.Descriptor instead.

func (*ClusterStatus) GetControlPlane 

func (x *ClusterStatus) GetControlPlane() *ControlPlaneStatus

func (*ClusterStatus) GetReconciling 

func (x *ClusterStatus) GetReconciling() bool

func (*ClusterStatus) GetState 

func (x *ClusterStatus) GetState() ClusterStatus_State

func (*ClusterStatus) ProtoMessage 

func (*ClusterStatus) ProtoMessage()

func (*ClusterStatus) ProtoReflect 

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

func (*ClusterStatus) Reset 

func (x *ClusterStatus) Reset()

func (*ClusterStatus) String 

func (x *ClusterStatus) String() string

type ClusterStatus_State 

type ClusterStatus_State int32
const (
	ClusterStatus_STATE_UNSPECIFIED ClusterStatus_State = 0
	ClusterStatus_PROVISIONING      ClusterStatus_State = 1
	ClusterStatus_RUNNING           ClusterStatus_State = 2
	ClusterStatus_DELETING          ClusterStatus_State = 3
)

func (ClusterStatus_State) Descriptor 

func (ClusterStatus_State) Descriptor() protoreflect.EnumDescriptor

func (ClusterStatus_State) Enum 

func (x ClusterStatus_State) Enum() *ClusterStatus_State

func (ClusterStatus_State) EnumDescriptor deprecated 

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

Deprecated: Use ClusterStatus_State.Descriptor instead.

func (ClusterStatus_State) Number 

func (x ClusterStatus_State) Number() protoreflect.EnumNumber

func (ClusterStatus_State) String 

func (x ClusterStatus_State) String() string

func (ClusterStatus_State) Type 

func (ClusterStatus_State) Type() protoreflect.EnumType

type ControlPlaneEndpointsSpec 

type ControlPlaneEndpointsSpec struct {

	// Specification of public endpoint for control plane.
	// Set value to empty, to enable it.
	PublicEndpoint *PublicEndpointSpec `protobuf:"bytes,1,opt,name=public_endpoint,json=publicEndpoint,proto3" json:"public_endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlPlaneEndpointsSpec) Descriptor deprecated 

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

Deprecated: Use ControlPlaneEndpointsSpec.ProtoReflect.Descriptor instead.

func (*ControlPlaneEndpointsSpec) GetPublicEndpoint 

func (x *ControlPlaneEndpointsSpec) GetPublicEndpoint() *PublicEndpointSpec

func (*ControlPlaneEndpointsSpec) ProtoMessage 

func (*ControlPlaneEndpointsSpec) ProtoMessage()

func (*ControlPlaneEndpointsSpec) ProtoReflect 

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

func (*ControlPlaneEndpointsSpec) Reset 

func (x *ControlPlaneEndpointsSpec) Reset()

func (*ControlPlaneEndpointsSpec) String 

func (x *ControlPlaneEndpointsSpec) String() string

type ControlPlaneSpec 

type ControlPlaneSpec struct {

	// Desired Kubernetes version of the cluster. For now only acceptable format is
	// `<major>.<minor>` like "1.30". Option for patch version update will be added later.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Nebius VPC Subnet ID where control plane instances will be located.
	// Also will be default NodeGroup subnet.
	SubnetId  string                     `protobuf:"bytes,2,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"`
	Endpoints *ControlPlaneEndpointsSpec `protobuf:"bytes,3,opt,name=endpoints,proto3" json:"endpoints,omitempty"`
	// Number of instances in etcd cluster.
	// 3 by default.
	// Control plane with `etcd_cluster_size: 3` called "Highly Available" ("HA"), because it's Kubernetes API
	// will be available despite a failure of one control plane instance.
	EtcdClusterSize int64 `protobuf:"varint,4,opt,name=etcd_cluster_size,json=etcdClusterSize,proto3" json:"etcd_cluster_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlPlaneSpec) Descriptor deprecated 

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

Deprecated: Use ControlPlaneSpec.ProtoReflect.Descriptor instead.

func (*ControlPlaneSpec) GetEndpoints 

func (x *ControlPlaneSpec) GetEndpoints() *ControlPlaneEndpointsSpec

func (*ControlPlaneSpec) GetEtcdClusterSize 

func (x *ControlPlaneSpec) GetEtcdClusterSize() int64

func (*ControlPlaneSpec) GetSubnetId 

func (x *ControlPlaneSpec) GetSubnetId() string

func (*ControlPlaneSpec) GetVersion 

func (x *ControlPlaneSpec) GetVersion() string

func (*ControlPlaneSpec) ProtoMessage 

func (*ControlPlaneSpec) ProtoMessage()

func (*ControlPlaneSpec) ProtoReflect 

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

func (*ControlPlaneSpec) Reset 

func (x *ControlPlaneSpec) Reset()

func (*ControlPlaneSpec) String 

func (x *ControlPlaneSpec) String() string

type ControlPlaneStatus 

type ControlPlaneStatus struct {

	// Actual Kubernetes and configuration version.
	// Version have format `<major>.<minor>.<patch>-nebius-cp.<infra_version>` like "1.30.0-nebius-cp.3".
	// Where <major>.<minor>.<patch> is Kubernetes version and <infra_version> is version of control plane infrastructure and configuration,
	// which update may include bug fixes, security updates and new features of components running on control plane, like CCM or Cluster Autoscaler.
	Version   string                       `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Endpoints *ControlPlaneStatusEndpoints `protobuf:"bytes,2,opt,name=endpoints,proto3" json:"endpoints,omitempty"`
	// Number of instances in etcd cluster.
	EtcdClusterSize int64                   `protobuf:"varint,3,opt,name=etcd_cluster_size,json=etcdClusterSize,proto3" json:"etcd_cluster_size,omitempty"`
	Auth            *ControlPlaneStatusAuth `protobuf:"bytes,100,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlPlaneStatus) Descriptor deprecated 

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

Deprecated: Use ControlPlaneStatus.ProtoReflect.Descriptor instead.

func (*ControlPlaneStatus) GetAuth 

func (x *ControlPlaneStatus) GetAuth() *ControlPlaneStatusAuth

func (*ControlPlaneStatus) GetEndpoints 

func (x *ControlPlaneStatus) GetEndpoints() *ControlPlaneStatusEndpoints

func (*ControlPlaneStatus) GetEtcdClusterSize 

func (x *ControlPlaneStatus) GetEtcdClusterSize() int64

func (*ControlPlaneStatus) GetVersion 

func (x *ControlPlaneStatus) GetVersion() string

func (*ControlPlaneStatus) ProtoMessage 

func (*ControlPlaneStatus) ProtoMessage()

func (*ControlPlaneStatus) ProtoReflect 

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

func (*ControlPlaneStatus) Reset 

func (x *ControlPlaneStatus) Reset()

func (*ControlPlaneStatus) String 

func (x *ControlPlaneStatus) String() string

type ControlPlaneStatusAuth 

type ControlPlaneStatusAuth struct {

	// PEM with the Cluster Certificate Authority, that must be used for TLS connection to Kubernetes API.
	ClusterCaCertificate string `protobuf:"bytes,1,opt,name=cluster_ca_certificate,json=clusterCaCertificate,proto3" json:"cluster_ca_certificate,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlPlaneStatusAuth) Descriptor deprecated 

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

Deprecated: Use ControlPlaneStatusAuth.ProtoReflect.Descriptor instead.

func (*ControlPlaneStatusAuth) GetClusterCaCertificate 

func (x *ControlPlaneStatusAuth) GetClusterCaCertificate() string

func (*ControlPlaneStatusAuth) ProtoMessage 

func (*ControlPlaneStatusAuth) ProtoMessage()

func (*ControlPlaneStatusAuth) ProtoReflect 

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

func (*ControlPlaneStatusAuth) Reset 

func (x *ControlPlaneStatusAuth) Reset()

func (*ControlPlaneStatusAuth) String 

func (x *ControlPlaneStatusAuth) String() string

type ControlPlaneStatusEndpoints 

type ControlPlaneStatusEndpoints struct {

	// DNS name or IP address accessible from the Internet.
	PublicEndpoint string `protobuf:"bytes,1,opt,name=public_endpoint,json=publicEndpoint,proto3" json:"public_endpoint,omitempty"`
	// DNS name or IP address accessible from the user VPC.
	PrivateEndpoint string `protobuf:"bytes,2,opt,name=private_endpoint,json=privateEndpoint,proto3" json:"private_endpoint,omitempty"`
	// contains filtered or unexported fields
}

Endpoints of Kubernetes control plane. Kubernetes API can be accessed at `https://endpoint/`.

func (*ControlPlaneStatusEndpoints) Descriptor deprecated 

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

Deprecated: Use ControlPlaneStatusEndpoints.ProtoReflect.Descriptor instead.

func (*ControlPlaneStatusEndpoints) GetPrivateEndpoint 

func (x *ControlPlaneStatusEndpoints) GetPrivateEndpoint() string

func (*ControlPlaneStatusEndpoints) GetPublicEndpoint 

func (x *ControlPlaneStatusEndpoints) GetPublicEndpoint() string

func (*ControlPlaneStatusEndpoints) ProtoMessage 

func (*ControlPlaneStatusEndpoints) ProtoMessage()

func (*ControlPlaneStatusEndpoints) ProtoReflect 

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

func (*ControlPlaneStatusEndpoints) Reset 

func (x *ControlPlaneStatusEndpoints) Reset()

func (*ControlPlaneStatusEndpoints) String 

func (x *ControlPlaneStatusEndpoints) String() string

type CreateClusterRequest 

type CreateClusterRequest struct {
	Metadata *v1.ResourceMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec     *ClusterSpec         `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateClusterRequest) Descriptor deprecated 

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

Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterRequest) GetMetadata 

func (x *CreateClusterRequest) GetMetadata() *v1.ResourceMetadata

func (*CreateClusterRequest) GetSpec 

func (x *CreateClusterRequest) GetSpec() *ClusterSpec

func (*CreateClusterRequest) ProtoMessage 

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) ProtoReflect 

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

func (*CreateClusterRequest) Reset 

func (x *CreateClusterRequest) Reset()

func (*CreateClusterRequest) String 

func (x *CreateClusterRequest) String() string

type CreateNodeGroupRequest 

type CreateNodeGroupRequest struct {
	Metadata *v1.ResourceMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec     *NodeGroupSpec       `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateNodeGroupRequest) Descriptor deprecated 

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

Deprecated: Use CreateNodeGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateNodeGroupRequest) GetMetadata 

func (x *CreateNodeGroupRequest) GetMetadata() *v1.ResourceMetadata

func (*CreateNodeGroupRequest) GetSpec 

func (x *CreateNodeGroupRequest) GetSpec() *NodeGroupSpec

func (*CreateNodeGroupRequest) LogValue 

func (x *CreateNodeGroupRequest) LogValue() slog.Value

LogValue implements slog.LogValuer interface. It returns sanitized copy of CreateNodeGroupRequest. Properly implemented slog.Handler must call LogValue, so sensitive values are not logged. Sensitive strings and bytes are masked with "**HIDDEN**", other sensitive fields are omitted.

Returning value has kind slog.KindAny. To extract proto.Message, use the following code: 

var original *CreateNodeGroupRequest
sanitized := original.LogValue().Any().(proto.Message)

If you need to extract CreateNodeGroupRequest, use the following code: 

var original *CreateNodeGroupRequest
sanitized := original.LogValue().Any().(proto.Message).ProtoReflect().Interface().(*CreateNodeGroupRequest)

func (*CreateNodeGroupRequest) ProtoMessage 

func (*CreateNodeGroupRequest) ProtoMessage()

func (*CreateNodeGroupRequest) ProtoReflect 

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

func (*CreateNodeGroupRequest) Reset 

func (x *CreateNodeGroupRequest) Reset()

func (*CreateNodeGroupRequest) Sanitize 

func (x *CreateNodeGroupRequest) Sanitize()

Sanitize mutates CreateNodeGroupRequest to remove/mask all sensitive values. Sensitive fields are marked with [(nebius.sensitive) = true].

func (*CreateNodeGroupRequest) String 

func (x *CreateNodeGroupRequest) String() string

type DeleteClusterRequest 

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

func (*DeleteClusterRequest) Descriptor deprecated 

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

Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterRequest) GetId 

func (x *DeleteClusterRequest) GetId() string

func (*DeleteClusterRequest) ProtoMessage 

func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) ProtoReflect 

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

func (*DeleteClusterRequest) Reset 

func (x *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) String 

func (x *DeleteClusterRequest) String() string

type DeleteNodeGroupRequest 

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

func (*DeleteNodeGroupRequest) Descriptor deprecated 

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

Deprecated: Use DeleteNodeGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteNodeGroupRequest) GetId 

func (x *DeleteNodeGroupRequest) GetId() string

func (*DeleteNodeGroupRequest) ProtoMessage 

func (*DeleteNodeGroupRequest) ProtoMessage()

func (*DeleteNodeGroupRequest) ProtoReflect 

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

func (*DeleteNodeGroupRequest) Reset 

func (x *DeleteNodeGroupRequest) Reset()

func (*DeleteNodeGroupRequest) String 

func (x *DeleteNodeGroupRequest) String() string

type DiskSpec 

type DiskSpec struct {

	// Types that are assignable to Size:
	//
	//	*DiskSpec_SizeBytes
	//	*DiskSpec_SizeKibibytes
	//	*DiskSpec_SizeMebibytes
	//	*DiskSpec_SizeGibibytes
	Size           isDiskSpec_Size   `protobuf_oneof:"size"`
	BlockSizeBytes int64             `protobuf:"varint,5,opt,name=block_size_bytes,json=blockSizeBytes,proto3" json:"block_size_bytes,omitempty"`
	Type           DiskSpec_DiskType `protobuf:"varint,6,opt,name=type,proto3,enum=nebius.mk8s.v1.DiskSpec_DiskType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskSpec) Descriptor deprecated 

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

Deprecated: Use DiskSpec.ProtoReflect.Descriptor instead.

func (*DiskSpec) GetBlockSizeBytes 

func (x *DiskSpec) GetBlockSizeBytes() int64

func (*DiskSpec) GetSize 

func (m *DiskSpec) GetSize() isDiskSpec_Size

func (*DiskSpec) GetSizeBytes 

func (x *DiskSpec) GetSizeBytes() int64

func (*DiskSpec) GetSizeGibibytes 

func (x *DiskSpec) GetSizeGibibytes() int64

func (*DiskSpec) GetSizeKibibytes 

func (x *DiskSpec) GetSizeKibibytes() int64

func (*DiskSpec) GetSizeMebibytes 

func (x *DiskSpec) GetSizeMebibytes() int64

func (*DiskSpec) GetType 

func (x *DiskSpec) GetType() DiskSpec_DiskType

func (*DiskSpec) ProtoMessage 

func (*DiskSpec) ProtoMessage()

func (*DiskSpec) ProtoReflect 

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

func (*DiskSpec) Reset 

func (x *DiskSpec) Reset()

func (*DiskSpec) String 

func (x *DiskSpec) String() string

type DiskSpec_DiskType 

type DiskSpec_DiskType int32
const (
	DiskSpec_UNSPECIFIED                DiskSpec_DiskType = 0
	DiskSpec_NETWORK_SSD                DiskSpec_DiskType = 1
	DiskSpec_NETWORK_HDD                DiskSpec_DiskType = 2
	DiskSpec_NETWORK_SSD_IO_M3          DiskSpec_DiskType = 3
	DiskSpec_NETWORK_SSD_NON_REPLICATED DiskSpec_DiskType = 4
)

func (DiskSpec_DiskType) Descriptor 

func (DiskSpec_DiskType) Descriptor() protoreflect.EnumDescriptor

func (DiskSpec_DiskType) Enum 

func (x DiskSpec_DiskType) Enum() *DiskSpec_DiskType

func (DiskSpec_DiskType) EnumDescriptor deprecated 

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

Deprecated: Use DiskSpec_DiskType.Descriptor instead.

func (DiskSpec_DiskType) Number 

func (x DiskSpec_DiskType) Number() protoreflect.EnumNumber

func (DiskSpec_DiskType) String 

func (x DiskSpec_DiskType) String() string

func (DiskSpec_DiskType) Type 

func (DiskSpec_DiskType) Type() protoreflect.EnumType

type DiskSpec_SizeBytes 

type DiskSpec_SizeBytes struct {
	SizeBytes int64 `protobuf:"varint,1,opt,name=size_bytes,json=sizeBytes,proto3,oneof"`
}

type DiskSpec_SizeGibibytes 

type DiskSpec_SizeGibibytes struct {
	SizeGibibytes int64 `protobuf:"varint,4,opt,name=size_gibibytes,json=sizeGibibytes,proto3,oneof"`
}

type DiskSpec_SizeKibibytes 

type DiskSpec_SizeKibibytes struct {
	SizeKibibytes int64 `protobuf:"varint,2,opt,name=size_kibibytes,json=sizeKibibytes,proto3,oneof"`
}

type DiskSpec_SizeMebibytes 

type DiskSpec_SizeMebibytes struct {
	SizeMebibytes int64 `protobuf:"varint,3,opt,name=size_mebibytes,json=sizeMebibytes,proto3,oneof"`
}

type ExistingFilesystem 

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

func (*ExistingFilesystem) Descriptor deprecated 

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

Deprecated: Use ExistingFilesystem.ProtoReflect.Descriptor instead.

func (*ExistingFilesystem) GetId 

func (x *ExistingFilesystem) GetId() string

func (*ExistingFilesystem) ProtoMessage 

func (*ExistingFilesystem) ProtoMessage()

func (*ExistingFilesystem) ProtoReflect 

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

func (*ExistingFilesystem) Reset 

func (x *ExistingFilesystem) Reset()

func (*ExistingFilesystem) String 

func (x *ExistingFilesystem) String() string

type GetClusterRequest 

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

func (*GetClusterRequest) Descriptor deprecated 

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

Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.

func (*GetClusterRequest) GetId 

func (x *GetClusterRequest) GetId() string

func (*GetClusterRequest) GetResourceVersion 

func (x *GetClusterRequest) GetResourceVersion() string

func (*GetClusterRequest) ProtoMessage 

func (*GetClusterRequest) ProtoMessage()

func (*GetClusterRequest) ProtoReflect 

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

func (*GetClusterRequest) Reset 

func (x *GetClusterRequest) Reset()

func (*GetClusterRequest) String 

func (x *GetClusterRequest) String() string

type GetNodeGroupRequest 

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

func (*GetNodeGroupRequest) Descriptor deprecated 

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

Deprecated: Use GetNodeGroupRequest.ProtoReflect.Descriptor instead.

func (*GetNodeGroupRequest) GetId 

func (x *GetNodeGroupRequest) GetId() string

func (*GetNodeGroupRequest) GetResourceVersion 

func (x *GetNodeGroupRequest) GetResourceVersion() string

func (*GetNodeGroupRequest) ProtoMessage 

func (*GetNodeGroupRequest) ProtoMessage()

func (*GetNodeGroupRequest) ProtoReflect 

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

func (*GetNodeGroupRequest) Reset 

func (x *GetNodeGroupRequest) Reset()

func (*GetNodeGroupRequest) String 

func (x *GetNodeGroupRequest) String() string

type GpuClusterSpec 

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

func (*GpuClusterSpec) Descriptor deprecated 

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

Deprecated: Use GpuClusterSpec.ProtoReflect.Descriptor instead.

func (*GpuClusterSpec) GetId 

func (x *GpuClusterSpec) GetId() string

func (*GpuClusterSpec) ProtoMessage 

func (*GpuClusterSpec) ProtoMessage()

func (*GpuClusterSpec) ProtoReflect 

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

func (*GpuClusterSpec) Reset 

func (x *GpuClusterSpec) Reset()

func (*GpuClusterSpec) String 

func (x *GpuClusterSpec) String() string

type KubeNetworkSpec 

type KubeNetworkSpec struct {

	// CIDR blocks for Service ClusterIP allocation. For now, only one value is supported.
	// For now, value should be in prefix length form (such as "/16").
	// Later a CIDR-formatted string (such as "10.1.2.0/16") will be supported.
	// In case of prefix length, certain CIDR is auto allocated.
	// Specified CIDR blocks will be reserved in Cluster.spec.control_plane.subnet_id to prevent address duplication.
	// Allowed prefix length is from "/12" to "/28".
	// Empty value treated as ["/16"].
	ServiceCidrs []string `protobuf:"bytes,1,rep,name=service_cidrs,json=serviceCidrs,proto3" json:"service_cidrs,omitempty"`
	// contains filtered or unexported fields
}

func (*KubeNetworkSpec) Descriptor deprecated 

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

Deprecated: Use KubeNetworkSpec.ProtoReflect.Descriptor instead.

func (*KubeNetworkSpec) GetServiceCidrs 

func (x *KubeNetworkSpec) GetServiceCidrs() []string

func (*KubeNetworkSpec) ProtoMessage 

func (*KubeNetworkSpec) ProtoMessage()

func (*KubeNetworkSpec) ProtoReflect 

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

func (*KubeNetworkSpec) Reset 

func (x *KubeNetworkSpec) Reset()

func (*KubeNetworkSpec) String 

func (x *KubeNetworkSpec) String() string

type ListClustersRequest 

type ListClustersRequest struct {

	// ID of the IAM container we are listing the resources in.
	ParentId string `protobuf:"bytes,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// Specifies the maximum number of items to return in the response.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Token for pagination, allowing the retrieval of the next set of results.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClustersRequest) Descriptor deprecated 

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

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) GetPageSize 

func (x *ListClustersRequest) GetPageSize() int64

func (*ListClustersRequest) GetPageToken 

func (x *ListClustersRequest) GetPageToken() string

func (*ListClustersRequest) GetParentId 

func (x *ListClustersRequest) GetParentId() string

func (*ListClustersRequest) ProtoMessage 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect 

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

func (*ListClustersRequest) Reset 

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) String 

func (x *ListClustersRequest) String() string

type ListClustersResponse 

type ListClustersResponse struct {
	Items         []*Cluster `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	NextPageToken string     `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClustersResponse) Descriptor deprecated 

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

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) GetItems 

func (x *ListClustersResponse) GetItems() []*Cluster

func (*ListClustersResponse) GetNextPageToken 

func (x *ListClustersResponse) GetNextPageToken() string

func (*ListClustersResponse) ProtoMessage 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect 

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

func (*ListClustersResponse) Reset 

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) String 

func (x *ListClustersResponse) String() string

type ListNodeGroupsRequest 

type ListNodeGroupsRequest struct {

	// ID of the parent Cluster.
	ParentId string `protobuf:"bytes,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	// Specifies the maximum number of items to return in the response.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Token for pagination, allowing the retrieval of the next set of results.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodeGroupsRequest) Descriptor deprecated 

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

Deprecated: Use ListNodeGroupsRequest.ProtoReflect.Descriptor instead.

func (*ListNodeGroupsRequest) GetPageSize 

func (x *ListNodeGroupsRequest) GetPageSize() int64

func (*ListNodeGroupsRequest) GetPageToken 

func (x *ListNodeGroupsRequest) GetPageToken() string

func (*ListNodeGroupsRequest) GetParentId 

func (x *ListNodeGroupsRequest) GetParentId() string

func (*ListNodeGroupsRequest) ProtoMessage 

func (*ListNodeGroupsRequest) ProtoMessage()

func (*ListNodeGroupsRequest) ProtoReflect 

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

func (*ListNodeGroupsRequest) Reset 

func (x *ListNodeGroupsRequest) Reset()

func (*ListNodeGroupsRequest) String 

func (x *ListNodeGroupsRequest) String() string

type ListNodeGroupsResponse 

type ListNodeGroupsResponse struct {
	Items         []*NodeGroup `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	NextPageToken string       `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodeGroupsResponse) Descriptor deprecated 

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

Deprecated: Use ListNodeGroupsResponse.ProtoReflect.Descriptor instead.

func (*ListNodeGroupsResponse) GetItems 

func (x *ListNodeGroupsResponse) GetItems() []*NodeGroup

func (*ListNodeGroupsResponse) GetNextPageToken 

func (x *ListNodeGroupsResponse) GetNextPageToken() string

func (*ListNodeGroupsResponse) LogValue 

func (x *ListNodeGroupsResponse) LogValue() slog.Value

LogValue implements slog.LogValuer interface. It returns sanitized copy of ListNodeGroupsResponse. Properly implemented slog.Handler must call LogValue, so sensitive values are not logged. Sensitive strings and bytes are masked with "**HIDDEN**", other sensitive fields are omitted.

Returning value has kind slog.KindAny. To extract proto.Message, use the following code: 

var original *ListNodeGroupsResponse
sanitized := original.LogValue().Any().(proto.Message)

If you need to extract ListNodeGroupsResponse, use the following code: 

var original *ListNodeGroupsResponse
sanitized := original.LogValue().Any().(proto.Message).ProtoReflect().Interface().(*ListNodeGroupsResponse)

func (*ListNodeGroupsResponse) ProtoMessage 

func (*ListNodeGroupsResponse) ProtoMessage()

func (*ListNodeGroupsResponse) ProtoReflect 

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

func (*ListNodeGroupsResponse) Reset 

func (x *ListNodeGroupsResponse) Reset()

func (*ListNodeGroupsResponse) Sanitize 

func (x *ListNodeGroupsResponse) Sanitize()

Sanitize mutates ListNodeGroupsResponse to remove/mask all sensitive values. Sensitive fields are marked with [(nebius.sensitive) = true].

func (*ListNodeGroupsResponse) String 

func (x *ListNodeGroupsResponse) String() string

type NetworkInterfaceTemplate 

type NetworkInterfaceTemplate struct {

	// Parameters for Public IPv4 address associated with the interface.
	// Set to empty value, to enable it.
	PublicIpAddress *PublicIPAddress `protobuf:"bytes,1,opt,name=public_ip_address,json=publicIpAddress,proto3" json:"public_ip_address,omitempty"`
	// Nebius VPC Subnet ID that will be attached to a node cloud instance network interface.
	// By default Cluster control plane subnet_id used.
	// Subnet should be located in the same network with control plane.
	SubnetId string `protobuf:"bytes,3,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkInterfaceTemplate) Descriptor deprecated 

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

Deprecated: Use NetworkInterfaceTemplate.ProtoReflect.Descriptor instead.

func (*NetworkInterfaceTemplate) GetPublicIpAddress 

func (x *NetworkInterfaceTemplate) GetPublicIpAddress() *PublicIPAddress

func (*NetworkInterfaceTemplate) GetSubnetId 

func (x *NetworkInterfaceTemplate) GetSubnetId() string

func (*NetworkInterfaceTemplate) ProtoMessage 

func (*NetworkInterfaceTemplate) ProtoMessage()

func (*NetworkInterfaceTemplate) ProtoReflect 

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

func (*NetworkInterfaceTemplate) Reset 

func (x *NetworkInterfaceTemplate) Reset()

func (*NetworkInterfaceTemplate) String 

func (x *NetworkInterfaceTemplate) String() string

type NodeGroup 

type NodeGroup struct {
	Metadata *v1.ResourceMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` // The parent_id is an ID of Cluster
	Spec     *NodeGroupSpec       `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	Status   *NodeGroupStatus     `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

NodeGroup represents Kubernetes node pool - set of worker machines having the same configuration. A Node is a Nebius Compute Instance created in Cluster.metadata.parent_id container, running kubelet that registers in Kubernetes API and a Node object created.

func (*NodeGroup) Descriptor deprecated 

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

Deprecated: Use NodeGroup.ProtoReflect.Descriptor instead.

func (*NodeGroup) GetMetadata 

func (x *NodeGroup) GetMetadata() *v1.ResourceMetadata

func (*NodeGroup) GetSpec 

func (x *NodeGroup) GetSpec() *NodeGroupSpec

func (*NodeGroup) GetStatus 

func (x *NodeGroup) GetStatus() *NodeGroupStatus

func (*NodeGroup) LogValue 

func (x *NodeGroup) LogValue() slog.Value

LogValue implements slog.LogValuer interface. It returns sanitized copy of NodeGroup. Properly implemented slog.Handler must call LogValue, so sensitive values are not logged. Sensitive strings and bytes are masked with "**HIDDEN**", other sensitive fields are omitted.

Returning value has kind slog.KindAny. To extract proto.Message, use the following code: 

var original *NodeGroup
sanitized := original.LogValue().Any().(proto.Message)

If you need to extract NodeGroup, use the following code: 

var original *NodeGroup
sanitized := original.LogValue().Any().(proto.Message).ProtoReflect().Interface().(*NodeGroup)

func (*NodeGroup) ProtoMessage 

func (*NodeGroup) ProtoMessage()

func (*NodeGroup) ProtoReflect 

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

func (*NodeGroup) Reset 

func (x *NodeGroup) Reset()

func (*NodeGroup) Sanitize 

func (x *NodeGroup) Sanitize()

Sanitize mutates NodeGroup to remove/mask all sensitive values. Sensitive fields are marked with [(nebius.sensitive) = true].

func (*NodeGroup) String 

func (x *NodeGroup) String() string

type NodeGroupAutoscalingSpec 

type NodeGroupAutoscalingSpec struct {
	MinNodeCount int64 `protobuf:"varint,1,opt,name=min_node_count,json=minNodeCount,proto3" json:"min_node_count,omitempty"`
	MaxNodeCount int64 `protobuf:"varint,2,opt,name=max_node_count,json=maxNodeCount,proto3" json:"max_node_count,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeGroupAutoscalingSpec) Descriptor deprecated 

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

Deprecated: Use NodeGroupAutoscalingSpec.ProtoReflect.Descriptor instead.

func (*NodeGroupAutoscalingSpec) GetMaxNodeCount 

func (x *NodeGroupAutoscalingSpec) GetMaxNodeCount() int64

func (*NodeGroupAutoscalingSpec) GetMinNodeCount 

func (x *NodeGroupAutoscalingSpec) GetMinNodeCount() int64

func (*NodeGroupAutoscalingSpec) ProtoMessage 

func (*NodeGroupAutoscalingSpec) ProtoMessage()

func (*NodeGroupAutoscalingSpec) ProtoReflect 

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

func (*NodeGroupAutoscalingSpec) Reset 

func (x *NodeGroupAutoscalingSpec) Reset()

func (*NodeGroupAutoscalingSpec) String 

func (x *NodeGroupAutoscalingSpec) String() string

type NodeGroupDeploymentStrategy 

type NodeGroupDeploymentStrategy struct {

	// The maximum number of nodes that can be simultaneously unavailable during the update process.
	// This value can be specified either as an absolute number (for example 3) or as a percentage of the desired number of nodes (for example 5%).
	// When specified as a percentage, the actual number is calculated by rounding down to the nearest whole number.
	// This value cannot be 0 if `max_surge` is also set to 0.
	// Defaults to 0.
	// Example: If set to 20%, up to 20% of the nodes can be taken offline at once during the update,
	// ensuring that at least 80% of the desired nodes remain operational.
	MaxUnavailable *PercentOrCount `protobuf:"bytes,1,opt,name=max_unavailable,json=maxUnavailable,proto3" json:"max_unavailable,omitempty"`
	// The maximum number of additional nodes that can be provisioned above the desired number of nodes during the update process.
	// This value can be specified either as an absolute number (for example 3) or as a percentage of the desired number of nodes (for example 5%).
	// When specified as a percentage, the actual number is calculated by rounding up to the nearest whole number.
	// This value cannot be 0 if `max_unavailable` is also set to 0.
	// Defaults to 1.
	// Example: If set to 25%, the node group can scale up by an additional 25% during the update,
	// allowing new nodes to be added before old nodes are removed, which helps minimize workload disruption.
	// NOTE: it is user responsibility to ensure that there are enough quota for provision nodes above the desired number.
	//
	//	Available quota effectively limits `max_surge`.
	//	In case of not enough quota even for one extra node, update operation will hung because of quota exhausted error.
	//	Such error will be visible in Operation.progress_data.
	MaxSurge *PercentOrCount `protobuf:"bytes,2,opt,name=max_surge,json=maxSurge,proto3" json:"max_surge,omitempty"`
	// Maximum amount of time that the service will spend on attempting gracefully draining a node (evicting it's pods), before
	// falling back to pod deletion.
	// By default, node can be drained unlimited time.
	// Important consequence of that is if PodDisruptionBudget doesn't allow to evict a pod,
	// then NodeGroup update with node re-creation will hung on that pod eviction.
	// Note, that it is different from `kubectl drain --timeout`
	DrainTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=drain_timeout,json=drainTimeout,proto3" json:"drain_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeGroupDeploymentStrategy) Descriptor deprecated 

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

Deprecated: Use NodeGroupDeploymentStrategy.ProtoReflect.Descriptor instead.

func (*NodeGroupDeploymentStrategy) GetDrainTimeout 

func (x *NodeGroupDeploymentStrategy) GetDrainTimeout() *durationpb.Duration

func (*NodeGroupDeploymentStrategy) GetMaxSurge 

func (x *NodeGroupDeploymentStrategy) GetMaxSurge() *PercentOrCount

func (*NodeGroupDeploymentStrategy) GetMaxUnavailable 

func (x *NodeGroupDeploymentStrategy) GetMaxUnavailable() *PercentOrCount

func (*NodeGroupDeploymentStrategy) ProtoMessage 

func (*NodeGroupDeploymentStrategy) ProtoMessage()

func (*NodeGroupDeploymentStrategy) ProtoReflect 

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

func (*NodeGroupDeploymentStrategy) Reset 

func (x *NodeGroupDeploymentStrategy) Reset()

func (*NodeGroupDeploymentStrategy) String 

func (x *NodeGroupDeploymentStrategy) String() string

type NodeGroupServiceClient 

type NodeGroupServiceClient interface {
	Get(ctx context.Context, in *GetNodeGroupRequest, opts ...grpc.CallOption) (*NodeGroup, error)
	GetByName(ctx context.Context, in *v1.GetByNameRequest, opts ...grpc.CallOption) (*NodeGroup, error)
	List(ctx context.Context, in *ListNodeGroupsRequest, opts ...grpc.CallOption) (*ListNodeGroupsResponse, error)
	Create(ctx context.Context, in *CreateNodeGroupRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	Update(ctx context.Context, in *UpdateNodeGroupRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	Delete(ctx context.Context, in *DeleteNodeGroupRequest, opts ...grpc.CallOption) (*v1.Operation, error)
	Upgrade(ctx context.Context, in *UpgradeNodeGroupRequest, opts ...grpc.CallOption) (*v1.Operation, error)
}

NodeGroupServiceClient is the client API for NodeGroupService 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 NewNodeGroupServiceClient 

func NewNodeGroupServiceClient(cc grpc.ClientConnInterface) NodeGroupServiceClient

type NodeGroupServiceServer 

type NodeGroupServiceServer interface {
	Get(context.Context, *GetNodeGroupRequest) (*NodeGroup, error)
	GetByName(context.Context, *v1.GetByNameRequest) (*NodeGroup, error)
	List(context.Context, *ListNodeGroupsRequest) (*ListNodeGroupsResponse, error)
	Create(context.Context, *CreateNodeGroupRequest) (*v1.Operation, error)
	Update(context.Context, *UpdateNodeGroupRequest) (*v1.Operation, error)
	Delete(context.Context, *DeleteNodeGroupRequest) (*v1.Operation, error)
	Upgrade(context.Context, *UpgradeNodeGroupRequest) (*v1.Operation, error)
}

NodeGroupServiceServer is the server API for NodeGroupService service. All implementations should embed UnimplementedNodeGroupServiceServer for forward compatibility

type NodeGroupSpec 

type NodeGroupSpec struct {

	// Version is desired Kubernetes version of the cluster. For now only acceptable format is
	// `<major>.<minor>` like "1.30". Option for patch version update will be added later.
	// By default the cluster control plane <major>.<minor> version will be used.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Types that are assignable to Size:
	//
	//	*NodeGroupSpec_FixedNodeCount
	//	*NodeGroupSpec_Autoscaling
	Size isNodeGroupSpec_Size `protobuf_oneof:"size"`
	// Parameters for Kubernetes Node object and Nebius Compute Instance
	// If not written opposite a NodeTemplate field update will cause NodeGroup roll-out according NodeGroupDeploymentStrategy.
	Template *NodeTemplate `protobuf:"bytes,3,opt,name=template,proto3" json:"template,omitempty"`
	// Defines deployment - roll-out, or nodes re-creation during configuration change.
	// Allows to setup compromise in roll-out speed, extra resources consumption and workloads disruption.
	Strategy *NodeGroupDeploymentStrategy `protobuf:"bytes,4,opt,name=strategy,proto3" json:"strategy,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeGroupSpec) Descriptor deprecated 

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

Deprecated: Use NodeGroupSpec.ProtoReflect.Descriptor instead.

func (*NodeGroupSpec) GetAutoscaling 

func (x *NodeGroupSpec) GetAutoscaling() *NodeGroupAutoscalingSpec

func (*NodeGroupSpec) GetFixedNodeCount 

func (x *NodeGroupSpec) GetFixedNodeCount() int64

func (*NodeGroupSpec) GetSize 

func (m *NodeGroupSpec) GetSize() isNodeGroupSpec_Size

func (*NodeGroupSpec) GetStrategy 

func (x *NodeGroupSpec) GetStrategy() *NodeGroupDeploymentStrategy

func (*NodeGroupSpec) GetTemplate 

func (x *NodeGroupSpec) GetTemplate() *NodeTemplate

func (*NodeGroupSpec) GetVersion 

func (x *NodeGroupSpec) GetVersion() string

func (*NodeGroupSpec) LogValue 

func (x *NodeGroupSpec) LogValue() slog.Value

LogValue implements slog.LogValuer interface. It returns sanitized copy of NodeGroupSpec. Properly implemented slog.Handler must call LogValue, so sensitive values are not logged. Sensitive strings and bytes are masked with "**HIDDEN**", other sensitive fields are omitted.

Returning value has kind slog.KindAny. To extract proto.Message, use the following code: 

var original *NodeGroupSpec
sanitized := original.LogValue().Any().(proto.Message)

If you need to extract NodeGroupSpec, use the following code: 

var original *NodeGroupSpec
sanitized := original.LogValue().Any().(proto.Message).ProtoReflect().Interface().(*NodeGroupSpec)

func (*NodeGroupSpec) ProtoMessage 

func (*NodeGroupSpec) ProtoMessage()

func (*NodeGroupSpec) ProtoReflect 

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

func (*NodeGroupSpec) Reset 

func (x *NodeGroupSpec) Reset()

func (*NodeGroupSpec) Sanitize 

func (x *NodeGroupSpec) Sanitize()

Sanitize mutates NodeGroupSpec to remove/mask all sensitive values. Sensitive fields are marked with [(nebius.sensitive) = true].

func (*NodeGroupSpec) String 

func (x *NodeGroupSpec) String() string

type NodeGroupSpec_Autoscaling 

type NodeGroupSpec_Autoscaling struct {
	// Enables [Kubernetes Cluster Autoscaler](https://github.com/kubernetes/autoscaler/tree/master/cluster-autoscaler)
	// for that NodeGroup, and defines autoscaling parameters.
	Autoscaling *NodeGroupAutoscalingSpec `protobuf:"bytes,5,opt,name=autoscaling,proto3,oneof"`
}

type NodeGroupSpec_FixedNodeCount 

type NodeGroupSpec_FixedNodeCount struct {
	// Number of nodes in the group. Can be changed manually at any time.
	FixedNodeCount int64 `protobuf:"varint,2,opt,name=fixed_node_count,json=fixedNodeCount,proto3,oneof"`
}

type NodeGroupStatus 

type NodeGroupStatus struct {
	State NodeGroupStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=nebius.mk8s.v1.NodeGroupStatus_State" json:"state,omitempty"`
	// Actual version of NodeGroup. Have format `<major>.<minor>.<patch>-nebius-node.<infra_version>` like "1.30.0-nebius-node.10".
	// Where <major>.<minor>.<patch> is Kubernetes version and <infra_version> is version of Node infrastructure and configuration,
	// which update may include bug fixes, security updates and new features depending on worker node configuration.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Desired total number of nodes that should be in the node group.
	// It is either `NodeGroupSpec.fixed_node_count` or arbitrary number between
	// `NodeGroupAutoscalingSpec.min_node_count` and `NodeGroupAutoscalingSpec.max_node_count` decided by autoscaler.
	TargetNodeCount int64 `protobuf:"varint,3,opt,name=target_node_count,json=targetNodeCount,proto3" json:"target_node_count,omitempty"`
	// Total number of nodes that are currently in the node group.
	// Both ready and not ready nodes are counted.
	NodeCount int64 `protobuf:"varint,4,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`
	// Total number of nodes that has outdated node configuration.
	// These nodes will be replaced by new nodes with up-to-date configuration.
	OutdatedNodeCount int64 `protobuf:"varint,5,opt,name=outdated_node_count,json=outdatedNodeCount,proto3" json:"outdated_node_count,omitempty"`
	// Total number of nodes that successfully joined the cluster and are ready to serve workloads.
	// Both outdated and up-to-date nodes are counted.
	ReadyNodeCount int64 `protobuf:"varint,6,opt,name=ready_node_count,json=readyNodeCount,proto3" json:"ready_node_count,omitempty"`
	// Show that there are changes are in flight.
	Reconciling bool `protobuf:"varint,100,opt,name=reconciling,proto3" json:"reconciling,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeGroupStatus) Descriptor deprecated 

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

Deprecated: Use NodeGroupStatus.ProtoReflect.Descriptor instead.

func (*NodeGroupStatus) GetNodeCount 

func (x *NodeGroupStatus) GetNodeCount() int64

func (*NodeGroupStatus) GetOutdatedNodeCount 

func (x *NodeGroupStatus) GetOutdatedNodeCount() int64

func (*NodeGroupStatus) GetReadyNodeCount 

func (x *NodeGroupStatus) GetReadyNodeCount() int64

func (*NodeGroupStatus) GetReconciling 

func (x *NodeGroupStatus) GetReconciling() bool

func (*NodeGroupStatus) GetState 

func (x *NodeGroupStatus) GetState() NodeGroupStatus_State

func (*NodeGroupStatus) GetTargetNodeCount 

func (x *NodeGroupStatus) GetTargetNodeCount() int64

func (*NodeGroupStatus) GetVersion 

func (x *NodeGroupStatus) GetVersion() string

func (*NodeGroupStatus) ProtoMessage 

func (*NodeGroupStatus) ProtoMessage()

func (*NodeGroupStatus) ProtoReflect 

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

func (*NodeGroupStatus) Reset 

func (x *NodeGroupStatus) Reset()

func (*NodeGroupStatus) String 

func (x *NodeGroupStatus) String() string

type NodeGroupStatus_State 

type NodeGroupStatus_State int32
const (
	NodeGroupStatus_STATE_UNSPECIFIED NodeGroupStatus_State = 0
	NodeGroupStatus_PROVISIONING      NodeGroupStatus_State = 1
	NodeGroupStatus_RUNNING           NodeGroupStatus_State = 2
	NodeGroupStatus_DELETING          NodeGroupStatus_State = 3
)

func (NodeGroupStatus_State) Descriptor 

func (NodeGroupStatus_State) Descriptor() protoreflect.EnumDescriptor

func (NodeGroupStatus_State) Enum 

func (x NodeGroupStatus_State) Enum() *NodeGroupStatus_State

func (NodeGroupStatus_State) EnumDescriptor deprecated 

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

Deprecated: Use NodeGroupStatus_State.Descriptor instead.

func (NodeGroupStatus_State) Number 

func (x NodeGroupStatus_State) Number() protoreflect.EnumNumber

func (NodeGroupStatus_State) String 

func (x NodeGroupStatus_State) String() string

func (NodeGroupStatus_State) Type 

func (NodeGroupStatus_State) Type() protoreflect.EnumType

type NodeMetadataTemplate 

type NodeMetadataTemplate struct {

	// Kubernetes Node labels.
	// For now change will not be propagated to existing nodes, so will be applied only to Kubernetes Nodes created after the field change.
	// That behaviour may change later.
	// So, for now you will need to manually set them to existing nodes, if that is needed.
	//
	// System labels containing "kubernetes.io" and "k8s.io" will be ignored.
	// Field change will NOT trigger NodeGroup roll out.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NodeMetadataTemplate) Descriptor deprecated 

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

Deprecated: Use NodeMetadataTemplate.ProtoReflect.Descriptor instead.

func (*NodeMetadataTemplate) GetLabels 

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

func (*NodeMetadataTemplate) ProtoMessage 

func (*NodeMetadataTemplate) ProtoMessage()

func (*NodeMetadataTemplate) ProtoReflect 

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

func (*NodeMetadataTemplate) Reset 

func (x *NodeMetadataTemplate) Reset()

func (*NodeMetadataTemplate) String 

func (x *NodeMetadataTemplate) String() string

type NodeTaint 

type NodeTaint 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"`
	Effect NodeTaint_Effect `protobuf:"varint,3,opt,name=effect,proto3,enum=nebius.mk8s.v1.NodeTaint_Effect" json:"effect,omitempty"`
	// contains filtered or unexported fields
}

See https://kubernetes.io/docs/concepts/scheduling-eviction/taint-and-toleration/

func (*NodeTaint) Descriptor deprecated 

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

Deprecated: Use NodeTaint.ProtoReflect.Descriptor instead.

func (*NodeTaint) GetEffect 

func (x *NodeTaint) GetEffect() NodeTaint_Effect

func (*NodeTaint) GetKey 

func (x *NodeTaint) GetKey() string

func (*NodeTaint) GetValue 

func (x *NodeTaint) GetValue() string

func (*NodeTaint) ProtoMessage 

func (*NodeTaint) ProtoMessage()

func (*NodeTaint) ProtoReflect 

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

func (*NodeTaint) Reset 

func (x *NodeTaint) Reset()

func (*NodeTaint) String 

func (x *NodeTaint) String() string

type NodeTaint_Effect 

type NodeTaint_Effect int32
const (
	NodeTaint_EFFECT_UNSPECIFIED NodeTaint_Effect = 0
	NodeTaint_NO_EXECUTE         NodeTaint_Effect = 1
	NodeTaint_NO_SCHEDULE        NodeTaint_Effect = 2
	NodeTaint_PREFER_NO_SCHEDULE NodeTaint_Effect = 3
)

func (NodeTaint_Effect) Descriptor 

func (NodeTaint_Effect) Descriptor() protoreflect.EnumDescriptor

func (NodeTaint_Effect) Enum 

func (x NodeTaint_Effect) Enum() *NodeTaint_Effect

func (NodeTaint_Effect) EnumDescriptor deprecated 

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

Deprecated: Use NodeTaint_Effect.Descriptor instead.

func (NodeTaint_Effect) Number 

func (x NodeTaint_Effect) Number() protoreflect.EnumNumber

func (NodeTaint_Effect) String 

func (x NodeTaint_Effect) String() string

func (NodeTaint_Effect) Type 

func (NodeTaint_Effect) Type() protoreflect.EnumType

type NodeTemplate 

type NodeTemplate struct {
	Metadata *NodeMetadataTemplate `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Kubernetes Node taints.
	// For now change will not be propagated to existing nodes, so will be applied only to Kubernetes Nodes created after the field change.
	// That behaviour may change later.
	// So, for now you will need to manually set them to existing nodes, if that is needed.
	// Field change will NOT trigger NodeGroup roll out.
	Taints []*NodeTaint `protobuf:"bytes,2,rep,name=taints,proto3" json:"taints,omitempty"`
	// Resources that will have Nebius Compute Instance where Node kubelet will run.
	Resources *ResourcesSpec `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"`
	// Parameters of a Node Nebius Compute Instance boot disk.
	BootDisk *DiskSpec `protobuf:"bytes,9,opt,name=boot_disk,json=bootDisk,proto3" json:"boot_disk,omitempty"`
	// Nebius Compute GPUCluster ID that will be attached to node.
	GpuCluster        *GpuClusterSpec             `protobuf:"bytes,4,opt,name=gpu_cluster,json=gpuCluster,proto3" json:"gpu_cluster,omitempty"`
	NetworkInterfaces []*NetworkInterfaceTemplate `protobuf:"bytes,5,rep,name=network_interfaces,json=networkInterfaces,proto3" json:"network_interfaces,omitempty"`
	// Static attachments of Compute Filesystem.
	// Can be used as a workaround, until CSI for Compute Disk and Filesystem will be available.
	Filesystems []*AttachedFilesystemSpec `protobuf:"bytes,7,rep,name=filesystems,proto3" json:"filesystems,omitempty"`
	// cloud-init user-data
	// Should contain at least one SSH key.
	CloudInitUserData string `protobuf:"bytes,6,opt,name=cloud_init_user_data,json=cloudInitUserData,proto3" json:"cloud_init_user_data,omitempty"`
	// the Nebius service account whose credentials will be available on the nodes of the group.
	// With these credentials, it is possible to make `npc` or public API requests from the nodes without the need for extra authentication.
	// This service account is also used to make requests to container registry.
	//
	// `resource.serviceaccount.issueAccessToken` permission is required to use this field.
	ServiceAccountId string `protobuf:"bytes,10,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeTemplate) Descriptor deprecated 

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

Deprecated: Use NodeTemplate.ProtoReflect.Descriptor instead.

func (*NodeTemplate) GetBootDisk 

func (x *NodeTemplate) GetBootDisk() *DiskSpec

func (*NodeTemplate) GetCloudInitUserData 

func (x *NodeTemplate) GetCloudInitUserData() string

func (*NodeTemplate) GetFilesystems 

func (x *NodeTemplate) GetFilesystems() []*AttachedFilesystemSpec

func (*NodeTemplate) GetGpuCluster 

func (x *NodeTemplate) GetGpuCluster() *GpuClusterSpec

func (*NodeTemplate) GetMetadata 

func (x *NodeTemplate) GetMetadata() *NodeMetadataTemplate

func (*NodeTemplate) GetNetworkInterfaces 

func (x *NodeTemplate) GetNetworkInterfaces() []*NetworkInterfaceTemplate

func (*NodeTemplate) GetResources 

func (x *NodeTemplate) GetResources() *ResourcesSpec

func (*NodeTemplate) GetServiceAccountId 

func (x *NodeTemplate) GetServiceAccountId() string

func (*NodeTemplate) GetTaints 

func (x *NodeTemplate) GetTaints() []*NodeTaint

func (*NodeTemplate) LogValue 

func (x *NodeTemplate) LogValue() slog.Value

LogValue implements slog.LogValuer interface. It returns sanitized copy of NodeTemplate. Properly implemented slog.Handler must call LogValue, so sensitive values are not logged. Sensitive strings and bytes are masked with "**HIDDEN**", other sensitive fields are omitted.

Returning value has kind slog.KindAny. To extract proto.Message, use the following code: 

var original *NodeTemplate
sanitized := original.LogValue().Any().(proto.Message)

If you need to extract NodeTemplate, use the following code: 

var original *NodeTemplate
sanitized := original.LogValue().Any().(proto.Message).ProtoReflect().Interface().(*NodeTemplate)

func (*NodeTemplate) ProtoMessage 

func (*NodeTemplate) ProtoMessage()

func (*NodeTemplate) ProtoReflect 

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

func (*NodeTemplate) Reset 

func (x *NodeTemplate) Reset()

func (*NodeTemplate) Sanitize 

func (x *NodeTemplate) Sanitize()

Sanitize mutates NodeTemplate to remove/mask all sensitive values. Sensitive fields are marked with [(nebius.sensitive) = true].

func (*NodeTemplate) String 

func (x *NodeTemplate) String() string

type PercentOrCount 

type PercentOrCount struct {

	// Types that are assignable to Value:
	//
	//	*PercentOrCount_Percent
	//	*PercentOrCount_Count
	Value isPercentOrCount_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*PercentOrCount) Descriptor deprecated 

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

Deprecated: Use PercentOrCount.ProtoReflect.Descriptor instead.

func (*PercentOrCount) GetCount 

func (x *PercentOrCount) GetCount() int64

func (*PercentOrCount) GetPercent 

func (x *PercentOrCount) GetPercent() int64

func (*PercentOrCount) GetValue 

func (m *PercentOrCount) GetValue() isPercentOrCount_Value

func (*PercentOrCount) ProtoMessage 

func (*PercentOrCount) ProtoMessage()

func (*PercentOrCount) ProtoReflect 

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

func (*PercentOrCount) Reset 

func (x *PercentOrCount) Reset()

func (*PercentOrCount) String 

func (x *PercentOrCount) String() string

type PercentOrCount_Count 

type PercentOrCount_Count struct {
	Count int64 `protobuf:"varint,2,opt,name=count,proto3,oneof"`
}

type PercentOrCount_Percent 

type PercentOrCount_Percent struct {
	Percent int64 `protobuf:"varint,1,opt,name=percent,proto3,oneof"`
}

type Problem 

type Problem struct {

	// Stage on which the problem occurred.
	Stage string `protobuf:"bytes,1,opt,name=stage,proto3" json:"stage,omitempty"`
	// Message describing the problem.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Problem) Descriptor deprecated 

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

Deprecated: Use Problem.ProtoReflect.Descriptor instead.

func (*Problem) GetMessage 

func (x *Problem) GetMessage() string

func (*Problem) GetStage 

func (x *Problem) GetStage() string

func (*Problem) ProtoMessage 

func (*Problem) ProtoMessage()

func (*Problem) ProtoReflect 

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

func (*Problem) Reset 

func (x *Problem) Reset()

func (*Problem) String 

func (x *Problem) String() string

type ProgressData 

type ProgressData struct {

	// Problems encountered during the operation execution.
	Problems []*Problem `protobuf:"bytes,1,rep,name=problems,proto3" json:"problems,omitempty"`
	// contains filtered or unexported fields
}

func (*ProgressData) Descriptor deprecated 

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

Deprecated: Use ProgressData.ProtoReflect.Descriptor instead.

func (*ProgressData) GetProblems 

func (x *ProgressData) GetProblems() []*Problem

func (*ProgressData) ProtoMessage 

func (*ProgressData) ProtoMessage()

func (*ProgressData) ProtoReflect 

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

func (*ProgressData) Reset 

func (x *ProgressData) Reset()

func (*ProgressData) String 

func (x *ProgressData) String() string

type PublicEndpointSpec 

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

func (*PublicEndpointSpec) Descriptor deprecated 

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

Deprecated: Use PublicEndpointSpec.ProtoReflect.Descriptor instead.

func (*PublicEndpointSpec) ProtoMessage 

func (*PublicEndpointSpec) ProtoMessage()

func (*PublicEndpointSpec) ProtoReflect 

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

func (*PublicEndpointSpec) Reset 

func (x *PublicEndpointSpec) Reset()

func (*PublicEndpointSpec) String 

func (x *PublicEndpointSpec) String() string

type PublicIPAddress 

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

Describes a public IP address.

func (*PublicIPAddress) Descriptor deprecated 

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

Deprecated: Use PublicIPAddress.ProtoReflect.Descriptor instead.

func (*PublicIPAddress) ProtoMessage 

func (*PublicIPAddress) ProtoMessage()

func (*PublicIPAddress) ProtoReflect 

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

func (*PublicIPAddress) Reset 

func (x *PublicIPAddress) Reset()

func (*PublicIPAddress) String 

func (x *PublicIPAddress) String() string

type ResourcesSpec 

type ResourcesSpec struct {
	Platform string `protobuf:"bytes,1,opt,name=platform,proto3" json:"platform,omitempty"`
	// Types that are assignable to Size:
	//
	//	*ResourcesSpec_Preset
	Size isResourcesSpec_Size `protobuf_oneof:"size"`
	// contains filtered or unexported fields
}

func (*ResourcesSpec) Descriptor deprecated 

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

Deprecated: Use ResourcesSpec.ProtoReflect.Descriptor instead.

func (*ResourcesSpec) GetPlatform 

func (x *ResourcesSpec) GetPlatform() string

func (*ResourcesSpec) GetPreset 

func (x *ResourcesSpec) GetPreset() string

func (*ResourcesSpec) GetSize 

func (m *ResourcesSpec) GetSize() isResourcesSpec_Size

func (*ResourcesSpec) ProtoMessage 

func (*ResourcesSpec) ProtoMessage()

func (*ResourcesSpec) ProtoReflect 

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

func (*ResourcesSpec) Reset 

func (x *ResourcesSpec) Reset()

func (*ResourcesSpec) String 

func (x *ResourcesSpec) String() string

type ResourcesSpec_Preset 

type ResourcesSpec_Preset struct {
	Preset string `protobuf:"bytes,2,opt,name=preset,proto3,oneof"`
}

type UnimplementedClusterServiceServer 

type UnimplementedClusterServiceServer struct {
}

UnimplementedClusterServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedClusterServiceServer) Create 

func (UnimplementedClusterServiceServer) Create(context.Context, *CreateClusterRequest) (*v1.Operation, error)

func (UnimplementedClusterServiceServer) Delete 

func (UnimplementedClusterServiceServer) Delete(context.Context, *DeleteClusterRequest) (*v1.Operation, error)

func (UnimplementedClusterServiceServer) Get 

func (UnimplementedClusterServiceServer) Get(context.Context, *GetClusterRequest) (*Cluster, error)

func (UnimplementedClusterServiceServer) GetByName 

func (UnimplementedClusterServiceServer) GetByName(context.Context, *v1.GetByNameRequest) (*Cluster, error)

func (UnimplementedClusterServiceServer) List 

func (UnimplementedClusterServiceServer) List(context.Context, *ListClustersRequest) (*ListClustersResponse, error)

func (UnimplementedClusterServiceServer) Update 

func (UnimplementedClusterServiceServer) Update(context.Context, *UpdateClusterRequest) (*v1.Operation, error)

type UnimplementedNodeGroupServiceServer 

type UnimplementedNodeGroupServiceServer struct {
}

UnimplementedNodeGroupServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedNodeGroupServiceServer) Create 

func (UnimplementedNodeGroupServiceServer) Create(context.Context, *CreateNodeGroupRequest) (*v1.Operation, error)

func (UnimplementedNodeGroupServiceServer) Delete 

func (UnimplementedNodeGroupServiceServer) Delete(context.Context, *DeleteNodeGroupRequest) (*v1.Operation, error)

func (UnimplementedNodeGroupServiceServer) Get 

func (UnimplementedNodeGroupServiceServer) Get(context.Context, *GetNodeGroupRequest) (*NodeGroup, error)

func (UnimplementedNodeGroupServiceServer) GetByName 

func (UnimplementedNodeGroupServiceServer) GetByName(context.Context, *v1.GetByNameRequest) (*NodeGroup, error)

func (UnimplementedNodeGroupServiceServer) List 

func (UnimplementedNodeGroupServiceServer) List(context.Context, *ListNodeGroupsRequest) (*ListNodeGroupsResponse, error)

func (UnimplementedNodeGroupServiceServer) Update 

func (UnimplementedNodeGroupServiceServer) Update(context.Context, *UpdateNodeGroupRequest) (*v1.Operation, error)

func (UnimplementedNodeGroupServiceServer) Upgrade 

func (UnimplementedNodeGroupServiceServer) Upgrade(context.Context, *UpgradeNodeGroupRequest) (*v1.Operation, error)

type UnsafeClusterServiceServer 

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

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

type UnsafeNodeGroupServiceServer 

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

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

type UpdateClusterRequest 

type UpdateClusterRequest struct {

	// Metadata associated with the instance.
	// Includes ID of the instance to update.
	Metadata *v1.ResourceMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Updated specifications for the instance.
	Spec *ClusterSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateClusterRequest) Descriptor deprecated 

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

Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterRequest) GetMetadata 

func (x *UpdateClusterRequest) GetMetadata() *v1.ResourceMetadata

func (*UpdateClusterRequest) GetSpec 

func (x *UpdateClusterRequest) GetSpec() *ClusterSpec

func (*UpdateClusterRequest) ProtoMessage 

func (*UpdateClusterRequest) ProtoMessage()

func (*UpdateClusterRequest) ProtoReflect 

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

func (*UpdateClusterRequest) Reset 

func (x *UpdateClusterRequest) Reset()

func (*UpdateClusterRequest) String 

func (x *UpdateClusterRequest) String() string

type UpdateNodeGroupRequest 

type UpdateNodeGroupRequest struct {
	Metadata *v1.ResourceMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec     *NodeGroupSpec       `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNodeGroupRequest) Descriptor deprecated 

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

Deprecated: Use UpdateNodeGroupRequest.ProtoReflect.Descriptor instead.

func (*UpdateNodeGroupRequest) GetMetadata 

func (x *UpdateNodeGroupRequest) GetMetadata() *v1.ResourceMetadata

func (*UpdateNodeGroupRequest) GetSpec 

func (x *UpdateNodeGroupRequest) GetSpec() *NodeGroupSpec

func (*UpdateNodeGroupRequest) LogValue 

func (x *UpdateNodeGroupRequest) LogValue() slog.Value

LogValue implements slog.LogValuer interface. It returns sanitized copy of UpdateNodeGroupRequest. Properly implemented slog.Handler must call LogValue, so sensitive values are not logged. Sensitive strings and bytes are masked with "**HIDDEN**", other sensitive fields are omitted.

Returning value has kind slog.KindAny. To extract proto.Message, use the following code: 

var original *UpdateNodeGroupRequest
sanitized := original.LogValue().Any().(proto.Message)

If you need to extract UpdateNodeGroupRequest, use the following code: 

var original *UpdateNodeGroupRequest
sanitized := original.LogValue().Any().(proto.Message).ProtoReflect().Interface().(*UpdateNodeGroupRequest)

func (*UpdateNodeGroupRequest) ProtoMessage 

func (*UpdateNodeGroupRequest) ProtoMessage()

func (*UpdateNodeGroupRequest) ProtoReflect 

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

func (*UpdateNodeGroupRequest) Reset 

func (x *UpdateNodeGroupRequest) Reset()

func (*UpdateNodeGroupRequest) Sanitize 

func (x *UpdateNodeGroupRequest) Sanitize()

Sanitize mutates UpdateNodeGroupRequest to remove/mask all sensitive values. Sensitive fields are marked with [(nebius.sensitive) = true].

func (*UpdateNodeGroupRequest) String 

func (x *UpdateNodeGroupRequest) String() string

type UpgradeNodeGroupRequest 

type UpgradeNodeGroupRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to UpgradeType:
	//
	//	*UpgradeNodeGroupRequest_LatestInfraVersion
	UpgradeType isUpgradeNodeGroupRequest_UpgradeType `protobuf_oneof:"upgrade_type"`
	// contains filtered or unexported fields
}

func (*UpgradeNodeGroupRequest) Descriptor deprecated 

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

Deprecated: Use UpgradeNodeGroupRequest.ProtoReflect.Descriptor instead.

func (*UpgradeNodeGroupRequest) GetId 

func (x *UpgradeNodeGroupRequest) GetId() string

func (*UpgradeNodeGroupRequest) GetLatestInfraVersion 

func (x *UpgradeNodeGroupRequest) GetLatestInfraVersion() *emptypb.Empty

func (*UpgradeNodeGroupRequest) GetUpgradeType 

func (m *UpgradeNodeGroupRequest) GetUpgradeType() isUpgradeNodeGroupRequest_UpgradeType

func (*UpgradeNodeGroupRequest) ProtoMessage 

func (*UpgradeNodeGroupRequest) ProtoMessage()

func (*UpgradeNodeGroupRequest) ProtoReflect 

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

func (*UpgradeNodeGroupRequest) Reset 

func (x *UpgradeNodeGroupRequest) Reset()

func (*UpgradeNodeGroupRequest) String 

func (x *UpgradeNodeGroupRequest) String() string

type UpgradeNodeGroupRequest_LatestInfraVersion 

type UpgradeNodeGroupRequest_LatestInfraVersion struct {
	// Upgrades to the latest infra version, which includes latest supported kubernetes patch version. Kubernetes minor version remain the same.
	LatestInfraVersion *emptypb.Empty `protobuf:"bytes,2,opt,name=latest_infra_version,json=latestInfraVersion,proto3,oneof"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.