predictor

Documentation

Index

• type GetPodsAssignedToNodeFunc
  • func BuildGetPodsAssignedToNodeFunc(podInformer informerv1.PodInformer) (GetPodsAssignedToNodeFunc, error)
• type Server
  • func NewServer(clientConfig *restclient.Config, kubeClient kubernetes.Interface, ...) (*Server, error)
  • func (s *Server) MaxAcceptableReplicas(ctx context.Context, requirements appsapi.ReplicaRequirements) (schedulerapi.PredictorResults, error)
  • func (s *Server) Run(ctx context.Context)
  • func (s *Server) UnschedulableReplicas(ctx context.Context, gvk metav1.GroupVersionKind, namespacedName string, ...) (int32, error)

Types

type GetPodsAssignedToNodeFunc

type GetPodsAssignedToNodeFunc func(string) ([]*corev1.Pod, error)

GetPodsAssignedToNodeFunc is a function which accept a node name input and returns the pods that assigned to the node.

func BuildGetPodsAssignedToNodeFunc

func BuildGetPodsAssignedToNodeFunc(podInformer informerv1.PodInformer) (GetPodsAssignedToNodeFunc, error)

BuildGetPodsAssignedToNodeFunc establishes an indexer to map the pods and their assigned nodes. It returns a function to help us get all the pods that assigned to a node based on the indexer.

type Server

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

func NewServer

func NewServer(
	clientConfig *restclient.Config,
	kubeClient kubernetes.Interface,
	informerFactory kubeinformers.SharedInformerFactory,
	addr string,
) (*Server, error)

func (*Server) MaxAcceptableReplicas

func (s *Server) MaxAcceptableReplicas(ctx context.Context, requirements appsapi.ReplicaRequirements) (schedulerapi.PredictorResults, error)

func (*Server) Run

func (s *Server) Run(ctx context.Context)

func (*Server) UnschedulableReplicas

func (s *Server) UnschedulableReplicas(ctx context.Context, gvk metav1.GroupVersionKind, namespacedName string,
	labelSelector map[string]string) (int32, error)