apiv1connect

package
v0.0.76 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	// ClusterServiceGetClustersBasicInfoProcedure is the fully-qualified name of the ClusterService's
	// GetClustersBasicInfo RPC.
	ClusterServiceGetClustersBasicInfoProcedure = "/api.v1.ClusterService/GetClustersBasicInfo"
	// ClusterServiceGetClustersWithMetricsProcedure is the fully-qualified name of the ClusterService's
	// GetClustersWithMetrics RPC.
	ClusterServiceGetClustersWithMetricsProcedure = "/api.v1.ClusterService/GetClustersWithMetrics"
	// ClusterServiceCreateClusterTokenProcedure is the fully-qualified name of the ClusterService's
	// CreateClusterToken RPC.
	ClusterServiceCreateClusterTokenProcedure = "/api.v1.ClusterService/CreateClusterToken"
	// ClusterServiceGetClustersDeltaMetricsProcedure is the fully-qualified name of the
	// ClusterService's GetClustersDeltaMetrics RPC.
	ClusterServiceGetClustersDeltaMetricsProcedure = "/api.v1.ClusterService/GetClustersDeltaMetrics"
	// ClusterServiceGetNetworkDependenciesProcedure is the fully-qualified name of the ClusterService's
	// GetNetworkDependencies RPC.
	ClusterServiceGetNetworkDependenciesProcedure = "/api.v1.ClusterService/GetNetworkDependencies"
	// ClusterServiceGetNetworkMetricsTimeSeriesProcedure is the fully-qualified name of the
	// ClusterService's GetNetworkMetricsTimeSeries RPC.
	ClusterServiceGetNetworkMetricsTimeSeriesProcedure = "/api.v1.ClusterService/GetNetworkMetricsTimeSeries"
	// ClusterServiceGetNodeTypeCountsProcedure is the fully-qualified name of the ClusterService's
	// GetNodeTypeCounts RPC.
	ClusterServiceGetNodeTypeCountsProcedure = "/api.v1.ClusterService/GetNodeTypeCounts"
	// ClusterServiceGetClusterIDByNameProcedure is the fully-qualified name of the ClusterService's
	// GetClusterIDByName RPC.
	ClusterServiceGetClusterIDByNameProcedure = "/api.v1.ClusterService/GetClusterIDByName"
	// ClusterServiceGetClusterInfoByNameProcedure is the fully-qualified name of the ClusterService's
	// GetClusterInfoByName RPC.
	ClusterServiceGetClusterInfoByNameProcedure = "/api.v1.ClusterService/GetClusterInfoByName"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// InstanceServiceGetInstanceProcedure is the fully-qualified name of the InstanceService's
	// GetInstance RPC.
	InstanceServiceGetInstanceProcedure = "/api.v1.InstanceService/GetInstance"
	// InstanceServiceGetInstancesProcedure is the fully-qualified name of the InstanceService's
	// GetInstances RPC.
	InstanceServiceGetInstancesProcedure = "/api.v1.InstanceService/GetInstances"
	// InstanceServiceGetInstanceTypeProcedure is the fully-qualified name of the InstanceService's
	// GetInstanceType RPC.
	InstanceServiceGetInstanceTypeProcedure = "/api.v1.InstanceService/GetInstanceType"
	// InstanceServiceGetInstanceTypesProcedure is the fully-qualified name of the InstanceService's
	// GetInstanceTypes RPC.
	InstanceServiceGetInstanceTypesProcedure = "/api.v1.InstanceService/GetInstanceTypes"
	// InstanceServiceGetRegionProcedure is the fully-qualified name of the InstanceService's GetRegion
	// RPC.
	InstanceServiceGetRegionProcedure = "/api.v1.InstanceService/GetRegion"
	// InstanceServiceGetRegionsProcedure is the fully-qualified name of the InstanceService's
	// GetRegions RPC.
	InstanceServiceGetRegionsProcedure = "/api.v1.InstanceService/GetRegions"
	// InstanceServiceGetAvailabilityZoneProcedure is the fully-qualified name of the InstanceService's
	// GetAvailabilityZone RPC.
	InstanceServiceGetAvailabilityZoneProcedure = "/api.v1.InstanceService/GetAvailabilityZone"
	// InstanceServiceGetAvailabilityZonesProcedure is the fully-qualified name of the InstanceService's
	// GetAvailabilityZones RPC.
	InstanceServiceGetAvailabilityZonesProcedure = "/api.v1.InstanceService/GetAvailabilityZones"
	// InstanceServiceGetOperatingSystemProcedure is the fully-qualified name of the InstanceService's
	// GetOperatingSystem RPC.
	InstanceServiceGetOperatingSystemProcedure = "/api.v1.InstanceService/GetOperatingSystem"
	// InstanceServiceGetOperatingSystemsProcedure is the fully-qualified name of the InstanceService's
	// GetOperatingSystems RPC.
	InstanceServiceGetOperatingSystemsProcedure = "/api.v1.InstanceService/GetOperatingSystems"
	// InstanceServiceGetCloudProviderProcedure is the fully-qualified name of the InstanceService's
	// GetCloudProvider RPC.
	InstanceServiceGetCloudProviderProcedure = "/api.v1.InstanceService/GetCloudProvider"
	// InstanceServiceGetCloudProvidersProcedure is the fully-qualified name of the InstanceService's
	// GetCloudProviders RPC.
	InstanceServiceGetCloudProvidersProcedure = "/api.v1.InstanceService/GetCloudProviders"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// K8SServiceName is the fully-qualified name of the K8SService service.
	K8SServiceName = "api.v1.K8SService"
	// ClusterMutationServiceName is the fully-qualified name of the ClusterMutationService service.
	ClusterMutationServiceName = "api.v1.ClusterMutationService"
	// UtilizationServiceName is the fully-qualified name of the UtilizationService service.
	UtilizationServiceName = "api.v1.UtilizationService"
)
View Source 
const (
	// K8SServiceGetWorkloadsStatsProcedure is the fully-qualified name of the K8SService's
	// GetWorkloadsStats RPC.
	K8SServiceGetWorkloadsStatsProcedure = "/api.v1.K8SService/GetWorkloadsStats"
	// K8SServiceGetClustersProcedure is the fully-qualified name of the K8SService's GetClusters RPC.
	K8SServiceGetClustersProcedure = "/api.v1.K8SService/GetClusters"
	// K8SServiceListClustersProcedure is the fully-qualified name of the K8SService's ListClusters RPC.
	K8SServiceListClustersProcedure = "/api.v1.K8SService/ListClusters"
	// K8SServiceGetClusterProcedure is the fully-qualified name of the K8SService's GetCluster RPC.
	K8SServiceGetClusterProcedure = "/api.v1.K8SService/GetCluster"
	// K8SServiceGetClusterMetadataProcedure is the fully-qualified name of the K8SService's
	// GetClusterMetadata RPC.
	K8SServiceGetClusterMetadataProcedure = "/api.v1.K8SService/GetClusterMetadata"
	// K8SServiceGetAllNamespacesProcedure is the fully-qualified name of the K8SService's
	// GetAllNamespaces RPC.
	K8SServiceGetAllNamespacesProcedure = "/api.v1.K8SService/GetAllNamespaces"
	// K8SServiceSearchNamespacesByClusterProcedure is the fully-qualified name of the K8SService's
	// SearchNamespacesByCluster RPC.
	K8SServiceSearchNamespacesByClusterProcedure = "/api.v1.K8SService/SearchNamespacesByCluster"
	// K8SServiceListNamespacesByClusterProcedure is the fully-qualified name of the K8SService's
	// ListNamespacesByCluster RPC.
	K8SServiceListNamespacesByClusterProcedure = "/api.v1.K8SService/ListNamespacesByCluster"
	// K8SServiceGetAllWorkloadNamesProcedure is the fully-qualified name of the K8SService's
	// GetAllWorkloadNames RPC.
	K8SServiceGetAllWorkloadNamesProcedure = "/api.v1.K8SService/GetAllWorkloadNames"
	// K8SServiceGetAllWorkloadLabelsProcedure is the fully-qualified name of the K8SService's
	// GetAllWorkloadLabels RPC.
	K8SServiceGetAllWorkloadLabelsProcedure = "/api.v1.K8SService/GetAllWorkloadLabels"
	// K8SServiceGetAllNodeGroupNamesProcedure is the fully-qualified name of the K8SService's
	// GetAllNodeGroupNames RPC.
	K8SServiceGetAllNodeGroupNamesProcedure = "/api.v1.K8SService/GetAllNodeGroupNames"
	// K8SServiceMetadataForWorkloadsProcedure is the fully-qualified name of the K8SService's
	// MetadataForWorkloads RPC.
	K8SServiceMetadataForWorkloadsProcedure = "/api.v1.K8SService/MetadataForWorkloads"
	// K8SServiceGetNodeGroupsProcedure is the fully-qualified name of the K8SService's GetNodeGroups
	// RPC.
	K8SServiceGetNodeGroupsProcedure = "/api.v1.K8SService/GetNodeGroups"
	// K8SServiceGetAllNodeGroupsProcedure is the fully-qualified name of the K8SService's
	// GetAllNodeGroups RPC.
	K8SServiceGetAllNodeGroupsProcedure = "/api.v1.K8SService/GetAllNodeGroups"
	// K8SServiceGetNodeGroupsUtilizationProcedure is the fully-qualified name of the K8SService's
	// GetNodeGroupsUtilization RPC.
	K8SServiceGetNodeGroupsUtilizationProcedure = "/api.v1.K8SService/GetNodeGroupsUtilization"
	// K8SServiceGetNodeGroupProcedure is the fully-qualified name of the K8SService's GetNodeGroup RPC.
	K8SServiceGetNodeGroupProcedure = "/api.v1.K8SService/GetNodeGroup"
	// K8SServiceGetNodeProcedure is the fully-qualified name of the K8SService's GetNode RPC.
	K8SServiceGetNodeProcedure = "/api.v1.K8SService/GetNode"
	// K8SServiceGetWorkloadsProcedure is the fully-qualified name of the K8SService's GetWorkloads RPC.
	K8SServiceGetWorkloadsProcedure = "/api.v1.K8SService/GetWorkloads"
	// K8SServiceGetWorkloadProcedure is the fully-qualified name of the K8SService's GetWorkload RPC.
	K8SServiceGetWorkloadProcedure = "/api.v1.K8SService/GetWorkload"
	// K8SServiceGetWorkloadContainerPercentilesProcedure is the fully-qualified name of the
	// K8SService's GetWorkloadContainerPercentiles RPC.
	K8SServiceGetWorkloadContainerPercentilesProcedure = "/api.v1.K8SService/GetWorkloadContainerPercentiles"
	// K8SServiceGetWorkloadContainerTimeSeriesProcedure is the fully-qualified name of the K8SService's
	// GetWorkloadContainerTimeSeries RPC.
	K8SServiceGetWorkloadContainerTimeSeriesProcedure = "/api.v1.K8SService/GetWorkloadContainerTimeSeries"
	// K8SServiceGetLatestContainerRequestLimitsProcedure is the fully-qualified name of the
	// K8SService's GetLatestContainerRequestLimits RPC.
	K8SServiceGetLatestContainerRequestLimitsProcedure = "/api.v1.K8SService/GetLatestContainerRequestLimits"
	// K8SServiceGetForecastWorkloadsProcedure is the fully-qualified name of the K8SService's
	// GetForecastWorkloads RPC.
	K8SServiceGetForecastWorkloadsProcedure = "/api.v1.K8SService/GetForecastWorkloads"
	// K8SServiceGetForecastWorkloadProcedure is the fully-qualified name of the K8SService's
	// GetForecastWorkload RPC.
	K8SServiceGetForecastWorkloadProcedure = "/api.v1.K8SService/GetForecastWorkload"
	// K8SServiceGetResourcesProcedure is the fully-qualified name of the K8SService's GetResources RPC.
	K8SServiceGetResourcesProcedure = "/api.v1.K8SService/GetResources"
	// K8SServiceGetPodsProcedure is the fully-qualified name of the K8SService's GetPods RPC.
	K8SServiceGetPodsProcedure = "/api.v1.K8SService/GetPods"
	// K8SServiceGetLatestOperatorVersionProcedure is the fully-qualified name of the K8SService's
	// GetLatestOperatorVersion RPC.
	K8SServiceGetLatestOperatorVersionProcedure = "/api.v1.K8SService/GetLatestOperatorVersion"
	// K8SServiceGalaxyGetWorkloadPerspectiveProcedure is the fully-qualified name of the K8SService's
	// GalaxyGetWorkloadPerspective RPC.
	K8SServiceGalaxyGetWorkloadPerspectiveProcedure = "/api.v1.K8SService/GalaxyGetWorkloadPerspective"
	// K8SServiceListAuditLogsProcedure is the fully-qualified name of the K8SService's ListAuditLogs
	// RPC.
	K8SServiceListAuditLogsProcedure = "/api.v1.K8SService/ListAuditLogs"
	// K8SServiceListAuditLogOriginatorsProcedure is the fully-qualified name of the K8SService's
	// ListAuditLogOriginators RPC.
	K8SServiceListAuditLogOriginatorsProcedure = "/api.v1.K8SService/ListAuditLogOriginators"
	// K8SServiceSendWorkloadEmailProcedure is the fully-qualified name of the K8SService's
	// SendWorkloadEmail RPC.
	K8SServiceSendWorkloadEmailProcedure = "/api.v1.K8SService/SendWorkloadEmail"
	// K8SServiceSendWeeklySummaryEmailProcedure is the fully-qualified name of the K8SService's
	// SendWeeklySummaryEmail RPC.
	K8SServiceSendWeeklySummaryEmailProcedure = "/api.v1.K8SService/SendWeeklySummaryEmail"
	// K8SServiceGetClustersNodeInfoProcedure is the fully-qualified name of the K8SService's
	// GetClustersNodeInfo RPC.
	K8SServiceGetClustersNodeInfoProcedure = "/api.v1.K8SService/GetClustersNodeInfo"
	// K8SServiceSearchK8SResourcesProcedure is the fully-qualified name of the K8SService's
	// SearchK8sResources RPC.
	K8SServiceSearchK8SResourcesProcedure = "/api.v1.K8SService/SearchK8sResources"
	// K8SServiceSearchK8SWorkloadsProcedure is the fully-qualified name of the K8SService's
	// SearchK8sWorkloads RPC.
	K8SServiceSearchK8SWorkloadsProcedure = "/api.v1.K8SService/SearchK8sWorkloads"
	// K8SServiceGetClusterTypeProcedure is the fully-qualified name of the K8SService's GetClusterType
	// RPC.
	K8SServiceGetClusterTypeProcedure = "/api.v1.K8SService/GetClusterType"
	// K8SServiceGetRelationsForKindProcedure is the fully-qualified name of the K8SService's
	// GetRelationsForKind RPC.
	K8SServiceGetRelationsForKindProcedure = "/api.v1.K8SService/GetRelationsForKind"
	// K8SServiceLookupNodeInstanceProcedure is the fully-qualified name of the K8SService's
	// LookupNodeInstance RPC.
	K8SServiceLookupNodeInstanceProcedure = "/api.v1.K8SService/LookupNodeInstance"
	// K8SServiceGetWorkloadPodHistoryProcedure is the fully-qualified name of the K8SService's
	// GetWorkloadPodHistory RPC.
	K8SServiceGetWorkloadPodHistoryProcedure = "/api.v1.K8SService/GetWorkloadPodHistory"
	// K8SServiceAddClusterTagsProcedure is the fully-qualified name of the K8SService's AddClusterTags
	// RPC.
	K8SServiceAddClusterTagsProcedure = "/api.v1.K8SService/AddClusterTags"
	// K8SServiceRemoveClusterTagsProcedure is the fully-qualified name of the K8SService's
	// RemoveClusterTags RPC.
	K8SServiceRemoveClusterTagsProcedure = "/api.v1.K8SService/RemoveClusterTags"
	// K8SServiceListTagsProcedure is the fully-qualified name of the K8SService's ListTags RPC.
	K8SServiceListTagsProcedure = "/api.v1.K8SService/ListTags"
	// ClusterMutationServiceCreateClusterProcedure is the fully-qualified name of the
	// ClusterMutationService's CreateCluster RPC.
	ClusterMutationServiceCreateClusterProcedure = "/api.v1.ClusterMutationService/CreateCluster"
	// ClusterMutationServiceDeleteClusterProcedure is the fully-qualified name of the
	// ClusterMutationService's DeleteCluster RPC.
	ClusterMutationServiceDeleteClusterProcedure = "/api.v1.ClusterMutationService/DeleteCluster"
	// ClusterMutationServiceUpdateClusterProcedure is the fully-qualified name of the
	// ClusterMutationService's UpdateCluster RPC.
	ClusterMutationServiceUpdateClusterProcedure = "/api.v1.ClusterMutationService/UpdateCluster"
	// ClusterMutationServiceResetClusterTokenProcedure is the fully-qualified name of the
	// ClusterMutationService's ResetClusterToken RPC.
	ClusterMutationServiceResetClusterTokenProcedure = "/api.v1.ClusterMutationService/ResetClusterToken"
	// UtilizationServiceDailyUtilizationProcedure is the fully-qualified name of the
	// UtilizationService's DailyUtilization RPC.
	UtilizationServiceDailyUtilizationProcedure = "/api.v1.UtilizationService/DailyUtilization"
	// UtilizationServiceDailyUtilizationInstanceTypeProcedure is the fully-qualified name of the
	// UtilizationService's DailyUtilizationInstanceType RPC.
	UtilizationServiceDailyUtilizationInstanceTypeProcedure = "/api.v1.UtilizationService/DailyUtilizationInstanceType"
	// UtilizationServiceDailyUtilizationNodeTypeProcedure is the fully-qualified name of the
	// UtilizationService's DailyUtilizationNodeType RPC.
	UtilizationServiceDailyUtilizationNodeTypeProcedure = "/api.v1.UtilizationService/DailyUtilizationNodeType"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// MetricsCollectorServiceSendResourceProcedure is the fully-qualified name of the
	// MetricsCollectorService's SendResource RPC.
	MetricsCollectorServiceSendResourceProcedure = "/api.v1.MetricsCollectorService/SendResource"
	// MetricsCollectorServiceSendResourceBatchProcedure is the fully-qualified name of the
	// MetricsCollectorService's SendResourceBatch RPC.
	MetricsCollectorServiceSendResourceBatchProcedure = "/api.v1.MetricsCollectorService/SendResourceBatch"
	// MetricsCollectorServiceSendTelemetryMetricsProcedure is the fully-qualified name of the
	// MetricsCollectorService's SendTelemetryMetrics RPC.
	MetricsCollectorServiceSendTelemetryMetricsProcedure = "/api.v1.MetricsCollectorService/SendTelemetryMetrics"
	// MetricsCollectorServiceSendClusterSnapshotStreamProcedure is the fully-qualified name of the
	// MetricsCollectorService's SendClusterSnapshotStream RPC.
	MetricsCollectorServiceSendClusterSnapshotStreamProcedure = "/api.v1.MetricsCollectorService/SendClusterSnapshotStream"
	// MetricsCollectorServiceSendTelemetryLogsProcedure is the fully-qualified name of the
	// MetricsCollectorService's SendTelemetryLogs RPC.
	MetricsCollectorServiceSendTelemetryLogsProcedure = "/api.v1.MetricsCollectorService/SendTelemetryLogs"
	// MetricsCollectorServiceSendNetworkTrafficMetricsProcedure is the fully-qualified name of the
	// MetricsCollectorService's SendNetworkTrafficMetrics RPC.
	MetricsCollectorServiceSendNetworkTrafficMetricsProcedure = "/api.v1.MetricsCollectorService/SendNetworkTrafficMetrics"
	// MetricsCollectorServiceNodeMetadataProcedure is the fully-qualified name of the
	// MetricsCollectorService's NodeMetadata RPC.
	MetricsCollectorServiceNodeMetadataProcedure = "/api.v1.MetricsCollectorService/NodeMetadata"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// OperatorServiceGetOperatorsProcedure is the fully-qualified name of the OperatorService's
	// GetOperators RPC.
	OperatorServiceGetOperatorsProcedure = "/api.v1.OperatorService/GetOperators"
	// OperatorServiceGetOperatorMetadataProcedure is the fully-qualified name of the OperatorService's
	// GetOperatorMetadata RPC.
	OperatorServiceGetOperatorMetadataProcedure = "/api.v1.OperatorService/GetOperatorMetadata"
	// OperatorServiceGetOCIRegistriesProcedure is the fully-qualified name of the OperatorService's
	// GetOCIRegistries RPC.
	OperatorServiceGetOCIRegistriesProcedure = "/api.v1.OperatorService/GetOCIRegistries"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// ClusterServiceName is the fully-qualified name of the ClusterService service.
	ClusterServiceName = "api.v1.ClusterService"
)
View Source 
const (
	// InstanceServiceName is the fully-qualified name of the InstanceService service.
	InstanceServiceName = "api.v1.InstanceService"
)
View Source 
const (
	// MetricsCollectorServiceName is the fully-qualified name of the MetricsCollectorService service.
	MetricsCollectorServiceName = "api.v1.MetricsCollectorService"
)
View Source 
const (
	// MpaServiceName is the fully-qualified name of the MpaService service.
	MpaServiceName = "api.v1.MpaService"
)
View Source 
const (
	// MpaServiceStreamWorkloadMetricsProcedure is the fully-qualified name of the MpaService's
	// StreamWorkloadMetrics RPC.
	MpaServiceStreamWorkloadMetricsProcedure = "/api.v1.MpaService/StreamWorkloadMetrics"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// OperatorHealthServiceName is the fully-qualified name of the OperatorHealthService service.
	OperatorHealthServiceName = "api.v1.OperatorHealthService"
)
View Source 
const (
	// OperatorHealthServiceReportHealthProcedure is the fully-qualified name of the
	// OperatorHealthService's ReportHealth RPC.
	OperatorHealthServiceReportHealthProcedure = "/api.v1.OperatorHealthService/ReportHealth"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// OperatorServiceName is the fully-qualified name of the OperatorService service.
	OperatorServiceName = "api.v1.OperatorService"
)

Variables

This section is empty.

Functions

func NewClusterMutationServiceHandler 

func NewClusterMutationServiceHandler(svc ClusterMutationServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewClusterMutationServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewClusterServiceHandler 

func NewClusterServiceHandler(svc ClusterServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewClusterServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewInstanceServiceHandler 

func NewInstanceServiceHandler(svc InstanceServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewInstanceServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewK8SServiceHandler 

func NewK8SServiceHandler(svc K8SServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewK8SServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewMetricsCollectorServiceHandler 

func NewMetricsCollectorServiceHandler(svc MetricsCollectorServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewMetricsCollectorServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewMpaServiceHandler 

func NewMpaServiceHandler(svc MpaServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewMpaServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewOperatorHealthServiceHandler added in v0.0.64 

func NewOperatorHealthServiceHandler(svc OperatorHealthServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewOperatorHealthServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewOperatorServiceHandler added in v0.0.64 

func NewOperatorServiceHandler(svc OperatorServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewOperatorServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewUtilizationServiceHandler 

func NewUtilizationServiceHandler(svc UtilizationServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewUtilizationServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type ClusterMutationServiceClient 

type ClusterMutationServiceClient interface {
	// CreateCluster creates a new cluster.
	CreateCluster(context.Context, *connect.Request[v1.CreateClusterRequest]) (*connect.Response[v1.CreateClusterResponse], error)
	// DeleteCluster deletes a cluster and all its resources.
	// This operation is irreversible and should be used with caution.
	DeleteCluster(context.Context, *connect.Request[v1.DeleteClusterRequest]) (*connect.Response[v1.DeleteClusterResponse], error)
	// UpdateCluster updates the configuration of an existing cluster.
	UpdateCluster(context.Context, *connect.Request[v1.UpdateClusterRequest]) (*connect.Response[v1.UpdateClusterResponse], error)
	// ResetClusterToken resets the token for a cluster.
	ResetClusterToken(context.Context, *connect.Request[v1.ResetClusterTokenRequest]) (*connect.Response[v1.ResetClusterTokenResponse], error)
}

ClusterMutationServiceClient is a client for the api.v1.ClusterMutationService service.

func NewClusterMutationServiceClient 

func NewClusterMutationServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ClusterMutationServiceClient

NewClusterMutationServiceClient constructs a client for the api.v1.ClusterMutationService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type ClusterMutationServiceHandler 

type ClusterMutationServiceHandler interface {
	// CreateCluster creates a new cluster.
	CreateCluster(context.Context, *connect.Request[v1.CreateClusterRequest]) (*connect.Response[v1.CreateClusterResponse], error)
	// DeleteCluster deletes a cluster and all its resources.
	// This operation is irreversible and should be used with caution.
	DeleteCluster(context.Context, *connect.Request[v1.DeleteClusterRequest]) (*connect.Response[v1.DeleteClusterResponse], error)
	// UpdateCluster updates the configuration of an existing cluster.
	UpdateCluster(context.Context, *connect.Request[v1.UpdateClusterRequest]) (*connect.Response[v1.UpdateClusterResponse], error)
	// ResetClusterToken resets the token for a cluster.
	ResetClusterToken(context.Context, *connect.Request[v1.ResetClusterTokenRequest]) (*connect.Response[v1.ResetClusterTokenResponse], error)
}

ClusterMutationServiceHandler is an implementation of the api.v1.ClusterMutationService service.

type ClusterServiceClient 

type ClusterServiceClient interface {
	// GetClustersBasicInfo retrieves basic information for all clusters in a team
	GetClustersBasicInfo(context.Context, *connect.Request[v1.GetClustersBasicInfoRequest]) (*connect.Response[v1.GetClustersBasicInfoResponse], error)
	// GetClustersWithMetrics retrieves clusters with full metrics using optimized batch queries
	GetClustersWithMetrics(context.Context, *connect.Request[v1.GetClustersWithMetricsRequest]) (*connect.Response[v1.GetClustersWithMetricsResponse], error)
	// CreateClusterToken creates a new cluster registration with authentication token
	CreateClusterToken(context.Context, *connect.Request[v1.CreateClusterTokenRequest]) (*connect.Response[v1.CreateClusterTokenResponse], error)
	// GetClustersDeltaMetrics retrieves lightweight aggregate metrics for delta/comparison calculations
	GetClustersDeltaMetrics(context.Context, *connect.Request[v1.GetClustersDeltaMetricsRequest]) (*connect.Response[v1.GetClustersDeltaMetricsResponse], error)
	// GetNetworkDependencies returns workload-level network dependencies for visualization
	GetNetworkDependencies(context.Context, *connect.Request[v1.GetNetworkDependenciesRequest]) (*connect.Response[v1.GetNetworkDependenciesResponse], error)
	// GetNetworkMetricsTimeSeries returns time-bucketed network metrics for charts
	GetNetworkMetricsTimeSeries(context.Context, *connect.Request[v1.GetNetworkMetricsTimeSeriesRequest]) (*connect.Response[v1.GetNetworkMetricsTimeSeriesResponse], error)
	// GetNodeTypeCounts retrieves node type breakdown for given clusters and time range
	GetNodeTypeCounts(context.Context, *connect.Request[v1.GetNodeTypeCountsRequest]) (*connect.Response[v1.GetNodeTypeCountsResponse], error)
	// GetClusterIDByName retrieves the ID of the first active cluster matching the given team and name
	GetClusterIDByName(context.Context, *connect.Request[v1.GetClusterIDByNameRequest]) (*connect.Response[v1.GetClusterIDByNameResponse], error)
	// GetClusterInfoByName retrieves full info of the first active cluster matching the given team and name
	GetClusterInfoByName(context.Context, *connect.Request[v1.GetClusterInfoByNameRequest]) (*connect.Response[v1.GetClusterInfoByNameResponse], error)
}

ClusterServiceClient is a client for the api.v1.ClusterService service.

func NewClusterServiceClient 

func NewClusterServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ClusterServiceClient

NewClusterServiceClient constructs a client for the api.v1.ClusterService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type ClusterServiceHandler 

type ClusterServiceHandler interface {
	// GetClustersBasicInfo retrieves basic information for all clusters in a team
	GetClustersBasicInfo(context.Context, *connect.Request[v1.GetClustersBasicInfoRequest]) (*connect.Response[v1.GetClustersBasicInfoResponse], error)
	// GetClustersWithMetrics retrieves clusters with full metrics using optimized batch queries
	GetClustersWithMetrics(context.Context, *connect.Request[v1.GetClustersWithMetricsRequest]) (*connect.Response[v1.GetClustersWithMetricsResponse], error)
	// CreateClusterToken creates a new cluster registration with authentication token
	CreateClusterToken(context.Context, *connect.Request[v1.CreateClusterTokenRequest]) (*connect.Response[v1.CreateClusterTokenResponse], error)
	// GetClustersDeltaMetrics retrieves lightweight aggregate metrics for delta/comparison calculations
	GetClustersDeltaMetrics(context.Context, *connect.Request[v1.GetClustersDeltaMetricsRequest]) (*connect.Response[v1.GetClustersDeltaMetricsResponse], error)
	// GetNetworkDependencies returns workload-level network dependencies for visualization
	GetNetworkDependencies(context.Context, *connect.Request[v1.GetNetworkDependenciesRequest]) (*connect.Response[v1.GetNetworkDependenciesResponse], error)
	// GetNetworkMetricsTimeSeries returns time-bucketed network metrics for charts
	GetNetworkMetricsTimeSeries(context.Context, *connect.Request[v1.GetNetworkMetricsTimeSeriesRequest]) (*connect.Response[v1.GetNetworkMetricsTimeSeriesResponse], error)
	// GetNodeTypeCounts retrieves node type breakdown for given clusters and time range
	GetNodeTypeCounts(context.Context, *connect.Request[v1.GetNodeTypeCountsRequest]) (*connect.Response[v1.GetNodeTypeCountsResponse], error)
	// GetClusterIDByName retrieves the ID of the first active cluster matching the given team and name
	GetClusterIDByName(context.Context, *connect.Request[v1.GetClusterIDByNameRequest]) (*connect.Response[v1.GetClusterIDByNameResponse], error)
	// GetClusterInfoByName retrieves full info of the first active cluster matching the given team and name
	GetClusterInfoByName(context.Context, *connect.Request[v1.GetClusterInfoByNameRequest]) (*connect.Response[v1.GetClusterInfoByNameResponse], error)
}

ClusterServiceHandler is an implementation of the api.v1.ClusterService service.

type InstanceServiceClient 

type InstanceServiceClient interface {
	GetInstance(context.Context, *connect.Request[v1.GetInstanceRequest]) (*connect.Response[v1.GetInstanceResponse], error)
	GetInstances(context.Context, *connect.Request[v1.GetInstancesRequest]) (*connect.Response[v1.GetInstancesResponse], error)
	GetInstanceType(context.Context, *connect.Request[v1.GetInstanceTypeRequest]) (*connect.Response[v1.GetInstanceTypeResponse], error)
	GetInstanceTypes(context.Context, *connect.Request[v1.GetInstanceTypesRequest]) (*connect.Response[v1.GetInstanceTypesResponse], error)
	GetRegion(context.Context, *connect.Request[v1.GetRegionRequest]) (*connect.Response[v1.GetRegionResponse], error)
	GetRegions(context.Context, *connect.Request[v1.GetRegionsRequest]) (*connect.Response[v1.GetRegionsResponse], error)
	GetAvailabilityZone(context.Context, *connect.Request[v1.GetAvailabilityZoneRequest]) (*connect.Response[v1.GetAvailabilityZoneResponse], error)
	GetAvailabilityZones(context.Context, *connect.Request[v1.GetAvailabilityZonesRequest]) (*connect.Response[v1.GetAvailabilityZonesResponse], error)
	GetOperatingSystem(context.Context, *connect.Request[v1.GetOperatingSystemRequest]) (*connect.Response[v1.GetOperatingSystemResponse], error)
	GetOperatingSystems(context.Context, *connect.Request[v1.GetOperatingSystemsRequest]) (*connect.Response[v1.GetOperatingSystemsResponse], error)
	GetCloudProvider(context.Context, *connect.Request[v1.GetCloudProviderRequest]) (*connect.Response[v1.GetCloudProviderResponse], error)
	GetCloudProviders(context.Context, *connect.Request[v1.GetCloudProvidersRequest]) (*connect.Response[v1.GetCloudProvidersResponse], error)
}

InstanceServiceClient is a client for the api.v1.InstanceService service.

func NewInstanceServiceClient 

func NewInstanceServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) InstanceServiceClient

NewInstanceServiceClient constructs a client for the api.v1.InstanceService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type InstanceServiceHandler 

type InstanceServiceHandler interface {
	GetInstance(context.Context, *connect.Request[v1.GetInstanceRequest]) (*connect.Response[v1.GetInstanceResponse], error)
	GetInstances(context.Context, *connect.Request[v1.GetInstancesRequest]) (*connect.Response[v1.GetInstancesResponse], error)
	GetInstanceType(context.Context, *connect.Request[v1.GetInstanceTypeRequest]) (*connect.Response[v1.GetInstanceTypeResponse], error)
	GetInstanceTypes(context.Context, *connect.Request[v1.GetInstanceTypesRequest]) (*connect.Response[v1.GetInstanceTypesResponse], error)
	GetRegion(context.Context, *connect.Request[v1.GetRegionRequest]) (*connect.Response[v1.GetRegionResponse], error)
	GetRegions(context.Context, *connect.Request[v1.GetRegionsRequest]) (*connect.Response[v1.GetRegionsResponse], error)
	GetAvailabilityZone(context.Context, *connect.Request[v1.GetAvailabilityZoneRequest]) (*connect.Response[v1.GetAvailabilityZoneResponse], error)
	GetAvailabilityZones(context.Context, *connect.Request[v1.GetAvailabilityZonesRequest]) (*connect.Response[v1.GetAvailabilityZonesResponse], error)
	GetOperatingSystem(context.Context, *connect.Request[v1.GetOperatingSystemRequest]) (*connect.Response[v1.GetOperatingSystemResponse], error)
	GetOperatingSystems(context.Context, *connect.Request[v1.GetOperatingSystemsRequest]) (*connect.Response[v1.GetOperatingSystemsResponse], error)
	GetCloudProvider(context.Context, *connect.Request[v1.GetCloudProviderRequest]) (*connect.Response[v1.GetCloudProviderResponse], error)
	GetCloudProviders(context.Context, *connect.Request[v1.GetCloudProvidersRequest]) (*connect.Response[v1.GetCloudProvidersResponse], error)
}

InstanceServiceHandler is an implementation of the api.v1.InstanceService service.

type K8SServiceClient 

type K8SServiceClient interface {
	// GetWorkloadsStats retrieves stats for workloads in a specific cluster.
	GetWorkloadsStats(context.Context, *connect.Request[v1.GetWorkloadsStatsRequest]) (*connect.Response[v1.GetWorkloadsStatsResponse], error)
	// GetClusters retrieves all clusters for a team.
	GetClusters(context.Context, *connect.Request[v1.GetClustersRequest]) (*connect.Response[v1.GetClustersResponse], error)
	// ListClusters retrieves clusters for a team with pagination.
	// Deprecated: Use GetClusters instead.
	//
	// Deprecated: do not use.
	ListClusters(context.Context, *connect.Request[v1.ListClustersRequest]) (*connect.Response[v1.ListClustersResponse], error)
	// GetCluster retrieves detailed information for a specific cluster.
	GetCluster(context.Context, *connect.Request[v1.GetClusterRequest]) (*connect.Response[v1.GetClusterResponse], error)
	// GetClusterMetadata retrieves metadata information for clusters in a team.
	GetClusterMetadata(context.Context, *connect.Request[v1.GetClusterMetadataRequest]) (*connect.Response[v1.GetClusterMetadataResponse], error)
	// GetAllNamespaces returns a list of all namespaces for a teamID; if cluster list is empty, returns all.
	GetAllNamespaces(context.Context, *connect.Request[v1.GetAllNamespacesRequest]) (*connect.Response[v1.GetAllNamespacesResponse], error)
	// SearchNamespacesByCluster searches namespaces by name within a single cluster.
	SearchNamespacesByCluster(context.Context, *connect.Request[v1.SearchNamespacesByClusterRequest]) (*connect.Response[v1.SearchNamespacesByClusterResponse], error)
	// ListNamespacesByCluster lists namespaces (id and name) within a single cluster.
	ListNamespacesByCluster(context.Context, *connect.Request[v1.ListNamespacesByClusterRequest]) (*connect.Response[v1.ListNamespacesByClusterResponse], error)
	// GetAllWorkloadNames returns a list of all workload names for a team ID; if cluster list is empty, returns all.
	GetAllWorkloadNames(context.Context, *connect.Request[v1.GetAllWorkloadNamesRequest]) (*connect.Response[v1.GetAllWorkloadNamesResponse], error)
	// GetAllWorkloadLabels returns all workload labels for a team ID; if cluster list is empty, returns all.
	GetAllWorkloadLabels(context.Context, *connect.Request[v1.GetAllWorkloadLabelsRequest]) (*connect.Response[v1.GetAllWorkloadLabelsResponse], error)
	// GetAllNodeGroupNames retrieves list of node group names by cluster
	GetAllNodeGroupNames(context.Context, *connect.Request[v1.GetAllNodeGroupNamesRequest]) (*connect.Response[v1.GetAllNodeGroupNamesResponse], error)
	MetadataForWorkloads(context.Context, *connect.Request[v1.MetadataForWorkloadsRequest]) (*connect.Response[v1.MetadataForWorkloadsResponse], error)
	// GetNodeGroups retrieves all node groups for a specific cluster.
	GetNodeGroups(context.Context, *connect.Request[v1.GetNodeGroupsRequest]) (*connect.Response[v1.GetNodeGroupsResponse], error)
	// GetAllNodeGroups retrieves all node groups for all clusters in a team.
	GetAllNodeGroups(context.Context, *connect.Request[v1.GetAllNodeGroupsRequest]) (*connect.Response[v1.GetAllNodeGroupsResponse], error)
	// GetNodeGroupsUtilization retrieves utilization data for node groups in a specific cluster.
	GetNodeGroupsUtilization(context.Context, *connect.Request[v1.GetNodeGroupsUtilizationRequest]) (*connect.Response[v1.GetNodeGroupsUtilizationResponse], error)
	// GetNodeGroup retrieves node group for a specific cluster.
	GetNodeGroup(context.Context, *connect.Request[v1.GetNodeGroupRequest]) (*connect.Response[v1.GetNodeGroupResponse], error)
	// GetNode retrieves detailed information for a specific node.
	GetNode(context.Context, *connect.Request[v1.GetNodeRequest]) (*connect.Response[v1.GetNodeResponse], error)
	// GetWorkloads retrieves all workloads for a specific cluster.
	GetWorkloads(context.Context, *connect.Request[v1.GetWorkloadsRequest]) (*connect.Response[v1.GetWorkloadsResponse], error)
	// GetWorkload retrieves detailed information for a specific workload.
	GetWorkload(context.Context, *connect.Request[v1.GetWorkloadRequest]) (*connect.Response[v1.GetWorkloadResponse], error)
	// GetWorkloadContainerPercentiles retrieves per-container percentile metrics for a workload.
	//
	// Note: fs_* and current_* fields in the response are no longer populated.
	// Prefer GetLatestContainerRequestLimits for progressive loading of request/limit values.
	GetWorkloadContainerPercentiles(context.Context, *connect.Request[v1.GetWorkloadContainerPercentilesRequest]) (*connect.Response[v1.GetWorkloadContainerPercentilesResponse], error)
	// GetWorkloadContainerTimeSeries retrieves per-container time-series resource metrics for a workload.
	GetWorkloadContainerTimeSeries(context.Context, *connect.Request[v1.GetWorkloadContainerTimeSeriesRequest]) (*connect.Response[v1.GetWorkloadContainerTimeSeriesResponse], error)
	// GetLatestContainerRequestLimits retrieves the most recent request/limit values per container for a workload.
	GetLatestContainerRequestLimits(context.Context, *connect.Request[v1.GetLatestContainerRequestLimitsRequest]) (*connect.Response[v1.GetLatestContainerRequestLimitsResponse], error)
	// GetForecastWorkloads retrieves all workloads for a specific cluster.
	//
	// Deprecated: do not use.
	GetForecastWorkloads(context.Context, *connect.Request[v1.GetForecastWorkloadsRequest]) (*connect.Response[v1.GetForecastWorkloadsResponse], error)
	// GetForecastWorkload retrieves detailed information for a specific workload.
	//
	// Deprecated: do not use.
	GetForecastWorkload(context.Context, *connect.Request[v1.GetForecastWorkloadRequest]) (*connect.Response[v1.GetForecastWorkloadResponse], error)
	// GetResources retrivers specific resource and their details from db, simulating informer.
	GetResources(context.Context, *connect.Request[v1.GetResourcesRequest]) (*connect.Response[v1.GetResourcesResponse], error)
	// GetPods retrieves Pod resources and their details from db.
	GetPods(context.Context, *connect.Request[v1.GetPodsRequest]) (*connect.Response[v1.GetPodsResponse], error)
	GetLatestOperatorVersion(context.Context, *connect.Request[v1.GetLatestOperatorVersionRequest]) (*connect.Response[v1.GetLatestOperatorVersionResponse], error)
	GalaxyGetWorkloadPerspective(context.Context, *connect.Request[v1.GalaxyGetWorkloadPerspectiveRequest]) (*connect.Response[v1.GalaxyGetWorkloadPerspectiveResponse], error)
	ListAuditLogs(context.Context, *connect.Request[v1.ListAuditLogsRequest]) (*connect.Response[v1.ListAuditLogsResponse], error)
	ListAuditLogOriginators(context.Context, *connect.Request[v1.ListAuditLogOriginatorsRequest]) (*connect.Response[v1.ListAuditLogOriginatorsResponse], error)
	SendWorkloadEmail(context.Context, *connect.Request[v1.SendWorkloadEmailRequest]) (*connect.Response[v1.SendWorkloadEmailResponse], error)
	SendWeeklySummaryEmail(context.Context, *connect.Request[v1.SendWeeklySummaryEmailRequest]) (*connect.Response[v1.SendWeeklySummaryEmailResponse], error)
	GetClustersNodeInfo(context.Context, *connect.Request[v1.GetClustersNodeInfoRequest]) (*connect.Response[v1.GetClustersNodeInfoResponse], error)
	// SearchK8sResources searches across all k8s resource types for a specific cluster.
	SearchK8SResources(context.Context, *connect.Request[v1.SearchK8SResourcesRequest]) (*connect.Response[v1.SearchK8SResourcesResponse], error)
	// SearchK8sWorkloads searches across all k8s workload types returning only kind and name.
	SearchK8SWorkloads(context.Context, *connect.Request[v1.SearchK8SWorkloadsRequest]) (*connect.Response[v1.SearchK8SWorkloadsResponse], error)
	// GetClusterType determines the cluster type based on kubelet version
	GetClusterType(context.Context, *connect.Request[v1.GetClusterTypeRequest]) (*connect.Response[v1.GetClusterTypeResponse], error)
	// GetDeploymentRelations retrieves all relations for a specific deployment.
	GetRelationsForKind(context.Context, *connect.Request[v1.GetRelatedResourcesRequest]) (*connect.Response[v1.GetRelatedResourcesResponse], error)
	// LookupNodeInstance retrieves instance information for a node, including both dynamic cache lookup and cached instance data
	LookupNodeInstance(context.Context, *connect.Request[v1.LookupNodeInstanceRequest]) (*connect.Response[v1.LookupNodeInstanceResponse], error)
	// GetWorkloadPodHistory retrieves historical pods for a workload.
	GetWorkloadPodHistory(context.Context, *connect.Request[v1.GetWorkloadPodHistoryRequest]) (*connect.Response[v1.GetWorkloadPodHistoryResponse], error)
	// AddClusterTags adds tags to a cluster.
	AddClusterTags(context.Context, *connect.Request[v1.AddClusterTagsRequest]) (*connect.Response[v1.AddClusterTagsResponse], error)
	// RemoveClusterTags removes tags from a cluster.
	RemoveClusterTags(context.Context, *connect.Request[v1.RemoveClusterTagsRequest]) (*connect.Response[v1.RemoveClusterTagsResponse], error)
	// ListTags lists all tags for a team.
	ListTags(context.Context, *connect.Request[v1.ListTagsRequest]) (*connect.Response[v1.ListTagsResponse], error)
}

K8SServiceClient is a client for the api.v1.K8SService service.

func NewK8SServiceClient 

func NewK8SServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) K8SServiceClient

NewK8SServiceClient constructs a client for the api.v1.K8SService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type K8SServiceHandler 

type K8SServiceHandler interface {
	// GetWorkloadsStats retrieves stats for workloads in a specific cluster.
	GetWorkloadsStats(context.Context, *connect.Request[v1.GetWorkloadsStatsRequest]) (*connect.Response[v1.GetWorkloadsStatsResponse], error)
	// GetClusters retrieves all clusters for a team.
	GetClusters(context.Context, *connect.Request[v1.GetClustersRequest]) (*connect.Response[v1.GetClustersResponse], error)
	// ListClusters retrieves clusters for a team with pagination.
	// Deprecated: Use GetClusters instead.
	//
	// Deprecated: do not use.
	ListClusters(context.Context, *connect.Request[v1.ListClustersRequest]) (*connect.Response[v1.ListClustersResponse], error)
	// GetCluster retrieves detailed information for a specific cluster.
	GetCluster(context.Context, *connect.Request[v1.GetClusterRequest]) (*connect.Response[v1.GetClusterResponse], error)
	// GetClusterMetadata retrieves metadata information for clusters in a team.
	GetClusterMetadata(context.Context, *connect.Request[v1.GetClusterMetadataRequest]) (*connect.Response[v1.GetClusterMetadataResponse], error)
	// GetAllNamespaces returns a list of all namespaces for a teamID; if cluster list is empty, returns all.
	GetAllNamespaces(context.Context, *connect.Request[v1.GetAllNamespacesRequest]) (*connect.Response[v1.GetAllNamespacesResponse], error)
	// SearchNamespacesByCluster searches namespaces by name within a single cluster.
	SearchNamespacesByCluster(context.Context, *connect.Request[v1.SearchNamespacesByClusterRequest]) (*connect.Response[v1.SearchNamespacesByClusterResponse], error)
	// ListNamespacesByCluster lists namespaces (id and name) within a single cluster.
	ListNamespacesByCluster(context.Context, *connect.Request[v1.ListNamespacesByClusterRequest]) (*connect.Response[v1.ListNamespacesByClusterResponse], error)
	// GetAllWorkloadNames returns a list of all workload names for a team ID; if cluster list is empty, returns all.
	GetAllWorkloadNames(context.Context, *connect.Request[v1.GetAllWorkloadNamesRequest]) (*connect.Response[v1.GetAllWorkloadNamesResponse], error)
	// GetAllWorkloadLabels returns all workload labels for a team ID; if cluster list is empty, returns all.
	GetAllWorkloadLabels(context.Context, *connect.Request[v1.GetAllWorkloadLabelsRequest]) (*connect.Response[v1.GetAllWorkloadLabelsResponse], error)
	// GetAllNodeGroupNames retrieves list of node group names by cluster
	GetAllNodeGroupNames(context.Context, *connect.Request[v1.GetAllNodeGroupNamesRequest]) (*connect.Response[v1.GetAllNodeGroupNamesResponse], error)
	MetadataForWorkloads(context.Context, *connect.Request[v1.MetadataForWorkloadsRequest]) (*connect.Response[v1.MetadataForWorkloadsResponse], error)
	// GetNodeGroups retrieves all node groups for a specific cluster.
	GetNodeGroups(context.Context, *connect.Request[v1.GetNodeGroupsRequest]) (*connect.Response[v1.GetNodeGroupsResponse], error)
	// GetAllNodeGroups retrieves all node groups for all clusters in a team.
	GetAllNodeGroups(context.Context, *connect.Request[v1.GetAllNodeGroupsRequest]) (*connect.Response[v1.GetAllNodeGroupsResponse], error)
	// GetNodeGroupsUtilization retrieves utilization data for node groups in a specific cluster.
	GetNodeGroupsUtilization(context.Context, *connect.Request[v1.GetNodeGroupsUtilizationRequest]) (*connect.Response[v1.GetNodeGroupsUtilizationResponse], error)
	// GetNodeGroup retrieves node group for a specific cluster.
	GetNodeGroup(context.Context, *connect.Request[v1.GetNodeGroupRequest]) (*connect.Response[v1.GetNodeGroupResponse], error)
	// GetNode retrieves detailed information for a specific node.
	GetNode(context.Context, *connect.Request[v1.GetNodeRequest]) (*connect.Response[v1.GetNodeResponse], error)
	// GetWorkloads retrieves all workloads for a specific cluster.
	GetWorkloads(context.Context, *connect.Request[v1.GetWorkloadsRequest]) (*connect.Response[v1.GetWorkloadsResponse], error)
	// GetWorkload retrieves detailed information for a specific workload.
	GetWorkload(context.Context, *connect.Request[v1.GetWorkloadRequest]) (*connect.Response[v1.GetWorkloadResponse], error)
	// GetWorkloadContainerPercentiles retrieves per-container percentile metrics for a workload.
	//
	// Note: fs_* and current_* fields in the response are no longer populated.
	// Prefer GetLatestContainerRequestLimits for progressive loading of request/limit values.
	GetWorkloadContainerPercentiles(context.Context, *connect.Request[v1.GetWorkloadContainerPercentilesRequest]) (*connect.Response[v1.GetWorkloadContainerPercentilesResponse], error)
	// GetWorkloadContainerTimeSeries retrieves per-container time-series resource metrics for a workload.
	GetWorkloadContainerTimeSeries(context.Context, *connect.Request[v1.GetWorkloadContainerTimeSeriesRequest]) (*connect.Response[v1.GetWorkloadContainerTimeSeriesResponse], error)
	// GetLatestContainerRequestLimits retrieves the most recent request/limit values per container for a workload.
	GetLatestContainerRequestLimits(context.Context, *connect.Request[v1.GetLatestContainerRequestLimitsRequest]) (*connect.Response[v1.GetLatestContainerRequestLimitsResponse], error)
	// GetForecastWorkloads retrieves all workloads for a specific cluster.
	//
	// Deprecated: do not use.
	GetForecastWorkloads(context.Context, *connect.Request[v1.GetForecastWorkloadsRequest]) (*connect.Response[v1.GetForecastWorkloadsResponse], error)
	// GetForecastWorkload retrieves detailed information for a specific workload.
	//
	// Deprecated: do not use.
	GetForecastWorkload(context.Context, *connect.Request[v1.GetForecastWorkloadRequest]) (*connect.Response[v1.GetForecastWorkloadResponse], error)
	// GetResources retrivers specific resource and their details from db, simulating informer.
	GetResources(context.Context, *connect.Request[v1.GetResourcesRequest]) (*connect.Response[v1.GetResourcesResponse], error)
	// GetPods retrieves Pod resources and their details from db.
	GetPods(context.Context, *connect.Request[v1.GetPodsRequest]) (*connect.Response[v1.GetPodsResponse], error)
	GetLatestOperatorVersion(context.Context, *connect.Request[v1.GetLatestOperatorVersionRequest]) (*connect.Response[v1.GetLatestOperatorVersionResponse], error)
	GalaxyGetWorkloadPerspective(context.Context, *connect.Request[v1.GalaxyGetWorkloadPerspectiveRequest]) (*connect.Response[v1.GalaxyGetWorkloadPerspectiveResponse], error)
	ListAuditLogs(context.Context, *connect.Request[v1.ListAuditLogsRequest]) (*connect.Response[v1.ListAuditLogsResponse], error)
	ListAuditLogOriginators(context.Context, *connect.Request[v1.ListAuditLogOriginatorsRequest]) (*connect.Response[v1.ListAuditLogOriginatorsResponse], error)
	SendWorkloadEmail(context.Context, *connect.Request[v1.SendWorkloadEmailRequest]) (*connect.Response[v1.SendWorkloadEmailResponse], error)
	SendWeeklySummaryEmail(context.Context, *connect.Request[v1.SendWeeklySummaryEmailRequest]) (*connect.Response[v1.SendWeeklySummaryEmailResponse], error)
	GetClustersNodeInfo(context.Context, *connect.Request[v1.GetClustersNodeInfoRequest]) (*connect.Response[v1.GetClustersNodeInfoResponse], error)
	// SearchK8sResources searches across all k8s resource types for a specific cluster.
	SearchK8SResources(context.Context, *connect.Request[v1.SearchK8SResourcesRequest]) (*connect.Response[v1.SearchK8SResourcesResponse], error)
	// SearchK8sWorkloads searches across all k8s workload types returning only kind and name.
	SearchK8SWorkloads(context.Context, *connect.Request[v1.SearchK8SWorkloadsRequest]) (*connect.Response[v1.SearchK8SWorkloadsResponse], error)
	// GetClusterType determines the cluster type based on kubelet version
	GetClusterType(context.Context, *connect.Request[v1.GetClusterTypeRequest]) (*connect.Response[v1.GetClusterTypeResponse], error)
	// GetDeploymentRelations retrieves all relations for a specific deployment.
	GetRelationsForKind(context.Context, *connect.Request[v1.GetRelatedResourcesRequest]) (*connect.Response[v1.GetRelatedResourcesResponse], error)
	// LookupNodeInstance retrieves instance information for a node, including both dynamic cache lookup and cached instance data
	LookupNodeInstance(context.Context, *connect.Request[v1.LookupNodeInstanceRequest]) (*connect.Response[v1.LookupNodeInstanceResponse], error)
	// GetWorkloadPodHistory retrieves historical pods for a workload.
	GetWorkloadPodHistory(context.Context, *connect.Request[v1.GetWorkloadPodHistoryRequest]) (*connect.Response[v1.GetWorkloadPodHistoryResponse], error)
	// AddClusterTags adds tags to a cluster.
	AddClusterTags(context.Context, *connect.Request[v1.AddClusterTagsRequest]) (*connect.Response[v1.AddClusterTagsResponse], error)
	// RemoveClusterTags removes tags from a cluster.
	RemoveClusterTags(context.Context, *connect.Request[v1.RemoveClusterTagsRequest]) (*connect.Response[v1.RemoveClusterTagsResponse], error)
	// ListTags lists all tags for a team.
	ListTags(context.Context, *connect.Request[v1.ListTagsRequest]) (*connect.Response[v1.ListTagsResponse], error)
}

K8SServiceHandler is an implementation of the api.v1.K8SService service.

type MetricsCollectorServiceClient 

type MetricsCollectorServiceClient interface {
	// SendResource pushes a single metric for a resource.
	SendResource(context.Context, *connect.Request[v1.SendResourceRequest]) (*connect.Response[v1.SendResourceResponse], error)
	// SendResourceBatch pushes multiple metrics for resources of the same type.
	SendResourceBatch(context.Context, *connect.Request[v1.SendResourceBatchRequest]) (*connect.Response[v1.SendResourceBatchResponse], error)
	// SendTelemetryMetrics pushes a batch of telemetry metrics (gauges, counters, histograms) from a cluster.
	SendTelemetryMetrics(context.Context, *connect.Request[v1.SendTelemetryMetricsRequest]) (*connect.Response[v1.SendTelemetryMetricsResponse], error)
	// SendClusterSnapshotStream processes cluster snapshot data in chunks via streaming
	SendClusterSnapshotStream(context.Context) *connect.ClientStreamForClient[v1.ClusterSnapshotChunk, v1.SendClusterSnapshotStreamResponse]
	// SendTelemetryLogs ingests a batch of log messages from the cluster.
	SendTelemetryLogs(context.Context, *connect.Request[v1.SendTelemetryLogsRequest]) (*connect.Response[v1.SendTelemetryLogsResponse], error)
	// SendNetworkTrafficMetrics pushes network traffic metrics from a node.
	SendNetworkTrafficMetrics(context.Context, *connect.Request[v1.SendNetworkTrafficMetricsRequest]) (*connect.Response[v1.SendNetworkTrafficMetricsResponse], error)
	NodeMetadata(context.Context, *connect.Request[v1.NodeMetadataRequest]) (*connect.Response[v1.NodeMetadataResponse], error)
}

MetricsCollectorServiceClient is a client for the api.v1.MetricsCollectorService service.

func NewMetricsCollectorServiceClient 

func NewMetricsCollectorServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) MetricsCollectorServiceClient

NewMetricsCollectorServiceClient constructs a client for the api.v1.MetricsCollectorService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type MetricsCollectorServiceHandler 

type MetricsCollectorServiceHandler interface {
	// SendResource pushes a single metric for a resource.
	SendResource(context.Context, *connect.Request[v1.SendResourceRequest]) (*connect.Response[v1.SendResourceResponse], error)
	// SendResourceBatch pushes multiple metrics for resources of the same type.
	SendResourceBatch(context.Context, *connect.Request[v1.SendResourceBatchRequest]) (*connect.Response[v1.SendResourceBatchResponse], error)
	// SendTelemetryMetrics pushes a batch of telemetry metrics (gauges, counters, histograms) from a cluster.
	SendTelemetryMetrics(context.Context, *connect.Request[v1.SendTelemetryMetricsRequest]) (*connect.Response[v1.SendTelemetryMetricsResponse], error)
	// SendClusterSnapshotStream processes cluster snapshot data in chunks via streaming
	SendClusterSnapshotStream(context.Context, *connect.ClientStream[v1.ClusterSnapshotChunk]) (*connect.Response[v1.SendClusterSnapshotStreamResponse], error)
	// SendTelemetryLogs ingests a batch of log messages from the cluster.
	SendTelemetryLogs(context.Context, *connect.Request[v1.SendTelemetryLogsRequest]) (*connect.Response[v1.SendTelemetryLogsResponse], error)
	// SendNetworkTrafficMetrics pushes network traffic metrics from a node.
	SendNetworkTrafficMetrics(context.Context, *connect.Request[v1.SendNetworkTrafficMetricsRequest]) (*connect.Response[v1.SendNetworkTrafficMetricsResponse], error)
	NodeMetadata(context.Context, *connect.Request[v1.NodeMetadataRequest]) (*connect.Response[v1.NodeMetadataResponse], error)
}

MetricsCollectorServiceHandler is an implementation of the api.v1.MetricsCollectorService service.

type MpaServiceClient 

type MpaServiceClient interface {
	// StreamWorkloadMetrics establishes a bidirectional stream where the client (Dakr)
	// subscribes to workloads, and the server (Zxporter) pushes metric updates.
	StreamWorkloadMetrics(context.Context) *connect.BidiStreamForClient[v1.MpaWorkloadSubscription, v1.MpaStreamResponse]
}

MpaServiceClient is a client for the api.v1.MpaService service.

func NewMpaServiceClient 

func NewMpaServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) MpaServiceClient

NewMpaServiceClient constructs a client for the api.v1.MpaService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type MpaServiceHandler 

type MpaServiceHandler interface {
	// StreamWorkloadMetrics establishes a bidirectional stream where the client (Dakr)
	// subscribes to workloads, and the server (Zxporter) pushes metric updates.
	StreamWorkloadMetrics(context.Context, *connect.BidiStream[v1.MpaWorkloadSubscription, v1.MpaStreamResponse]) error
}

MpaServiceHandler is an implementation of the api.v1.MpaService service.

type OperatorHealthServiceClient added in v0.0.64 

type OperatorHealthServiceClient interface {
	ReportHealth(context.Context, *connect.Request[v1.ReportHealthRequest]) (*connect.Response[v1.ReportHealthResponse], error)
}

OperatorHealthServiceClient is a client for the api.v1.OperatorHealthService service.

func NewOperatorHealthServiceClient added in v0.0.64 

func NewOperatorHealthServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) OperatorHealthServiceClient

NewOperatorHealthServiceClient constructs a client for the api.v1.OperatorHealthService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type OperatorHealthServiceHandler added in v0.0.64 

type OperatorHealthServiceHandler interface {
	ReportHealth(context.Context, *connect.Request[v1.ReportHealthRequest]) (*connect.Response[v1.ReportHealthResponse], error)
}

OperatorHealthServiceHandler is an implementation of the api.v1.OperatorHealthService service.

type OperatorServiceClient added in v0.0.64 

type OperatorServiceClient interface {
	GetOperators(context.Context, *connect.Request[v1.GetOperatorsRequest]) (*connect.Response[v1.GetOperatorsResponse], error)
	GetOperatorMetadata(context.Context, *connect.Request[v1.GetOperatorMetadataRequest]) (*connect.Response[v1.GetOperatorMetadataResponse], error)
	GetOCIRegistries(context.Context, *connect.Request[v1.GetOCIRegistriesRequest]) (*connect.Response[v1.GetOCIRegistriesResponse], error)
}

OperatorServiceClient is a client for the api.v1.OperatorService service.

func NewOperatorServiceClient added in v0.0.64 

func NewOperatorServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) OperatorServiceClient

NewOperatorServiceClient constructs a client for the api.v1.OperatorService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type OperatorServiceHandler added in v0.0.64 

type OperatorServiceHandler interface {
	GetOperators(context.Context, *connect.Request[v1.GetOperatorsRequest]) (*connect.Response[v1.GetOperatorsResponse], error)
	GetOperatorMetadata(context.Context, *connect.Request[v1.GetOperatorMetadataRequest]) (*connect.Response[v1.GetOperatorMetadataResponse], error)
	GetOCIRegistries(context.Context, *connect.Request[v1.GetOCIRegistriesRequest]) (*connect.Response[v1.GetOCIRegistriesResponse], error)
}

OperatorServiceHandler is an implementation of the api.v1.OperatorService service.

type UnimplementedClusterMutationServiceHandler 

type UnimplementedClusterMutationServiceHandler struct{}

UnimplementedClusterMutationServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedClusterMutationServiceHandler) CreateCluster 

func (UnimplementedClusterMutationServiceHandler) CreateCluster(context.Context, *connect.Request[v1.CreateClusterRequest]) (*connect.Response[v1.CreateClusterResponse], error)

func (UnimplementedClusterMutationServiceHandler) DeleteCluster 

func (UnimplementedClusterMutationServiceHandler) DeleteCluster(context.Context, *connect.Request[v1.DeleteClusterRequest]) (*connect.Response[v1.DeleteClusterResponse], error)

func (UnimplementedClusterMutationServiceHandler) ResetClusterToken 

func (UnimplementedClusterMutationServiceHandler) ResetClusterToken(context.Context, *connect.Request[v1.ResetClusterTokenRequest]) (*connect.Response[v1.ResetClusterTokenResponse], error)

func (UnimplementedClusterMutationServiceHandler) UpdateCluster 

func (UnimplementedClusterMutationServiceHandler) UpdateCluster(context.Context, *connect.Request[v1.UpdateClusterRequest]) (*connect.Response[v1.UpdateClusterResponse], error)

type UnimplementedClusterServiceHandler 

type UnimplementedClusterServiceHandler struct{}

UnimplementedClusterServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedClusterServiceHandler) CreateClusterToken 

func (UnimplementedClusterServiceHandler) CreateClusterToken(context.Context, *connect.Request[v1.CreateClusterTokenRequest]) (*connect.Response[v1.CreateClusterTokenResponse], error)

func (UnimplementedClusterServiceHandler) GetClusterIDByName added in v0.0.76 

func (UnimplementedClusterServiceHandler) GetClusterIDByName(context.Context, *connect.Request[v1.GetClusterIDByNameRequest]) (*connect.Response[v1.GetClusterIDByNameResponse], error)

func (UnimplementedClusterServiceHandler) GetClusterInfoByName added in v0.0.76 

func (UnimplementedClusterServiceHandler) GetClusterInfoByName(context.Context, *connect.Request[v1.GetClusterInfoByNameRequest]) (*connect.Response[v1.GetClusterInfoByNameResponse], error)

func (UnimplementedClusterServiceHandler) GetClustersBasicInfo 

func (UnimplementedClusterServiceHandler) GetClustersBasicInfo(context.Context, *connect.Request[v1.GetClustersBasicInfoRequest]) (*connect.Response[v1.GetClustersBasicInfoResponse], error)

func (UnimplementedClusterServiceHandler) GetClustersDeltaMetrics added in v0.0.66 

func (UnimplementedClusterServiceHandler) GetClustersDeltaMetrics(context.Context, *connect.Request[v1.GetClustersDeltaMetricsRequest]) (*connect.Response[v1.GetClustersDeltaMetricsResponse], error)

func (UnimplementedClusterServiceHandler) GetClustersWithMetrics 

func (UnimplementedClusterServiceHandler) GetClustersWithMetrics(context.Context, *connect.Request[v1.GetClustersWithMetricsRequest]) (*connect.Response[v1.GetClustersWithMetricsResponse], error)

func (UnimplementedClusterServiceHandler) GetNetworkDependencies added in v0.0.55 

func (UnimplementedClusterServiceHandler) GetNetworkDependencies(context.Context, *connect.Request[v1.GetNetworkDependenciesRequest]) (*connect.Response[v1.GetNetworkDependenciesResponse], error)

func (UnimplementedClusterServiceHandler) GetNetworkMetricsTimeSeries added in v0.0.66 

func (UnimplementedClusterServiceHandler) GetNetworkMetricsTimeSeries(context.Context, *connect.Request[v1.GetNetworkMetricsTimeSeriesRequest]) (*connect.Response[v1.GetNetworkMetricsTimeSeriesResponse], error)

func (UnimplementedClusterServiceHandler) GetNodeTypeCounts added in v0.0.66 

func (UnimplementedClusterServiceHandler) GetNodeTypeCounts(context.Context, *connect.Request[v1.GetNodeTypeCountsRequest]) (*connect.Response[v1.GetNodeTypeCountsResponse], error)

type UnimplementedInstanceServiceHandler 

type UnimplementedInstanceServiceHandler struct{}

UnimplementedInstanceServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedInstanceServiceHandler) GetAvailabilityZone 

func (UnimplementedInstanceServiceHandler) GetAvailabilityZone(context.Context, *connect.Request[v1.GetAvailabilityZoneRequest]) (*connect.Response[v1.GetAvailabilityZoneResponse], error)

func (UnimplementedInstanceServiceHandler) GetAvailabilityZones 

func (UnimplementedInstanceServiceHandler) GetAvailabilityZones(context.Context, *connect.Request[v1.GetAvailabilityZonesRequest]) (*connect.Response[v1.GetAvailabilityZonesResponse], error)

func (UnimplementedInstanceServiceHandler) GetCloudProvider 

func (UnimplementedInstanceServiceHandler) GetCloudProvider(context.Context, *connect.Request[v1.GetCloudProviderRequest]) (*connect.Response[v1.GetCloudProviderResponse], error)

func (UnimplementedInstanceServiceHandler) GetCloudProviders 

func (UnimplementedInstanceServiceHandler) GetCloudProviders(context.Context, *connect.Request[v1.GetCloudProvidersRequest]) (*connect.Response[v1.GetCloudProvidersResponse], error)

func (UnimplementedInstanceServiceHandler) GetInstance 

func (UnimplementedInstanceServiceHandler) GetInstance(context.Context, *connect.Request[v1.GetInstanceRequest]) (*connect.Response[v1.GetInstanceResponse], error)

func (UnimplementedInstanceServiceHandler) GetInstanceType 

func (UnimplementedInstanceServiceHandler) GetInstanceType(context.Context, *connect.Request[v1.GetInstanceTypeRequest]) (*connect.Response[v1.GetInstanceTypeResponse], error)

func (UnimplementedInstanceServiceHandler) GetInstanceTypes 

func (UnimplementedInstanceServiceHandler) GetInstanceTypes(context.Context, *connect.Request[v1.GetInstanceTypesRequest]) (*connect.Response[v1.GetInstanceTypesResponse], error)

func (UnimplementedInstanceServiceHandler) GetInstances 

func (UnimplementedInstanceServiceHandler) GetInstances(context.Context, *connect.Request[v1.GetInstancesRequest]) (*connect.Response[v1.GetInstancesResponse], error)

func (UnimplementedInstanceServiceHandler) GetOperatingSystem 

func (UnimplementedInstanceServiceHandler) GetOperatingSystem(context.Context, *connect.Request[v1.GetOperatingSystemRequest]) (*connect.Response[v1.GetOperatingSystemResponse], error)

func (UnimplementedInstanceServiceHandler) GetOperatingSystems 

func (UnimplementedInstanceServiceHandler) GetOperatingSystems(context.Context, *connect.Request[v1.GetOperatingSystemsRequest]) (*connect.Response[v1.GetOperatingSystemsResponse], error)

func (UnimplementedInstanceServiceHandler) GetRegion 

func (UnimplementedInstanceServiceHandler) GetRegion(context.Context, *connect.Request[v1.GetRegionRequest]) (*connect.Response[v1.GetRegionResponse], error)

func (UnimplementedInstanceServiceHandler) GetRegions 

func (UnimplementedInstanceServiceHandler) GetRegions(context.Context, *connect.Request[v1.GetRegionsRequest]) (*connect.Response[v1.GetRegionsResponse], error)

type UnimplementedK8SServiceHandler 

type UnimplementedK8SServiceHandler struct{}

UnimplementedK8SServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedK8SServiceHandler) AddClusterTags added in v0.0.63 

func (UnimplementedK8SServiceHandler) AddClusterTags(context.Context, *connect.Request[v1.AddClusterTagsRequest]) (*connect.Response[v1.AddClusterTagsResponse], error)

func (UnimplementedK8SServiceHandler) GalaxyGetWorkloadPerspective 

func (UnimplementedK8SServiceHandler) GalaxyGetWorkloadPerspective(context.Context, *connect.Request[v1.GalaxyGetWorkloadPerspectiveRequest]) (*connect.Response[v1.GalaxyGetWorkloadPerspectiveResponse], error)

func (UnimplementedK8SServiceHandler) GetAllNamespaces 

func (UnimplementedK8SServiceHandler) GetAllNamespaces(context.Context, *connect.Request[v1.GetAllNamespacesRequest]) (*connect.Response[v1.GetAllNamespacesResponse], error)

func (UnimplementedK8SServiceHandler) GetAllNodeGroupNames 

func (UnimplementedK8SServiceHandler) GetAllNodeGroupNames(context.Context, *connect.Request[v1.GetAllNodeGroupNamesRequest]) (*connect.Response[v1.GetAllNodeGroupNamesResponse], error)

func (UnimplementedK8SServiceHandler) GetAllNodeGroups 

func (UnimplementedK8SServiceHandler) GetAllNodeGroups(context.Context, *connect.Request[v1.GetAllNodeGroupsRequest]) (*connect.Response[v1.GetAllNodeGroupsResponse], error)

func (UnimplementedK8SServiceHandler) GetAllWorkloadLabels 

func (UnimplementedK8SServiceHandler) GetAllWorkloadLabels(context.Context, *connect.Request[v1.GetAllWorkloadLabelsRequest]) (*connect.Response[v1.GetAllWorkloadLabelsResponse], error)

func (UnimplementedK8SServiceHandler) GetAllWorkloadNames 

func (UnimplementedK8SServiceHandler) GetAllWorkloadNames(context.Context, *connect.Request[v1.GetAllWorkloadNamesRequest]) (*connect.Response[v1.GetAllWorkloadNamesResponse], error)

func (UnimplementedK8SServiceHandler) GetCluster 

func (UnimplementedK8SServiceHandler) GetCluster(context.Context, *connect.Request[v1.GetClusterRequest]) (*connect.Response[v1.GetClusterResponse], error)

func (UnimplementedK8SServiceHandler) GetClusterMetadata 

func (UnimplementedK8SServiceHandler) GetClusterMetadata(context.Context, *connect.Request[v1.GetClusterMetadataRequest]) (*connect.Response[v1.GetClusterMetadataResponse], error)

func (UnimplementedK8SServiceHandler) GetClusterType 

func (UnimplementedK8SServiceHandler) GetClusterType(context.Context, *connect.Request[v1.GetClusterTypeRequest]) (*connect.Response[v1.GetClusterTypeResponse], error)

func (UnimplementedK8SServiceHandler) GetClusters 

func (UnimplementedK8SServiceHandler) GetClusters(context.Context, *connect.Request[v1.GetClustersRequest]) (*connect.Response[v1.GetClustersResponse], error)

func (UnimplementedK8SServiceHandler) GetClustersNodeInfo 

func (UnimplementedK8SServiceHandler) GetClustersNodeInfo(context.Context, *connect.Request[v1.GetClustersNodeInfoRequest]) (*connect.Response[v1.GetClustersNodeInfoResponse], error)

func (UnimplementedK8SServiceHandler) GetForecastWorkload 

func (UnimplementedK8SServiceHandler) GetForecastWorkload(context.Context, *connect.Request[v1.GetForecastWorkloadRequest]) (*connect.Response[v1.GetForecastWorkloadResponse], error)

func (UnimplementedK8SServiceHandler) GetForecastWorkloads 

func (UnimplementedK8SServiceHandler) GetForecastWorkloads(context.Context, *connect.Request[v1.GetForecastWorkloadsRequest]) (*connect.Response[v1.GetForecastWorkloadsResponse], error)

func (UnimplementedK8SServiceHandler) GetLatestContainerRequestLimits added in v0.0.76 

func (UnimplementedK8SServiceHandler) GetLatestContainerRequestLimits(context.Context, *connect.Request[v1.GetLatestContainerRequestLimitsRequest]) (*connect.Response[v1.GetLatestContainerRequestLimitsResponse], error)

func (UnimplementedK8SServiceHandler) GetLatestOperatorVersion 

func (UnimplementedK8SServiceHandler) GetLatestOperatorVersion(context.Context, *connect.Request[v1.GetLatestOperatorVersionRequest]) (*connect.Response[v1.GetLatestOperatorVersionResponse], error)

func (UnimplementedK8SServiceHandler) GetNode 

func (UnimplementedK8SServiceHandler) GetNode(context.Context, *connect.Request[v1.GetNodeRequest]) (*connect.Response[v1.GetNodeResponse], error)

func (UnimplementedK8SServiceHandler) GetNodeGroup 

func (UnimplementedK8SServiceHandler) GetNodeGroup(context.Context, *connect.Request[v1.GetNodeGroupRequest]) (*connect.Response[v1.GetNodeGroupResponse], error)

func (UnimplementedK8SServiceHandler) GetNodeGroups 

func (UnimplementedK8SServiceHandler) GetNodeGroups(context.Context, *connect.Request[v1.GetNodeGroupsRequest]) (*connect.Response[v1.GetNodeGroupsResponse], error)

func (UnimplementedK8SServiceHandler) GetNodeGroupsUtilization 

func (UnimplementedK8SServiceHandler) GetNodeGroupsUtilization(context.Context, *connect.Request[v1.GetNodeGroupsUtilizationRequest]) (*connect.Response[v1.GetNodeGroupsUtilizationResponse], error)

func (UnimplementedK8SServiceHandler) GetPods 

func (UnimplementedK8SServiceHandler) GetPods(context.Context, *connect.Request[v1.GetPodsRequest]) (*connect.Response[v1.GetPodsResponse], error)

func (UnimplementedK8SServiceHandler) GetRelationsForKind 

func (UnimplementedK8SServiceHandler) GetRelationsForKind(context.Context, *connect.Request[v1.GetRelatedResourcesRequest]) (*connect.Response[v1.GetRelatedResourcesResponse], error)

func (UnimplementedK8SServiceHandler) GetResources 

func (UnimplementedK8SServiceHandler) GetResources(context.Context, *connect.Request[v1.GetResourcesRequest]) (*connect.Response[v1.GetResourcesResponse], error)

func (UnimplementedK8SServiceHandler) GetWorkload 

func (UnimplementedK8SServiceHandler) GetWorkload(context.Context, *connect.Request[v1.GetWorkloadRequest]) (*connect.Response[v1.GetWorkloadResponse], error)

func (UnimplementedK8SServiceHandler) GetWorkloadContainerPercentiles added in v0.0.76 

func (UnimplementedK8SServiceHandler) GetWorkloadContainerPercentiles(context.Context, *connect.Request[v1.GetWorkloadContainerPercentilesRequest]) (*connect.Response[v1.GetWorkloadContainerPercentilesResponse], error)

func (UnimplementedK8SServiceHandler) GetWorkloadContainerTimeSeries added in v0.0.76 

func (UnimplementedK8SServiceHandler) GetWorkloadContainerTimeSeries(context.Context, *connect.Request[v1.GetWorkloadContainerTimeSeriesRequest]) (*connect.Response[v1.GetWorkloadContainerTimeSeriesResponse], error)

func (UnimplementedK8SServiceHandler) GetWorkloadPodHistory 

func (UnimplementedK8SServiceHandler) GetWorkloadPodHistory(context.Context, *connect.Request[v1.GetWorkloadPodHistoryRequest]) (*connect.Response[v1.GetWorkloadPodHistoryResponse], error)

func (UnimplementedK8SServiceHandler) GetWorkloads 

func (UnimplementedK8SServiceHandler) GetWorkloads(context.Context, *connect.Request[v1.GetWorkloadsRequest]) (*connect.Response[v1.GetWorkloadsResponse], error)

func (UnimplementedK8SServiceHandler) GetWorkloadsStats 

func (UnimplementedK8SServiceHandler) GetWorkloadsStats(context.Context, *connect.Request[v1.GetWorkloadsStatsRequest]) (*connect.Response[v1.GetWorkloadsStatsResponse], error)

func (UnimplementedK8SServiceHandler) ListAuditLogOriginators 

func (UnimplementedK8SServiceHandler) ListAuditLogOriginators(context.Context, *connect.Request[v1.ListAuditLogOriginatorsRequest]) (*connect.Response[v1.ListAuditLogOriginatorsResponse], error)

func (UnimplementedK8SServiceHandler) ListAuditLogs 

func (UnimplementedK8SServiceHandler) ListAuditLogs(context.Context, *connect.Request[v1.ListAuditLogsRequest]) (*connect.Response[v1.ListAuditLogsResponse], error)

func (UnimplementedK8SServiceHandler) ListClusters 

func (UnimplementedK8SServiceHandler) ListClusters(context.Context, *connect.Request[v1.ListClustersRequest]) (*connect.Response[v1.ListClustersResponse], error)

func (UnimplementedK8SServiceHandler) ListNamespacesByCluster added in v0.0.76 

func (UnimplementedK8SServiceHandler) ListNamespacesByCluster(context.Context, *connect.Request[v1.ListNamespacesByClusterRequest]) (*connect.Response[v1.ListNamespacesByClusterResponse], error)

func (UnimplementedK8SServiceHandler) ListTags added in v0.0.63 

func (UnimplementedK8SServiceHandler) ListTags(context.Context, *connect.Request[v1.ListTagsRequest]) (*connect.Response[v1.ListTagsResponse], error)

func (UnimplementedK8SServiceHandler) LookupNodeInstance 

func (UnimplementedK8SServiceHandler) LookupNodeInstance(context.Context, *connect.Request[v1.LookupNodeInstanceRequest]) (*connect.Response[v1.LookupNodeInstanceResponse], error)

func (UnimplementedK8SServiceHandler) MetadataForWorkloads 

func (UnimplementedK8SServiceHandler) MetadataForWorkloads(context.Context, *connect.Request[v1.MetadataForWorkloadsRequest]) (*connect.Response[v1.MetadataForWorkloadsResponse], error)

func (UnimplementedK8SServiceHandler) RemoveClusterTags added in v0.0.63 

func (UnimplementedK8SServiceHandler) RemoveClusterTags(context.Context, *connect.Request[v1.RemoveClusterTagsRequest]) (*connect.Response[v1.RemoveClusterTagsResponse], error)

func (UnimplementedK8SServiceHandler) SearchK8SResources 

func (UnimplementedK8SServiceHandler) SearchK8SResources(context.Context, *connect.Request[v1.SearchK8SResourcesRequest]) (*connect.Response[v1.SearchK8SResourcesResponse], error)

func (UnimplementedK8SServiceHandler) SearchK8SWorkloads 

func (UnimplementedK8SServiceHandler) SearchK8SWorkloads(context.Context, *connect.Request[v1.SearchK8SWorkloadsRequest]) (*connect.Response[v1.SearchK8SWorkloadsResponse], error)

func (UnimplementedK8SServiceHandler) SearchNamespacesByCluster added in v0.0.63 

func (UnimplementedK8SServiceHandler) SearchNamespacesByCluster(context.Context, *connect.Request[v1.SearchNamespacesByClusterRequest]) (*connect.Response[v1.SearchNamespacesByClusterResponse], error)

func (UnimplementedK8SServiceHandler) SendWeeklySummaryEmail 

func (UnimplementedK8SServiceHandler) SendWeeklySummaryEmail(context.Context, *connect.Request[v1.SendWeeklySummaryEmailRequest]) (*connect.Response[v1.SendWeeklySummaryEmailResponse], error)

func (UnimplementedK8SServiceHandler) SendWorkloadEmail 

func (UnimplementedK8SServiceHandler) SendWorkloadEmail(context.Context, *connect.Request[v1.SendWorkloadEmailRequest]) (*connect.Response[v1.SendWorkloadEmailResponse], error)

type UnimplementedMetricsCollectorServiceHandler 

type UnimplementedMetricsCollectorServiceHandler struct{}

UnimplementedMetricsCollectorServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedMetricsCollectorServiceHandler) NodeMetadata 

func (UnimplementedMetricsCollectorServiceHandler) NodeMetadata(context.Context, *connect.Request[v1.NodeMetadataRequest]) (*connect.Response[v1.NodeMetadataResponse], error)

func (UnimplementedMetricsCollectorServiceHandler) SendClusterSnapshotStream 

func (UnimplementedMetricsCollectorServiceHandler) SendClusterSnapshotStream(context.Context, *connect.ClientStream[v1.ClusterSnapshotChunk]) (*connect.Response[v1.SendClusterSnapshotStreamResponse], error)

func (UnimplementedMetricsCollectorServiceHandler) SendNetworkTrafficMetrics 

func (UnimplementedMetricsCollectorServiceHandler) SendNetworkTrafficMetrics(context.Context, *connect.Request[v1.SendNetworkTrafficMetricsRequest]) (*connect.Response[v1.SendNetworkTrafficMetricsResponse], error)

func (UnimplementedMetricsCollectorServiceHandler) SendResource 

func (UnimplementedMetricsCollectorServiceHandler) SendResource(context.Context, *connect.Request[v1.SendResourceRequest]) (*connect.Response[v1.SendResourceResponse], error)

func (UnimplementedMetricsCollectorServiceHandler) SendResourceBatch 

func (UnimplementedMetricsCollectorServiceHandler) SendResourceBatch(context.Context, *connect.Request[v1.SendResourceBatchRequest]) (*connect.Response[v1.SendResourceBatchResponse], error)

func (UnimplementedMetricsCollectorServiceHandler) SendTelemetryLogs 

func (UnimplementedMetricsCollectorServiceHandler) SendTelemetryLogs(context.Context, *connect.Request[v1.SendTelemetryLogsRequest]) (*connect.Response[v1.SendTelemetryLogsResponse], error)

func (UnimplementedMetricsCollectorServiceHandler) SendTelemetryMetrics 

func (UnimplementedMetricsCollectorServiceHandler) SendTelemetryMetrics(context.Context, *connect.Request[v1.SendTelemetryMetricsRequest]) (*connect.Response[v1.SendTelemetryMetricsResponse], error)

type UnimplementedMpaServiceHandler 

type UnimplementedMpaServiceHandler struct{}

UnimplementedMpaServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedMpaServiceHandler) StreamWorkloadMetrics 

func (UnimplementedMpaServiceHandler) StreamWorkloadMetrics(context.Context, *connect.BidiStream[v1.MpaWorkloadSubscription, v1.MpaStreamResponse]) error

type UnimplementedOperatorHealthServiceHandler added in v0.0.64 

type UnimplementedOperatorHealthServiceHandler struct{}

UnimplementedOperatorHealthServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedOperatorHealthServiceHandler) ReportHealth added in v0.0.64 

func (UnimplementedOperatorHealthServiceHandler) ReportHealth(context.Context, *connect.Request[v1.ReportHealthRequest]) (*connect.Response[v1.ReportHealthResponse], error)

type UnimplementedOperatorServiceHandler added in v0.0.64 

type UnimplementedOperatorServiceHandler struct{}

UnimplementedOperatorServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedOperatorServiceHandler) GetOCIRegistries added in v0.0.64 

func (UnimplementedOperatorServiceHandler) GetOCIRegistries(context.Context, *connect.Request[v1.GetOCIRegistriesRequest]) (*connect.Response[v1.GetOCIRegistriesResponse], error)

func (UnimplementedOperatorServiceHandler) GetOperatorMetadata added in v0.0.64 

func (UnimplementedOperatorServiceHandler) GetOperatorMetadata(context.Context, *connect.Request[v1.GetOperatorMetadataRequest]) (*connect.Response[v1.GetOperatorMetadataResponse], error)

func (UnimplementedOperatorServiceHandler) GetOperators added in v0.0.64 

func (UnimplementedOperatorServiceHandler) GetOperators(context.Context, *connect.Request[v1.GetOperatorsRequest]) (*connect.Response[v1.GetOperatorsResponse], error)

type UnimplementedUtilizationServiceHandler 

type UnimplementedUtilizationServiceHandler struct{}

UnimplementedUtilizationServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedUtilizationServiceHandler) DailyUtilization 

func (UnimplementedUtilizationServiceHandler) DailyUtilization(context.Context, *connect.Request[v1.DailyUtilizationRequest]) (*connect.Response[v1.DailyUtilizationResponse], error)

func (UnimplementedUtilizationServiceHandler) DailyUtilizationInstanceType 

func (UnimplementedUtilizationServiceHandler) DailyUtilizationInstanceType(context.Context, *connect.Request[v1.DailyUtilizationInstanceTypeRequest]) (*connect.Response[v1.DailyUtilizationInstanceTypeResponse], error)

func (UnimplementedUtilizationServiceHandler) DailyUtilizationNodeType 

func (UnimplementedUtilizationServiceHandler) DailyUtilizationNodeType(context.Context, *connect.Request[v1.DailyUtilizationNodeTypeRequest]) (*connect.Response[v1.DailyUtilizationNodeTypeResponse], error)

type UtilizationServiceClient 

type UtilizationServiceClient interface {
	DailyUtilization(context.Context, *connect.Request[v1.DailyUtilizationRequest]) (*connect.Response[v1.DailyUtilizationResponse], error)
	DailyUtilizationInstanceType(context.Context, *connect.Request[v1.DailyUtilizationInstanceTypeRequest]) (*connect.Response[v1.DailyUtilizationInstanceTypeResponse], error)
	DailyUtilizationNodeType(context.Context, *connect.Request[v1.DailyUtilizationNodeTypeRequest]) (*connect.Response[v1.DailyUtilizationNodeTypeResponse], error)
}

UtilizationServiceClient is a client for the api.v1.UtilizationService service.

func NewUtilizationServiceClient 

func NewUtilizationServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) UtilizationServiceClient

NewUtilizationServiceClient constructs a client for the api.v1.UtilizationService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type UtilizationServiceHandler 

type UtilizationServiceHandler interface {
	DailyUtilization(context.Context, *connect.Request[v1.DailyUtilizationRequest]) (*connect.Response[v1.DailyUtilizationResponse], error)
	DailyUtilizationInstanceType(context.Context, *connect.Request[v1.DailyUtilizationInstanceTypeRequest]) (*connect.Response[v1.DailyUtilizationInstanceTypeResponse], error)
	DailyUtilizationNodeType(context.Context, *connect.Request[v1.DailyUtilizationNodeTypeRequest]) (*connect.Response[v1.DailyUtilizationNodeTypeResponse], error)
}

UtilizationServiceHandler is an implementation of the api.v1.UtilizationService service.

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.