controller

package
v2.0.0-alpha2+incompat... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 5, 2017 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ArtifactRepository

type ArtifactRepository struct {
	S3 *S3ArtifactRepository `json:"s3,omitempty"`
}

ArtifactRepository represents a artifact repository in which a controller will store its artifacts

type S3ArtifactRepository

type S3ArtifactRepository struct {
	wfv1.S3Bucket `json:",inline,squash"`

	// KeyPrefix is prefix used as part of the bucket key in which the controller will store artifacts.
	KeyPrefix string `json:"keyPrefix,omitempty"`
}

type WorkflowController

type WorkflowController struct {
	// ConfigMap is the name of the config map in which to derive configuration of the controller from
	ConfigMap string
	// namespace for config map
	ConfigMapNS string
	//WorkflowClient *workflowclient.WorkflowClient
	Config WorkflowControllerConfig
	// contains filtered or unexported fields
}

func NewWorkflowController

func NewWorkflowController(config *rest.Config, configMap string) *WorkflowController

NewWorkflowController instantiates a new WorkflowController

func (*WorkflowController) ResyncConfig

func (wfc *WorkflowController) ResyncConfig() error

ResyncConfig reloads the controller config from the configmap

func (*WorkflowController) Run

func (wfc *WorkflowController) Run(ctx context.Context) error

Run starts an Workflow resource controller

func (*WorkflowController) StartStatsTicker

func (wfc *WorkflowController) StartStatsTicker(d time.Duration)

StartStatsTicker starts a goroutine which dumps stats at a specified interval

type WorkflowControllerConfig

type WorkflowControllerConfig struct {
	ExecutorImage      string             `json:"executorImage,omitempty"`
	ArtifactRepository ArtifactRepository `json:"artifactRepository,omitempty"`
	Namespace          string             `json:"namespace,omitempty"`
	MatchLabels        map[string]string  `json:"matchLabels,omitempty"`
}

Jump to

Keyboard shortcuts

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