flow

Documentation

Index

• Constants
• func DeepHashObject(objectToWrite interface{}) string
• type Controller
  • func NewController(options *ControllerOptions) *Controller
  • func (c *Controller) GenerateJobs(flow *v1alpha1.Flow, hash string) error
  • func (c *Controller) Run(workers int, stopCh <-chan struct{})
• type ControllerOptions
• type JobCache
• type WorkerFactory

Constants

const (
	// CodeSourceYAML defines code source config name
	CodeSourceYAML = "codesource.yaml"
	// ImageListYAML defines config name of image list
	ImageListYAML = "imagelist.yaml"
)

Functions

func DeepHashObject

func DeepHashObject(objectToWrite interface{}) string

DeepHashObject hashes an object

Types

type Controller

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

Controller defines flow controller to control CI/CD flow

func NewController

func NewController(options *ControllerOptions) *Controller

NewController return a flow controller

func (*Controller) GenerateJobs

func (c *Controller) GenerateJobs(flow *v1alpha1.Flow, hash string) error

func (*Controller) Run

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

Run will start the flow controller

type ControllerOptions

type ControllerOptions struct {
	// KubeClient defines interface of raw kubernetes API
	KubeClient kubernetes.Interface

	// ExtClient defines interface of extension API of this project
	ExtClient clientset.Interface

	// FlowInformer defines informer of flow
	FlowInformer flowinformers.FlowInformer

	// JobInformer defines informer of job
	JobInformer batchinformers.JobInformer

	// SCMImage defines image for scm
	SCMImage string
}

ControllerOptions defines options to flow controller

type JobCache

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

JobCache defines cache of jobs

type WorkerFactory

type WorkerFactory func(queue workqueue.RateLimitingInterface, handler func(key string) error) func() bool

WorkerFactory defines factory function to create worker queue + sync handler => worker