jointinference

Documentation

Index

• Constants
• Variables
• func New(cc *runtime.ControllerContext) (runtime.FeatureControllerI, error)
• 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 (
	// Name is this controller name
	Name = "JointInference"

	// KindName is the kind name of CR this controller controls
	KindName = "JointInferenceService"
)

const (
	BigModelPort = 5000
)

Variables

var Kind = sednav1.SchemeGroupVersion.WithKind(Name)

Kind contains the schema.GroupVersionKind for this controller type.

Functions

func New

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

New creates a new JointInferenceService controller that keeps the relevant pods in sync with their corresponding JointInferenceService objects.

Types

type Controller

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

Controller ensures that all JointInferenceService 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 services.

func (*Controller) SetDownstreamSendFunc

func (c *Controller) SetDownstreamSendFunc(f runtime.DownstreamSendFunc) error

func (*Controller) SetUpstreamHandler

func (c *Controller) SetUpstreamHandler(addFunc runtime.UpstreamHandlerAddFunc) error