thunderingherdscheduling

Documentation

Index

• Constants
• Variables
• func New(obj runtime.Object, handle framework.Handle) (framework.Plugin, error)
• func SetDefaultThunderingHerdArgs(args *ThunderingHerdSchedulingArgs)
• type ThunderingHerdScheduling
  • func (t *ThunderingHerdScheduling) Name() string
  • func (t *ThunderingHerdScheduling) Permit(_ context.Context, _ *framework.CycleState, p *v1.Pod, nodeName string) (*framework.Status, time.Duration)
  • func (t *ThunderingHerdScheduling) PermitInternal(p *v1.Pod, nodeName string) (*framework.Status, time.Duration)
• type ThunderingHerdSchedulingArgs
  • func ParseArguments(obj runtime.Object) (*ThunderingHerdSchedulingArgs, error)
  • func (in *ThunderingHerdSchedulingArgs) DeepCopy() *ThunderingHerdSchedulingArgs
  • func (in *ThunderingHerdSchedulingArgs) DeepCopyInto(out *ThunderingHerdSchedulingArgs)
  • func (in *ThunderingHerdSchedulingArgs) DeepCopyObject() runtime.Object
  • func (in *ThunderingHerdSchedulingArgs) PrintArgs()

Constants

const GroupName = "kubescheduler.config.k8s.io"

const (
	Name = "ThunderingHerdScheduling"
)

Variables

var (
	AddToScheme = localSchemeBuilder.AddToScheme
)

var SchemaVersionV1 = schema.GroupVersion{Group: GroupName, Version: "v1"}

var SchemeGroupVersionInternal = schema.GroupVersion{Group: GroupName, Version: runtime.APIVersionInternal}

Functions

func New

func New(obj runtime.Object, handle framework.Handle) (framework.Plugin, error)

func SetDefaultThunderingHerdArgs

func SetDefaultThunderingHerdArgs(args *ThunderingHerdSchedulingArgs)

Types

type ThunderingHerdScheduling

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

func (*ThunderingHerdScheduling) Name

func (t *ThunderingHerdScheduling) Name() string

func (*ThunderingHerdScheduling) Permit

func (t *ThunderingHerdScheduling) Permit(_ context.Context, _ *framework.CycleState, p *v1.Pod, nodeName string) (*framework.Status, time.Duration)

func (*ThunderingHerdScheduling) PermitInternal

func (t *ThunderingHerdScheduling) PermitInternal(p *v1.Pod, nodeName string) (*framework.Status, time.Duration)

type ThunderingHerdSchedulingArgs

type ThunderingHerdSchedulingArgs struct {
	meta_v1.TypeMeta

	ParallelStartingPodsPerNode *int `json:"parallelStartingPodsPerNode"`
	TimeoutSeconds              *int `json:"timeoutSeconds"`
	MaxRetries                  *int `json:"maxRetries"`
}

func ParseArguments

func ParseArguments(obj runtime.Object) (*ThunderingHerdSchedulingArgs, error)

func (*ThunderingHerdSchedulingArgs) DeepCopy

func (in *ThunderingHerdSchedulingArgs) DeepCopy() *ThunderingHerdSchedulingArgs

func (*ThunderingHerdSchedulingArgs) DeepCopyInto

func (in *ThunderingHerdSchedulingArgs) DeepCopyInto(out *ThunderingHerdSchedulingArgs)

func (*ThunderingHerdSchedulingArgs) DeepCopyObject

func (in *ThunderingHerdSchedulingArgs) DeepCopyObject() runtime.Object

func (*ThunderingHerdSchedulingArgs) PrintArgs

func (in *ThunderingHerdSchedulingArgs) PrintArgs()