featureextraction

Documentation

Index

• Constants
• Variables
• func New(cc *runtime.ControllerContext) (runtime.FeatureControllerI, error)
• func NewFeatureExtractionServiceCondition(conditionType sednav1.FeatureExtractionServiceConditionType, ...) sednav1.FeatureExtractionServiceCondition
• type Controller
  • func (c *Controller) GetName() string
  • 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 (
	// 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

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