task

Documentation

Index

• Variables
• func GetAttrs(obj runtime.Object) (labels.Set, fields.Set, error)
• func Indexers() *cgtoolscache.Indexers
• func MatchTask(label labels.Selector, field fields.Selector) apistorage.SelectionPredicate
• func OwnerPipelineIndexFunc(obj interface{}) ([]string, error)
• func OwnerPipelineTriggerFunc(obj runtime.Object) string
• func ToSelectableFields(task *kubekeyv1alpha1.Task) fields.Set
• type REST
• type StatusREST
  • func (r *StatusREST) ConvertToTable(ctx context.Context, object runtime.Object, tableOptions runtime.Object) (*metav1.Table, error)
  • func (r *StatusREST) Destroy()
  • func (r *StatusREST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error)
  • func (r *StatusREST) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set
  • func (r *StatusREST) NamespaceScoped() bool
  • func (r *StatusREST) New() runtime.Object
  • func (r *StatusREST) Update(ctx context.Context, name string, objInfo apirest.UpdatedObjectInfo, ...) (runtime.Object, bool, error)
• type TaskStorage
  • func NewStorage(optsGetter apigeneric.RESTOptionsGetter) (TaskStorage, error)

Variables

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 Indexers

func Indexers() *cgtoolscache.Indexers

Indexers returns the indexers for pod storage.

func MatchTask

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

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

func OwnerPipelineIndexFunc

func OwnerPipelineIndexFunc(obj interface{}) ([]string, error)

OwnerPipelineIndexFunc return value ownerReference.object is pipeline.

func OwnerPipelineTriggerFunc

func OwnerPipelineTriggerFunc(obj runtime.Object) string

OwnerPipelineTriggerFunc returns value ownerReference is pipeline of given object.

func ToSelectableFields

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

ToSelectableFields returns a field set that represents the object TODO: fields are not labels, and the validation rules for them do not apply.

Types

type REST

type REST struct {
	*apiregistry.Store
}

type StatusREST

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

func (*StatusREST) ConvertToTable

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

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) GetResetFields

func (r *StatusREST) GetResetFields() map[fieldpath.APIVersion]*fieldpath.Set

GetResetFields implements rest.ResetFieldsStrategy

func (*StatusREST) NamespaceScoped

func (r *StatusREST) NamespaceScoped() bool

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, forceAllowCreate 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
}

func NewStorage

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