v1

package
v1.8.0 Latest Latest
Warning

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

Go to latest
Published: Jul 10, 2025 License: Apache-2.0 Imports: 17 Imported by: 1

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var ClustersInternalService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.clusters.server.v1.ClustersInternalService",
	HandlerType: (*ClustersInternalServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListInternalClusters",
			Handler:    _ClustersInternalService_ListInternalClusters_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/cluster_manager_server_internal.proto",
}

ClustersInternalService_ServiceDesc is the grpc.ServiceDesc for ClustersInternalService 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 ClustersService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.clusters.server.v1.ClustersService",
	HandlerType: (*ClustersServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateCluster",
			Handler:    _ClustersService_CreateCluster_Handler,
		},
		{
			MethodName: "ListClusters",
			Handler:    _ClustersService_ListClusters_Handler,
		},
		{
			MethodName: "GetCluster",
			Handler:    _ClustersService_GetCluster_Handler,
		},
		{
			MethodName: "DeleteCluster",
			Handler:    _ClustersService_DeleteCluster_Handler,
		},
		{
			MethodName: "CreateClusterConfig",
			Handler:    _ClustersService_CreateClusterConfig_Handler,
		},
		{
			MethodName: "GetClusterConfig",
			Handler:    _ClustersService_GetClusterConfig_Handler,
		},
		{
			MethodName: "UpdateClusterConfig",
			Handler:    _ClustersService_UpdateClusterConfig_Handler,
		},
		{
			MethodName: "DeleteClusterConfig",
			Handler:    _ClustersService_DeleteClusterConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/cluster_manager_server.proto",
}

ClustersService_ServiceDesc is the grpc.ServiceDesc for ClustersService 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 ClustersWorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.clusters.server.v1.ClustersWorkerService",
	HandlerType: (*ClustersWorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateComponentStatus",
			Handler:    _ClustersWorkerService_UpdateComponentStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/cluster_manager_server_worker.proto",
}

ClustersWorkerService_ServiceDesc is the grpc.ServiceDesc for ClustersWorkerService 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_api_v1_cluster_manager_server_internal_proto protoreflect.FileDescriptor
View Source
var File_api_v1_cluster_manager_server_proto protoreflect.FileDescriptor
View Source
var File_api_v1_cluster_manager_server_worker_proto protoreflect.FileDescriptor

Functions

func RegisterClustersInternalServiceServer

func RegisterClustersInternalServiceServer(s grpc.ServiceRegistrar, srv ClustersInternalServiceServer)

func RegisterClustersServiceHandler

func RegisterClustersServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterClustersServiceHandler registers the http handlers for service ClustersService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterClustersServiceHandlerClient

func RegisterClustersServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ClustersServiceClient) error

RegisterClustersServiceHandlerClient registers the http handlers for service ClustersService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ClustersServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ClustersServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ClustersServiceClient" to call the correct interceptors.

func RegisterClustersServiceHandlerFromEndpoint

func RegisterClustersServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterClustersServiceHandlerFromEndpoint is same as RegisterClustersServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterClustersServiceHandlerServer

func RegisterClustersServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ClustersServiceServer) error

RegisterClustersServiceHandlerServer registers the http handlers for service ClustersService to "mux". UnaryRPC :call ClustersServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterClustersServiceHandlerFromEndpoint instead.

func RegisterClustersServiceServer

func RegisterClustersServiceServer(s grpc.ServiceRegistrar, srv ClustersServiceServer)

func RegisterClustersWorkerServiceServer

func RegisterClustersWorkerServiceServer(s grpc.ServiceRegistrar, srv ClustersWorkerServiceServer)

Types

type Cluster

type Cluster struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// registration_key is the key used to register the cluster. Only populated
	// when a new cluster is created or from internal gRPC service.
	RegistrationKey string `protobuf:"bytes,3,opt,name=registration_key,json=registrationKey,proto3" json:"registration_key,omitempty"`
	Object          string `protobuf:"bytes,4,opt,name=object,proto3" json:"object,omitempty"`
	// components_statuses is keyed by component name.
	ComponentStatuses map[string]*ComponentStatus `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor deprecated

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetComponentStatuses added in v1.5.2

func (x *Cluster) GetComponentStatuses() map[string]*ComponentStatus

func (*Cluster) GetId

func (x *Cluster) GetId() string

func (*Cluster) GetName

func (x *Cluster) GetName() string

func (*Cluster) GetObject

func (x *Cluster) GetObject() string

func (*Cluster) GetRegistrationKey

func (x *Cluster) GetRegistrationKey() string

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 ClusterConfig added in v1.7.0

type ClusterConfig struct {
	DevicePluginConfig *DevicePluginConfig `protobuf:"bytes,1,opt,name=device_plugin_config,json=devicePluginConfig,proto3" json:"device_plugin_config,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterConfig) Descriptor deprecated added in v1.7.0

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

Deprecated: Use ClusterConfig.ProtoReflect.Descriptor instead.

func (*ClusterConfig) GetDevicePluginConfig added in v1.7.0

func (x *ClusterConfig) GetDevicePluginConfig() *DevicePluginConfig

func (*ClusterConfig) ProtoMessage added in v1.7.0

func (*ClusterConfig) ProtoMessage()

func (*ClusterConfig) ProtoReflect added in v1.7.0

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

func (*ClusterConfig) Reset added in v1.7.0

func (x *ClusterConfig) Reset()

func (*ClusterConfig) String added in v1.7.0

func (x *ClusterConfig) String() string

type ClustersInternalServiceClient

type ClustersInternalServiceClient interface {
	ListInternalClusters(ctx context.Context, in *ListInternalClustersRequest, opts ...grpc.CallOption) (*ListInternalClustersResponse, error)
}

ClustersInternalServiceClient is the client API for ClustersInternalService 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.

type ClustersInternalServiceServer

type ClustersInternalServiceServer interface {
	ListInternalClusters(context.Context, *ListInternalClustersRequest) (*ListInternalClustersResponse, error)
	// contains filtered or unexported methods
}

ClustersInternalServiceServer is the server API for ClustersInternalService service. All implementations must embed UnimplementedClustersInternalServiceServer for forward compatibility

type ClustersServiceClient

type ClustersServiceClient interface {
	CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
	DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*DeleteClusterResponse, error)
	CreateClusterConfig(ctx context.Context, in *CreateClusterConfigRequest, opts ...grpc.CallOption) (*ClusterConfig, error)
	GetClusterConfig(ctx context.Context, in *GetClusterConfigRequest, opts ...grpc.CallOption) (*ClusterConfig, error)
	UpdateClusterConfig(ctx context.Context, in *UpdateClusterConfigRequest, opts ...grpc.CallOption) (*ClusterConfig, error)
	DeleteClusterConfig(ctx context.Context, in *DeleteClusterConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ClustersServiceClient is the client API for ClustersService 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.

type ClustersServiceServer

type ClustersServiceServer interface {
	CreateCluster(context.Context, *CreateClusterRequest) (*Cluster, error)
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	GetCluster(context.Context, *GetClusterRequest) (*Cluster, error)
	DeleteCluster(context.Context, *DeleteClusterRequest) (*DeleteClusterResponse, error)
	CreateClusterConfig(context.Context, *CreateClusterConfigRequest) (*ClusterConfig, error)
	GetClusterConfig(context.Context, *GetClusterConfigRequest) (*ClusterConfig, error)
	UpdateClusterConfig(context.Context, *UpdateClusterConfigRequest) (*ClusterConfig, error)
	DeleteClusterConfig(context.Context, *DeleteClusterConfigRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ClustersServiceServer is the server API for ClustersService service. All implementations must embed UnimplementedClustersServiceServer for forward compatibility

type ClustersWorkerServiceClient

type ClustersWorkerServiceClient interface {
	// UpdateComponentStatus updates the component's health status to the cluster.
	UpdateComponentStatus(ctx context.Context, in *UpdateComponentStatusRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ClustersWorkerServiceClient is the client API for ClustersWorkerService 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.

type ClustersWorkerServiceServer

type ClustersWorkerServiceServer interface {
	// UpdateComponentStatus updates the component's health status to the cluster.
	UpdateComponentStatus(context.Context, *UpdateComponentStatusRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ClustersWorkerServiceServer is the server API for ClustersWorkerService service. All implementations must embed UnimplementedClustersWorkerServiceServer for forward compatibility

type ComponentStatus added in v1.3.0

type ComponentStatus struct {
	IsHealthy bool   `protobuf:"varint,1,opt,name=is_healthy,json=isHealthy,proto3" json:"is_healthy,omitempty"`
	Message   string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ComponentStatus.ProtoReflect.Descriptor instead.

func (*ComponentStatus) GetIsHealthy added in v1.3.0

func (x *ComponentStatus) GetIsHealthy() bool

func (*ComponentStatus) GetMessage added in v1.3.0

func (x *ComponentStatus) GetMessage() string

func (*ComponentStatus) ProtoMessage added in v1.3.0

func (*ComponentStatus) ProtoMessage()

func (*ComponentStatus) ProtoReflect added in v1.3.0

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

func (*ComponentStatus) Reset added in v1.3.0

func (x *ComponentStatus) Reset()

func (*ComponentStatus) String added in v1.3.0

func (x *ComponentStatus) String() string

type CreateClusterConfigRequest added in v1.7.0

type CreateClusterConfigRequest struct {
	ClusterId          string              `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	DevicePluginConfig *DevicePluginConfig `protobuf:"bytes,2,opt,name=device_plugin_config,json=devicePluginConfig,proto3" json:"device_plugin_config,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateClusterConfigRequest) Descriptor deprecated added in v1.7.0

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

Deprecated: Use CreateClusterConfigRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterConfigRequest) GetClusterId added in v1.7.0

func (x *CreateClusterConfigRequest) GetClusterId() string

func (*CreateClusterConfigRequest) GetDevicePluginConfig added in v1.7.0

func (x *CreateClusterConfigRequest) GetDevicePluginConfig() *DevicePluginConfig

func (*CreateClusterConfigRequest) ProtoMessage added in v1.7.0

func (*CreateClusterConfigRequest) ProtoMessage()

func (*CreateClusterConfigRequest) ProtoReflect added in v1.7.0

func (*CreateClusterConfigRequest) Reset added in v1.7.0

func (x *CreateClusterConfigRequest) Reset()

func (*CreateClusterConfigRequest) String added in v1.7.0

func (x *CreateClusterConfigRequest) String() string

type CreateClusterRequest

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

func (*CreateClusterRequest) Descriptor deprecated

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

Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterRequest) GetName

func (x *CreateClusterRequest) GetName() string

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 DeleteClusterConfigRequest added in v1.7.0

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

func (*DeleteClusterConfigRequest) Descriptor deprecated added in v1.7.0

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

Deprecated: Use DeleteClusterConfigRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterConfigRequest) GetClusterId added in v1.7.0

func (x *DeleteClusterConfigRequest) GetClusterId() string

func (*DeleteClusterConfigRequest) ProtoMessage added in v1.7.0

func (*DeleteClusterConfigRequest) ProtoMessage()

func (*DeleteClusterConfigRequest) ProtoReflect added in v1.7.0

func (*DeleteClusterConfigRequest) Reset added in v1.7.0

func (x *DeleteClusterConfigRequest) Reset()

func (*DeleteClusterConfigRequest) String added in v1.7.0

func (x *DeleteClusterConfigRequest) 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 DeleteClusterResponse

type DeleteClusterResponse struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Object  string `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	Deleted bool   `protobuf:"varint,3,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteClusterResponse) Descriptor deprecated

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

Deprecated: Use DeleteClusterResponse.ProtoReflect.Descriptor instead.

func (*DeleteClusterResponse) GetDeleted

func (x *DeleteClusterResponse) GetDeleted() bool

func (*DeleteClusterResponse) GetId

func (x *DeleteClusterResponse) GetId() string

func (*DeleteClusterResponse) GetObject

func (x *DeleteClusterResponse) GetObject() string

func (*DeleteClusterResponse) ProtoMessage

func (*DeleteClusterResponse) ProtoMessage()

func (*DeleteClusterResponse) ProtoReflect

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

func (*DeleteClusterResponse) Reset

func (x *DeleteClusterResponse) Reset()

func (*DeleteClusterResponse) String

func (x *DeleteClusterResponse) String() string

type DevicePluginConfig added in v1.7.0

type DevicePluginConfig struct {
	TimeSlicing *DevicePluginConfig_TimeSlicing `protobuf:"bytes,1,opt,name=time_slicing,json=timeSlicing,proto3" json:"time_slicing,omitempty"`
	// contains filtered or unexported fields
}

Follow https://docs.nvidia.com/datacenter/cloud-native/gpu-operator/latest/gpu-sharing.html.

func (*DevicePluginConfig) Descriptor deprecated added in v1.7.0

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

Deprecated: Use DevicePluginConfig.ProtoReflect.Descriptor instead.

func (*DevicePluginConfig) GetTimeSlicing added in v1.7.0

func (*DevicePluginConfig) ProtoMessage added in v1.7.0

func (*DevicePluginConfig) ProtoMessage()

func (*DevicePluginConfig) ProtoReflect added in v1.7.0

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

func (*DevicePluginConfig) Reset added in v1.7.0

func (x *DevicePluginConfig) Reset()

func (*DevicePluginConfig) String added in v1.7.0

func (x *DevicePluginConfig) String() string

type DevicePluginConfig_TimeSlicing added in v1.7.0

type DevicePluginConfig_TimeSlicing struct {
	Gpus int32 `protobuf:"varint,1,opt,name=gpus,proto3" json:"gpus,omitempty"`
	// contains filtered or unexported fields
}

func (*DevicePluginConfig_TimeSlicing) Descriptor deprecated added in v1.7.0

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

Deprecated: Use DevicePluginConfig_TimeSlicing.ProtoReflect.Descriptor instead.

func (*DevicePluginConfig_TimeSlicing) GetGpus added in v1.7.0

func (*DevicePluginConfig_TimeSlicing) ProtoMessage added in v1.7.0

func (*DevicePluginConfig_TimeSlicing) ProtoMessage()

func (*DevicePluginConfig_TimeSlicing) ProtoReflect added in v1.7.0

func (*DevicePluginConfig_TimeSlicing) Reset added in v1.7.0

func (x *DevicePluginConfig_TimeSlicing) Reset()

func (*DevicePluginConfig_TimeSlicing) String added in v1.7.0

type GetClusterConfigRequest added in v1.7.0

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

func (*GetClusterConfigRequest) Descriptor deprecated added in v1.7.0

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

Deprecated: Use GetClusterConfigRequest.ProtoReflect.Descriptor instead.

func (*GetClusterConfigRequest) GetClusterId added in v1.7.0

func (x *GetClusterConfigRequest) GetClusterId() string

func (*GetClusterConfigRequest) ProtoMessage added in v1.7.0

func (*GetClusterConfigRequest) ProtoMessage()

func (*GetClusterConfigRequest) ProtoReflect added in v1.7.0

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

func (*GetClusterConfigRequest) Reset added in v1.7.0

func (x *GetClusterConfigRequest) Reset()

func (*GetClusterConfigRequest) String added in v1.7.0

func (x *GetClusterConfigRequest) String() string

type GetClusterRequest

type GetClusterRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,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) 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 InternalCluster

type InternalCluster struct {
	Cluster  *Cluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	TenantId string   `protobuf:"bytes,2,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*InternalCluster) Descriptor deprecated

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

Deprecated: Use InternalCluster.ProtoReflect.Descriptor instead.

func (*InternalCluster) GetCluster

func (x *InternalCluster) GetCluster() *Cluster

func (*InternalCluster) GetTenantId

func (x *InternalCluster) GetTenantId() string

func (*InternalCluster) ProtoMessage

func (*InternalCluster) ProtoMessage()

func (*InternalCluster) ProtoReflect

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

func (*InternalCluster) Reset

func (x *InternalCluster) Reset()

func (*InternalCluster) String

func (x *InternalCluster) String() string

type ListClustersRequest

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

func (*ListClustersRequest) Descriptor deprecated

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

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

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 {
	Object string     `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Data   []*Cluster `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClustersResponse) Descriptor deprecated

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

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) GetData

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

func (*ListClustersResponse) GetObject

func (x *ListClustersResponse) GetObject() 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 ListInternalClustersRequest

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

func (*ListInternalClustersRequest) Descriptor deprecated

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

Deprecated: Use ListInternalClustersRequest.ProtoReflect.Descriptor instead.

func (*ListInternalClustersRequest) ProtoMessage

func (*ListInternalClustersRequest) ProtoMessage()

func (*ListInternalClustersRequest) ProtoReflect

func (*ListInternalClustersRequest) Reset

func (x *ListInternalClustersRequest) Reset()

func (*ListInternalClustersRequest) String

func (x *ListInternalClustersRequest) String() string

type ListInternalClustersResponse

type ListInternalClustersResponse struct {
	Clusters []*InternalCluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListInternalClustersResponse) Descriptor deprecated

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

Deprecated: Use ListInternalClustersResponse.ProtoReflect.Descriptor instead.

func (*ListInternalClustersResponse) GetClusters

func (x *ListInternalClustersResponse) GetClusters() []*InternalCluster

func (*ListInternalClustersResponse) ProtoMessage

func (*ListInternalClustersResponse) ProtoMessage()

func (*ListInternalClustersResponse) ProtoReflect

func (*ListInternalClustersResponse) Reset

func (x *ListInternalClustersResponse) Reset()

func (*ListInternalClustersResponse) String

type UnimplementedClustersInternalServiceServer

type UnimplementedClustersInternalServiceServer struct {
}

UnimplementedClustersInternalServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedClustersInternalServiceServer) ListInternalClusters

type UnimplementedClustersServiceServer

type UnimplementedClustersServiceServer struct {
}

UnimplementedClustersServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedClustersServiceServer) CreateCluster

func (UnimplementedClustersServiceServer) CreateClusterConfig added in v1.7.0

func (UnimplementedClustersServiceServer) DeleteCluster

func (UnimplementedClustersServiceServer) DeleteClusterConfig added in v1.7.0

func (UnimplementedClustersServiceServer) GetCluster

func (UnimplementedClustersServiceServer) GetClusterConfig added in v1.7.0

func (UnimplementedClustersServiceServer) ListClusters

func (UnimplementedClustersServiceServer) UpdateClusterConfig added in v1.7.0

type UnimplementedClustersWorkerServiceServer

type UnimplementedClustersWorkerServiceServer struct {
}

UnimplementedClustersWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedClustersWorkerServiceServer) UpdateComponentStatus added in v1.3.0

type UnsafeClustersInternalServiceServer

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

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

type UnsafeClustersServiceServer

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

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

type UnsafeClustersWorkerServiceServer

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

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

type UpdateClusterConfigRequest added in v1.7.0

type UpdateClusterConfigRequest struct {
	ClusterId          string              `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	DevicePluginConfig *DevicePluginConfig `protobuf:"bytes,2,opt,name=device_plugin_config,json=devicePluginConfig,proto3" json:"device_plugin_config,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateClusterConfigRequest) Descriptor deprecated added in v1.7.0

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

Deprecated: Use UpdateClusterConfigRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterConfigRequest) GetClusterId added in v1.7.0

func (x *UpdateClusterConfigRequest) GetClusterId() string

func (*UpdateClusterConfigRequest) GetDevicePluginConfig added in v1.7.0

func (x *UpdateClusterConfigRequest) GetDevicePluginConfig() *DevicePluginConfig

func (*UpdateClusterConfigRequest) ProtoMessage added in v1.7.0

func (*UpdateClusterConfigRequest) ProtoMessage()

func (*UpdateClusterConfigRequest) ProtoReflect added in v1.7.0

func (*UpdateClusterConfigRequest) Reset added in v1.7.0

func (x *UpdateClusterConfigRequest) Reset()

func (*UpdateClusterConfigRequest) String added in v1.7.0

func (x *UpdateClusterConfigRequest) String() string

type UpdateComponentStatusRequest added in v1.3.0

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

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

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

Deprecated: Use UpdateComponentStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateComponentStatusRequest) GetName added in v1.3.0

func (x *UpdateComponentStatusRequest) GetName() string

func (*UpdateComponentStatusRequest) GetStatus added in v1.3.0

func (*UpdateComponentStatusRequest) ProtoMessage added in v1.3.0

func (*UpdateComponentStatusRequest) ProtoMessage()

func (*UpdateComponentStatusRequest) ProtoReflect added in v1.3.0

func (*UpdateComponentStatusRequest) Reset added in v1.3.0

func (x *UpdateComponentStatusRequest) Reset()

func (*UpdateComponentStatusRequest) String added in v1.3.0

Jump to

Keyboard shortcuts

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