Documentation
¶
Index ¶
Constants ¶
View Source
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 ¶
View Source
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
Source Files
Click to show internal directories.
Click to hide internal directories.