task

package

v4.0.3 Latest Latest Go to latest Published: Jan 14, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kubesphere/kubekey

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func GetAttrs(obj runtime.Object) (labels.Set, fields.Set, error)
func MatchTask(label labels.Selector, fd fields.Selector) apistorage.SelectionPredicate
func NameTriggerFunc(obj runtime.Object) string
func OwnerPlaybookIndexFunc(obj any) ([]string, error)
func ToSelectableFields(task *kkcorev1alpha1.Task) fields.Set
type REST
type StatusREST
type TaskStorage
- func NewStorage(optsGetter apigeneric.RESTOptionsGetter) (TaskStorage, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var Strategy = taskStrategy{_const.Scheme, apinames.SimpleNameGenerator}

Strategy is the default logic that applies when creating and updating Pod objects via the REST API.

Functions ¶

func GetAttrs ¶

func GetAttrs(obj runtime.Object) (labels.Set, fields.Set, error)

GetAttrs returns labels and fields of a given object for filtering purposes.

func MatchTask ¶

func MatchTask(label labels.Selector, fd fields.Selector) apistorage.SelectionPredicate

MatchTask returns a generic matcher for a given label and field selector.

func NameTriggerFunc ¶

func NameTriggerFunc(obj runtime.Object) string

NameTriggerFunc returns value metadata.namespace of given object.

func OwnerPlaybookIndexFunc ¶

func OwnerPlaybookIndexFunc(obj any) ([]string, error)

OwnerPlaybookIndexFunc return value ownerReference.object is playbook.

func ToSelectableFields ¶

func ToSelectableFields(task *kkcorev1alpha1.Task) fields.Set

ToSelectableFields returns a field set that represents the object

Types ¶

type REST ¶

type REST struct {
	*apiregistry.Store
}

REST resource for Task

type StatusREST ¶

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

StatusREST status subresource for Task

func (*StatusREST) ConvertToTable ¶

func (r *StatusREST) ConvertToTable(ctx context.Context, object runtime.Object, tableOptions runtime.Object) (*metav1.Table, error)

ConvertToTable print table view

func (*StatusREST) Destroy ¶

func (r *StatusREST) Destroy()

Destroy cleans up resources on shutdown.

func (*StatusREST) Get ¶

func (r *StatusREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)

Get retrieves the object from the storage. It is required to support Patch.

func (*StatusREST) NamespaceScoped ¶

func (r *StatusREST) NamespaceScoped() bool

NamespaceScoped is true for Task

func (*StatusREST) New ¶

func (r *StatusREST) New() runtime.Object

New creates a new Node object.

func (*StatusREST) Update ¶

func (r *StatusREST) Update(ctx context.Context, name string, objInfo apirest.UpdatedObjectInfo, createValidation apirest.ValidateObjectFunc, updateValidation apirest.ValidateObjectUpdateFunc, _ bool, options *metav1.UpdateOptions) (runtime.Object, bool, error)

Update alters the status subset of an object.

type TaskStorage ¶

type TaskStorage struct {
	Task       *REST
	TaskStatus *StatusREST
}

TaskStorage storage for Task

func NewStorage ¶

func NewStorage(optsGetter apigeneric.RESTOptionsGetter) (TaskStorage, error)

NewStorage for Task storage

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL