list

Documentation

Index

• Constants
• func NewClusterQueueCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, ...) *cobra.Command
• func NewListCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, ...) *cobra.Command
• func NewLocalQueueCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, ...) *cobra.Command
• func NewResourceFlavorCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, ...) *cobra.Command
• func NewWorkloadCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, ...) *cobra.Command
• type ClusterQueueOptions
  • func NewClusterQueueOptions(streams genericiooptions.IOStreams, clock clock.Clock) *ClusterQueueOptions
  • func (o *ClusterQueueOptions) Complete(clientGetter util.ClientGetter, cmd *cobra.Command, args []string) error
  • func (o *ClusterQueueOptions) Run(ctx context.Context) error
  • func (o *ClusterQueueOptions) ToPrinter(headers bool) (printers.ResourcePrinterFunc, error)
  • func (o *ClusterQueueOptions) Validate() error
• type LocalQueueOptions
  • func NewLocalQueueOptions(streams genericiooptions.IOStreams, clock clock.Clock) *LocalQueueOptions
  • func (o *LocalQueueOptions) Complete(clientGetter util.ClientGetter) error
  • func (o *LocalQueueOptions) Run(ctx context.Context) error
  • func (o *LocalQueueOptions) ToPrinter(headers bool) (printers.ResourcePrinterFunc, error)
• type ResourceFlavorOptions
  • func NewResourceFlavorOptions(streams genericiooptions.IOStreams, clock clock.Clock) *ResourceFlavorOptions
  • func (o *ResourceFlavorOptions) Complete(clientGetter util.ClientGetter) error
  • func (o *ResourceFlavorOptions) Run(ctx context.Context) error
  • func (o *ResourceFlavorOptions) ToPrinter(headers bool) (printers.ResourcePrinterFunc, error)
• type WorkloadOptions
  • func NewWorkloadOptions(streams genericiooptions.IOStreams, clock clock.Clock) *WorkloadOptions
  • func (o *WorkloadOptions) Complete(clientGetter util.ClientGetter, cmd *cobra.Command) error
  • func (o *WorkloadOptions) Run(ctx context.Context) error
  • func (o *WorkloadOptions) ToPrinter(r *listWorkloadResources, headers bool) (printers.ResourcePrinterFunc, error)

Constants

const (
	KueuectlListRequestLimitEnvName = "KUEUECTL_LIST_REQUEST_LIMIT"
)

Functions

func NewClusterQueueCmd

func NewClusterQueueCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, clock clock.Clock) *cobra.Command

func NewListCmd

func NewListCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, clock clock.Clock) *cobra.Command

func NewLocalQueueCmd

func NewLocalQueueCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, clock clock.Clock) *cobra.Command

func NewResourceFlavorCmd

func NewResourceFlavorCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, clock clock.Clock) *cobra.Command

func NewWorkloadCmd

func NewWorkloadCmd(clientGetter util.ClientGetter, streams genericiooptions.IOStreams, clock clock.Clock) *cobra.Command

Types

type ClusterQueueOptions

type ClusterQueueOptions struct {
	Clock clock.Clock
	// PrintFlags holds options necessary for obtaining a printer
	PrintFlags *genericclioptions.PrintFlags

	Limit         int64
	LabelSelector string
	FieldSelector string

	// Kueuectl flags
	// Active is an optional flag to filter true/false (active/inactive) cluster queues
	// Active means the cluster queue has kueue.ClusterQueueActive condition with status=metav1.ConditionTrue
	Active []bool

	Client kueuev1beta1.KueueV1beta1Interface

	genericiooptions.IOStreams
}

func NewClusterQueueOptions

func NewClusterQueueOptions(streams genericiooptions.IOStreams, clock clock.Clock) *ClusterQueueOptions

func (*ClusterQueueOptions) Complete

func (o *ClusterQueueOptions) Complete(clientGetter util.ClientGetter, cmd *cobra.Command, args []string) error

Complete takes the command arguments and infers any remaining options.

func (*ClusterQueueOptions) Run

func (o *ClusterQueueOptions) Run(ctx context.Context) error

Run prints the cluster queues.

func (*ClusterQueueOptions) ToPrinter

func (o *ClusterQueueOptions) ToPrinter(headers bool) (printers.ResourcePrinterFunc, error)

func (*ClusterQueueOptions) Validate

func (o *ClusterQueueOptions) Validate() error

type LocalQueueOptions

type LocalQueueOptions struct {
	Clock      clock.Clock
	PrintFlags *genericclioptions.PrintFlags

	Limit              int64
	AllNamespaces      bool
	Namespace          string
	FieldSelector      string
	LabelSelector      string
	ClusterQueueFilter string

	Client kueuev1beta1.KueueV1beta1Interface

	genericiooptions.IOStreams
}

func NewLocalQueueOptions

func NewLocalQueueOptions(streams genericiooptions.IOStreams, clock clock.Clock) *LocalQueueOptions

func (*LocalQueueOptions) Complete

func (o *LocalQueueOptions) Complete(clientGetter util.ClientGetter) error

Complete completes all the required options

func (*LocalQueueOptions) Run

func (o *LocalQueueOptions) Run(ctx context.Context) error

Run performs the list operation.

func (*LocalQueueOptions) ToPrinter

func (o *LocalQueueOptions) ToPrinter(headers bool) (printers.ResourcePrinterFunc, error)

type ResourceFlavorOptions

type ResourceFlavorOptions struct {
	Clock      clock.Clock
	PrintFlags *genericclioptions.PrintFlags

	Limit         int64
	FieldSelector string
	LabelSelector string

	Client kueuev1beta1.KueueV1beta1Interface

	genericiooptions.IOStreams
}

func NewResourceFlavorOptions

func NewResourceFlavorOptions(streams genericiooptions.IOStreams, clock clock.Clock) *ResourceFlavorOptions

func (*ResourceFlavorOptions) Complete

func (o *ResourceFlavorOptions) Complete(clientGetter util.ClientGetter) error

Complete completes all the required options

func (*ResourceFlavorOptions) Run

func (o *ResourceFlavorOptions) Run(ctx context.Context) error

Run performs the list operation.

func (*ResourceFlavorOptions) ToPrinter

func (o *ResourceFlavorOptions) ToPrinter(headers bool) (printers.ResourcePrinterFunc, error)

type WorkloadOptions

type WorkloadOptions struct {
	Clock      clock.Clock
	PrintFlags *genericclioptions.PrintFlags

	Limit              int64
	AllNamespaces      bool
	Namespace          string
	FieldSelector      string
	LabelSelector      string
	ClusterQueueFilter string
	LocalQueueFilter   string
	StatusesFilter     sets.Set[int]

	UserSpecifiedForObject string

	ClientSet clientset.Interface

	genericiooptions.IOStreams
	// contains filtered or unexported fields
}

func NewWorkloadOptions

func NewWorkloadOptions(streams genericiooptions.IOStreams, clock clock.Clock) *WorkloadOptions

func (*WorkloadOptions) Complete

func (o *WorkloadOptions) Complete(clientGetter util.ClientGetter, cmd *cobra.Command) error

Complete completes all the required options

func (*WorkloadOptions) Run

func (o *WorkloadOptions) Run(ctx context.Context) error

Run performs the list operation.

func (*WorkloadOptions) ToPrinter

func (o *WorkloadOptions) ToPrinter(r *listWorkloadResources, headers bool) (printers.ResourcePrinterFunc, error)