Documentation
¶
Index ¶
Constants ¶
View Source
const ( // Name is this controller name Name = "FeatureExtraction" // KindName is the kind name of CR this controller controls KindName = "FeatureExtractionService" // VideoAnalyticsWorker is this name given to the worker pod FEWorker = "fe" // VideoAnalyticsPort is the port where the service will be exposed FEPort = 6000 )
Variables ¶
View Source
var FeatureExtractionServiceKind = sednav1.SchemeGroupVersion.WithKind(KindName)
FeatureExtractionServiceKind contains the schema.GroupVersionKind for this controller type.
Functions ¶
func New ¶
func New(cc *runtime.ControllerContext) (runtime.FeatureControllerI, error)
NewJointController creates a new FeatureExtractionService controller that keeps the relevant pods in sync with their corresponding FeatureExtractionService objects.
func NewFeatureExtractionServiceCondition ¶
func NewFeatureExtractionServiceCondition(conditionType sednav1.FeatureExtractionServiceConditionType, reason, message string) sednav1.FeatureExtractionServiceCondition
NewFeatureExtractionServiceCondition creates a new joint condition
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller ensures that all FeatureExtractionService objects have corresponding pods to run their configured workload.
func (*Controller) GetName ¶
func (c *Controller) GetName() string
func (*Controller) Run ¶
func (c *Controller) Run(stopCh <-chan struct{})
Run starts the main goroutine responsible for watching and syncing services.
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.