videoanalytics

Documentation

Index

• Constants
• Variables
• func IsJobFinished(j *sednav1.VideoAnalyticsJob) bool
• func New(cc *runtime.ControllerContext) (runtime.FeatureControllerI, error)
• func NewJobCondition(conditionType sednav1.VideoAnalyticsJobConditionType, reason, message string) sednav1.VideoAnalyticsJobCondition
• 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 = "VideoAnalyticsJob"
	// Name is this controller name
	Name = "VideoAnalytics"
	// VideoAnalyticsWorker is this name given to the worker pod
	VideoAnalyticsWorker = "videoanalytics"
	// VideoAnalyticsPort is the port where the service will be exposed
	VideoAnalyticsPort = 4000
)

Variables

var Kind = sednav1.SchemeGroupVersion.WithKind(KindName)

Kind contains the schema.GroupVersionKind for this controller type.

Functions

func IsJobFinished

func IsJobFinished(j *sednav1.VideoAnalyticsJob) bool

func New

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

New creates a new video analytics job controller that keeps the relevant pods in sync with their corresponding VideoAnalyticsJob objects.

func NewJobCondition

func NewJobCondition(conditionType sednav1.VideoAnalyticsJobConditionType, reason, message string) sednav1.VideoAnalyticsJobCondition

Types

type Controller

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

Controller ensures that all VideoAnalyticsJob 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