Documentation
¶
Index ¶
- type AccurateSchedulerEstimatorServer
- func (es *AccurateSchedulerEstimatorServer) EstimateComponents(ctx context.Context, object string, ...) (int32, error)
- func (es *AccurateSchedulerEstimatorServer) EstimateReplicas(ctx context.Context, object string, request *pb.MaxAvailableReplicasRequest) (int32, error)
- func (es *AccurateSchedulerEstimatorServer) GetUnschedulableReplicas(ctx context.Context, request *pb.UnschedulableReplicasRequest) (response *pb.UnschedulableReplicasResponse, rerr error)
- func (es *AccurateSchedulerEstimatorServer) MaxAvailableComponentSets(ctx context.Context, request *pb.MaxAvailableComponentSetsRequest) (response *pb.MaxAvailableComponentSetsResponse, rerr error)
- func (es *AccurateSchedulerEstimatorServer) MaxAvailableReplicas(ctx context.Context, request *pb.MaxAvailableReplicasRequest) (response *pb.MaxAvailableReplicasResponse, rerr error)
- func (es *AccurateSchedulerEstimatorServer) Start(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AccurateSchedulerEstimatorServer ¶
type AccurateSchedulerEstimatorServer struct {
Cache schedcache.Cache
GrpcConfig *grpcconnection.ServerConfig
// contains filtered or unexported fields
}
AccurateSchedulerEstimatorServer is the gRPC server of a cluster accurate scheduler estimator. Please see https://github.com/karmada-io/karmada/pull/580 (#580).
func NewEstimatorServer ¶
func NewEstimatorServer( ctx context.Context, kubeClient kubernetes.Interface, dynamicClient dynamic.Interface, discoveryClient discovery.DiscoveryInterface, opts *options.Options, ) (*AccurateSchedulerEstimatorServer, error)
NewEstimatorServer creates an instance of AccurateSchedulerEstimatorServer.
func (*AccurateSchedulerEstimatorServer) EstimateComponents ¶ added in v1.16.0
func (es *AccurateSchedulerEstimatorServer) EstimateComponents(ctx context.Context, object string, request *pb.MaxAvailableComponentSetsRequest) (int32, error)
EstimateComponents returns max available component sets in terms of request and cluster status.
func (*AccurateSchedulerEstimatorServer) EstimateReplicas ¶ added in v1.4.0
func (es *AccurateSchedulerEstimatorServer) EstimateReplicas(ctx context.Context, object string, request *pb.MaxAvailableReplicasRequest) (int32, error)
EstimateReplicas returns max available replicas in terms of request and cluster status.
func (*AccurateSchedulerEstimatorServer) GetUnschedulableReplicas ¶ added in v1.1.0
func (es *AccurateSchedulerEstimatorServer) GetUnschedulableReplicas(ctx context.Context, request *pb.UnschedulableReplicasRequest) (response *pb.UnschedulableReplicasResponse, rerr error)
GetUnschedulableReplicas is the implementation of gRPC interface. It will return the unschedulable replicas of a workload.
func (*AccurateSchedulerEstimatorServer) MaxAvailableComponentSets ¶ added in v1.16.0
func (es *AccurateSchedulerEstimatorServer) MaxAvailableComponentSets(ctx context.Context, request *pb.MaxAvailableComponentSetsRequest) (response *pb.MaxAvailableComponentSetsResponse, rerr error)
MaxAvailableComponentSets is the implementation of gRPC interface. It returns the maximum number of complete multi-component sets (in terms of replicas) that each cluster can host.
func (*AccurateSchedulerEstimatorServer) MaxAvailableReplicas ¶
func (es *AccurateSchedulerEstimatorServer) MaxAvailableReplicas(ctx context.Context, request *pb.MaxAvailableReplicasRequest) (response *pb.MaxAvailableReplicasResponse, rerr error)
MaxAvailableReplicas is the implementation of gRPC interface. It will return the max available replicas that a cluster could accommodate based on its requirements.
Source Files
Directories