featureextraction

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 13, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL