controller

Documentation

Index

• func InitWorkplanTree(tasks []api.Task) [][]api.StepEntry
• func UpdateWorkplanTreeForPod(stepTree [][]api.StepEntry, pod *v1.Pod) [][]api.StepEntry
• type Config
  • func NewConfig(clientConfig *rest.Config) *Config
  • func (c *Config) New() (*Controller, error)
• type Controller
  • func (c *Controller) NewWorkflowMutatingWebhook() hooks.AdmissionHook
  • func (c *Controller) NewWorkflowValidatingWebhook() hooks.AdmissionHook
  • func (c *Controller) NewWorkplanMutatingWebhook() hooks.AdmissionHook
  • func (c *Controller) Run(stopCh <-chan struct{})
  • func (c *Controller) RunInformers(stopCh <-chan struct{})
• type LogsREST
  • func NewLogsREST(controller *Controller) *LogsREST
  • func (r *LogsREST) Categories() []string
  • func (r *LogsREST) Get(ctx context.Context, name string, options runtime.Object) (runtime.Object, error)
  • func (r *LogsREST) GroupVersionKind(containingGV schema.GroupVersion) schema.GroupVersionKind
  • func (r *LogsREST) NamespaceScoped() bool
  • func (r *LogsREST) New() runtime.Object
  • func (r *LogsREST) NewGetOptions() (runtime.Object, bool, string)
• type ResourceIdentifier
  • func (res ResourceIdentifier) GetEnvFromPath(paths map[string]string) []corev1.EnvVar
  • func (res ResourceIdentifier) String() string
• type TriggerREST
  • func NewTriggerREST(controller *Controller) *TriggerREST
  • func (r *TriggerREST) Categories() []string
  • func (r *TriggerREST) Create(ctx context.Context, obj runtime.Object, ...) (runtime.Object, error)
  • func (r *TriggerREST) GroupVersionKind(containingGV schema.GroupVersion) schema.GroupVersionKind
  • func (r *TriggerREST) NamespaceScoped() bool
  • func (r *TriggerREST) New() runtime.Object

Functions

func InitWorkplanTree

func InitWorkplanTree(tasks []api.Task) [][]api.StepEntry

func UpdateWorkplanTreeForPod

func UpdateWorkplanTreeForPod(stepTree [][]api.StepEntry, pod *v1.Pod) [][]api.StepEntry

Types

type Config

type Config struct {
	ClientConfig *rest.Config
	KubeClient   kubernetes.Interface
	KubeciClient cs.Interface
	CRDClient    crd_cs.ApiextensionsV1beta1Interface
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(clientConfig *rest.Config) *Config

func (*Config) New

func (c *Config) New() (*Controller, error)

type Controller

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

func (*Controller) NewWorkflowMutatingWebhook

func (c *Controller) NewWorkflowMutatingWebhook() hooks.AdmissionHook

func (*Controller) NewWorkflowValidatingWebhook

func (c *Controller) NewWorkflowValidatingWebhook() hooks.AdmissionHook

func (*Controller) NewWorkplanMutatingWebhook

func (c *Controller) NewWorkplanMutatingWebhook() hooks.AdmissionHook

func (*Controller) Run

func (c *Controller) Run(stopCh <-chan struct{})

func (*Controller) RunInformers

func (c *Controller) RunInformers(stopCh <-chan struct{})

type LogsREST

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

func NewLogsREST

func NewLogsREST(controller *Controller) *LogsREST

func (*LogsREST) Categories

func (r *LogsREST) Categories() []string

func (*LogsREST) Get

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

Get retrieves a runtime.Object that will stream the contents of the pod log

func (*LogsREST) GroupVersionKind

func (r *LogsREST) GroupVersionKind(containingGV schema.GroupVersion) schema.GroupVersionKind

func (*LogsREST) NamespaceScoped

func (r *LogsREST) NamespaceScoped() bool

func (*LogsREST) New

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

func (*LogsREST) NewGetOptions

func (r *LogsREST) NewGetOptions() (runtime.Object, bool, string)

type ResourceIdentifier

type ResourceIdentifier struct {
	Object             map[string]interface{} // required for json path data
	ObjectReference    api.ObjectReference
	ResourceGeneration *types.IntHash

	// TODO: remove extra fields
	Group    string
	Resource string
	Version  string
	Labels   map[string]string
}

func (ResourceIdentifier) GetEnvFromPath

func (res ResourceIdentifier) GetEnvFromPath(paths map[string]string) []corev1.EnvVar

func (ResourceIdentifier) String

func (res ResourceIdentifier) String() string

type TriggerREST

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

func NewTriggerREST

func NewTriggerREST(controller *Controller) *TriggerREST

func (*TriggerREST) Categories

func (r *TriggerREST) Categories() []string

func (*TriggerREST) Create

func (r *TriggerREST) Create(ctx context.Context, obj runtime.Object, createValidation rest.ValidateObjectFunc, _ *metav1.CreateOptions) (runtime.Object, error)

func (*TriggerREST) GroupVersionKind

func (r *TriggerREST) GroupVersionKind(containingGV schema.GroupVersion) schema.GroupVersionKind

func (*TriggerREST) NamespaceScoped

func (r *TriggerREST) NamespaceScoped() bool

func (*TriggerREST) New

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