reid

Documentation

Index

• Constants
• Variables
• func IsJobFinished(j *sednav1.ReidJob) bool
• func New(cc *runtime.ControllerContext) (runtime.FeatureControllerI, error)
• func NewJobCondition(conditionType sednav1.ReidJobConditionType, reason, message string) sednav1.ReidJobCondition
• type Controller
  • func (c *Controller) Run(stopCh <-chan struct{})
  • func (c *Controller) SetDownstreamSendFunc(f runtime.DownstreamSendFunc) error
  • func (c *Controller) SetUpstreamHandler(addFunc runtime.UpstreamHandlerAddFunc) error

Constants

const (
	// KindName is the kind name of CR this controller controls
	KindName = "ReidJob"
	// Name is this controller name
	Name = "Reid"
	// ReidWorker is this name given to the worker pod
	ReidWorker = "reid"
	// ReidPort is the port where the service will be exposed
	ReidPort = 5000
)

Variables

var Kind = sednav1.SchemeGroupVersion.WithKind(KindName)

Kind contains the schema.GroupVersionKind for this controller type.

Functions

func IsJobFinished

func IsJobFinished(j *sednav1.ReidJob) bool

func New

func New(cc *runtime.ControllerContext) (runtime.FeatureControllerI, error)

New creates a new reid job controller that keeps the relevant pods in sync with their corresponding ReidJob objects.

func NewJobCondition

func NewJobCondition(conditionType sednav1.ReidJobConditionType, reason, message string) sednav1.ReidJobCondition

Types

type Controller

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

Controller ensures that all ReidJob objects have corresponding pods to run their configured workload.

func (*Controller) Run

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

Run starts the main goroutine responsible for watching and syncing jobs.

func (*Controller) SetDownstreamSendFunc

func (c *Controller) SetDownstreamSendFunc(f runtime.DownstreamSendFunc) error

func (*Controller) SetUpstreamHandler

func (c *Controller) SetUpstreamHandler(addFunc runtime.UpstreamHandlerAddFunc) error