task

Documentation

Overview

task package contains Tasks implementation that encapsulate actions against an api-server

Index

• type ApplyTask
  • func (t *ApplyTask) Run(state runner.State)
• type InfoFetcher
  • func DefaultInfoFetcherBuilder(factory util.ClientFactory) (InfoFetcher, error)
• type InventoryTask
  • func (t *InventoryTask) Run(state runner.State)
• type PruneTask
  • func (t *PruneTask) Run(state runner.State)
• type WaitTask
  • func (t *WaitTask) Run(state runner.State)

Types

type ApplyTask

type ApplyTask struct {
	DryRun       bool
	FieldManager string

	RemoteGetter cache.RemoteResourceGetter
	Objects      []*unstructured.Unstructured
	Filters      []filter.Interface
	InfoFetcher  InfoFetcher
}

ApplyTask will apply the Objects to a remote api-server with the server-side config of kubectl

func (*ApplyTask) Run

func (t *ApplyTask) Run(state runner.State)

Run implement the runner.Task interface

type InfoFetcher

type InfoFetcher func(*unstructured.Unstructured) (resource.Info, error)

InfoFetcher function for transforming a jpl Resources in a kubernetes resource Info object

func DefaultInfoFetcherBuilder

func DefaultInfoFetcherBuilder(factory util.ClientFactory) (InfoFetcher, error)

type InventoryTask

type InventoryTask struct {
	Manager *inventory.Manager
	DryRun  bool
}

InventoryTask is used for updating an inventory with the current state saved in the Manager

func (*InventoryTask) Run

func (t *InventoryTask) Run(state runner.State)

Run implement the runner.Task interface

type PruneTask

type PruneTask struct {
	DryRun       bool
	FieldManager string
	Client       dynamic.Interface
	Mapper       meta.RESTMapper

	Objects []*unstructured.Unstructured
}

PruneTask is the task used for removing Objects from the remote server

func (*PruneTask) Run

func (t *PruneTask) Run(state runner.State)

Run implement the runner.Task interface

type WaitTask

type WaitTask struct {
	Objects []*unstructured.Unstructured
	Poller  poller.StatusPoller
	Mapper  meta.RESTMapper
	Manager *inventory.Manager
	// contains filtered or unexported fields
}

WaitTask is the task used for removing Objects from the remote server

func (*WaitTask) Run

func (t *WaitTask) Run(state runner.State)

Run implement the runner.Task interface