dispatcher

package
v4.5.2003+incompatible Latest Latest
Warning

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

 Go to latest Published: Jun 29, 2020 License: Apache-2.0 Imports: 32 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,
	datahubGrpcCn *grpc.ClientConn, metricExporter *metrics.Exporter)

func NewApplicationModelJobSender added in v0.9.166 

func NewApplicationModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *applicationModelJobSender

func NewClusterModelJobSender added in v0.9.166 

func NewClusterModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *clusterModelJobSender

func NewControllerModelJobSender added in v0.9.166 

func NewControllerModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *controllerModelJobSender

func NewGPUModelJobSender added in v0.9.166 

func NewGPUModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *gpuModelJobSender

func NewModelJobSender added in v0.9.1 

func NewModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *modelJobSender

func NewNamespaceModelJobSender added in v0.9.166 

func NewNamespaceModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *namespaceModelJobSender

func NewNodeModelJobSender added in v0.9.166 

func NewNodeModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *nodeModelJobSender

func NewPodModelJobSender added in v0.9.166 

func NewPodModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper,
	metricExporter *metrics.Exporter) *podModelJobSender

func NewPredictJobSender added in v0.9.1 

func NewPredictJobSender(datahubGrpcCn *grpc.ClientConn) *predictJobSender

Types

type Dispatcher 

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

func NewDispatcher 

func NewDispatcher(datahubGrpcCn *grpc.ClientConn, 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.