incrementallearning

Documentation

Index

• Constants
• Variables
• func IsJobFinished(j *sednav1.IncrementalLearningJob) bool
• func New(cc *runtime.ControllerContext) (runtime.FeatureControllerI, error)
• func NewIncrementalJobCondition(conditionType sednav1.ILJobStageConditionType, jobStage sednav1.ILJobStage) sednav1.ILJobCondition
• 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
• type IncrementalCondData
  • func (cd *IncrementalCondData) GetInputModelURLs() []string
  • func (cd *IncrementalCondData) GetOutputModelURLs() []string
  • func (cd IncrementalCondData) Marshal() ([]byte, error)
  • func (cd *IncrementalCondData) Unmarshal(data []byte) error
• type Model

Constants

const (
	// Name is this controller name
	Name = "IncrementalLearning"

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

Variables

var Kind = sednav1.SchemeGroupVersion.WithKind(KindName)

Kind contains the schema.GroupVersionKind for this controller type.

Functions

func IsJobFinished

func IsJobFinished(j *sednav1.IncrementalLearningJob) bool

func New

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

New creates a new incremental learning job controller that keeps the relevant pods in sync with the corresponding IncrementalLearningJob objects.

func NewIncrementalJobCondition

func NewIncrementalJobCondition(conditionType sednav1.ILJobStageConditionType, jobStage sednav1.ILJobStage) sednav1.ILJobCondition

Types

type Controller

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

Controller ensures that all IncrementalLearningJob 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

type IncrementalCondData

type IncrementalCondData struct {
	Input *struct {
		// Only one model cases
		Model  *Model  `json:"model,omitempty"`
		Models []Model `json:"models,omitempty"`

		DataURL string `json:"dataURL,omitempty"`

		// the data samples reference will be stored into this URL.
		// The content of this url would be:
		// # the first uncomment line means the directory
		// s3://dataset/
		// mnist/0.jpg
		// mnist/1.jpg
		DataIndexURL string `json:"dataIndexURL,omitempty"`

		OutputDir string `json:"outputDir,omitempty"`
	} `json:"input,omitempty"`

	Output *struct {
		Model  *Model  `json:"model,omitempty"`
		Models []Model `json:"models,omitempty"`
	} `json:"output,omitempty"`
}

IncrementalCondData the data of this condition including the input/output to do the next step

func (*IncrementalCondData) GetInputModelURLs

func (cd *IncrementalCondData) GetInputModelURLs() []string

func (*IncrementalCondData) GetOutputModelURLs

func (cd *IncrementalCondData) GetOutputModelURLs() []string

func (IncrementalCondData) Marshal

func (cd IncrementalCondData) Marshal() ([]byte, error)

func (*IncrementalCondData) Unmarshal

func (cd *IncrementalCondData) Unmarshal(data []byte) error

type Model

type Model = runtime.Model