dispatcher

package
v4.2.504+incompatible Latest Latest
Warning

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

Go to latest
Published: Oct 30, 2019 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
const (
	UnitTypeNode = "NODE"
	UnitTypePod  = "POD"
	UnitTypeGPU  = "GPU"
)

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 ModelCompleteNotification added in v0.9.166

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

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 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) *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(predictUnitTypes []string, granularities []string) *ModelMapper

func (*ModelMapper) AddModelInfo added in v0.9.1

func (mm *ModelMapper) AddModelInfo(predictUnitType string,
	granularity string, mInfo *modelInfo)

func (*ModelMapper) GetModelInfo added in v0.9.166

func (mm *ModelMapper) GetModelInfo(predictUnitType string,
	granularity string, modelID string) *modelInfo

func (*ModelMapper) IsModelTimeout added in v0.9.1

func (mm *ModelMapper) IsModelTimeout(predictUnitType string,
	granularity string, mInfo *modelInfo) bool

func (*ModelMapper) IsModeling added in v0.9.1

func (mm *ModelMapper) IsModeling(predictUnitType string,
	granularity string, mInfo *modelInfo) bool

func (*ModelMapper) RemoveModelInfo added in v0.9.1

func (mm *ModelMapper) RemoveModelInfo(predictUnitType string,
	granularity string, modelID string)

Jump to

Keyboard shortcuts

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