dispatcher

package
v4.3.942+incompatible Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2020 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DriftEvaluation added in v0.9.166 

func DriftEvaluation(unitType string, metricType datahub_common.MetricType, granularity int64,
	mData []*datahub_common.Sample, pData []*datahub_predictions.Sample,
	unitMeta map[string]string, metricExporter *metrics.Exporter) ([]datahub_common.MetricType, bool)

func GetUnitResourceK8SNSName 

func GetUnitResourceK8SNSName(unit *config.Unit, rowValues []string, columns []string) (*string, *string, error)

func GetUnitScalerNSName 

func GetUnitScalerNSName(unit *config.Unit, rowValues []string, columns []string) (string, string, error)

func ModelCompleteNotification added in v0.9.166 

func ModelCompleteNotification(modelMapper *ModelMapper, metricExporter *metrics.Exporter)

func NewApplicationModelJobSender added in v0.9.166 

func NewApplicationModelJobSender(datahubClient *datahubpkg.Client, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *applicationModelJobSender

func NewClusterModelJobSender added in v0.9.166 

func NewClusterModelJobSender(datahubClient *datahubpkg.Client, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *clusterModelJobSender

func NewControllerModelJobSender added in v0.9.166 

func NewControllerModelJobSender(datahubClient *datahubpkg.Client, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *controllerModelJobSender

func NewGPUModelJobSender added in v0.9.166 

func NewGPUModelJobSender(datahubClient *datahubpkg.Client, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *gpuModelJobSender

func NewModelJobSender added in v0.9.1 

func NewModelJobSender(datahubClient *datahubpkg.Client, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *modelJobSender

func NewNamespaceModelJobSender added in v0.9.166 

func NewNamespaceModelJobSender(datahubClient *datahubpkg.Client, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *namespaceModelJobSender

func NewNodeModelJobSender added in v0.9.166 

func NewNodeModelJobSender(datahubClient *datahubpkg.Client, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *nodeModelJobSender

func NewPodModelJobSender added in v0.9.166 

func NewPodModelJobSender(datahubClient *datahubpkg.Client, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *podModelJobSender

func NewPredictJobSender added in v0.9.1 

func NewPredictJobSender(datahubClient *datahubpkg.Client) *predictJobSender

Types

type Dispatcher 

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

func NewDispatcher 

func NewDispatcher(datahubClient *datahubpkg.Client, granularities []string,
	predictUnits []string, modelMapper *ModelMapper, metricExporter *metrics.Exporter,
	cfg *config.Config) *Dispatcher

func (*Dispatcher) Start 

func (dispatcher *Dispatcher) Start()

type ModelMapper added in v0.9.1 

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

func NewModelMapper added in v0.9.1 

func NewModelMapper() *ModelMapper

func (*ModelMapper) AddModelInfo added in v0.9.1 

func (mm *ModelMapper) AddModelInfo(clusterID string, predictUnitType string,
	granularity string, metricType string, extraInfo map[string]string)

func (*ModelMapper) AddModelInfoV2 

func (mm *ModelMapper) AddModelInfoV2(jobID string)

func (*ModelMapper) GetModelInfo added in v0.9.166 

func (mm *ModelMapper) GetModelInfo(clusterID string, predictUnitType string,
	granularity string, metricType string, extraInfo map[string]string) *modelInfo

func (*ModelMapper) GetModelInfoV2 

func (mm *ModelMapper) GetModelInfoV2(jobID string) *modelInfo

func (*ModelMapper) IsModelTimeout added in v0.9.1 

func (mm *ModelMapper) IsModelTimeout(clusterID string, predictUnitType string,
	granularity string, metricType string, extraInfo map[string]string) bool

func (*ModelMapper) IsModelTimeoutV2 

func (mm *ModelMapper) IsModelTimeoutV2(jobID string) bool

func (*ModelMapper) IsModeling added in v0.9.1 

func (mm *ModelMapper) IsModeling(clusterID string, predictUnitType string,
	granularity string, metricType string, extraInfo map[string]string) bool

func (*ModelMapper) IsModelingV2 

func (mm *ModelMapper) IsModelingV2(jobID string) bool

func (*ModelMapper) RemoveModelInfo added in v0.9.1 

func (mm *ModelMapper) RemoveModelInfo(clusterID string, predictUnitType string,
	granularity string, metricType string, extraInfo map[string]string)

func (*ModelMapper) RemoveModelInfoV2 

func (mm *ModelMapper) RemoveModelInfoV2(jobID string)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.