dispatcher

Documentation

Index

• Constants
• func DriftEvaluation(unitType string, metricType datahub_common.MetricType, granularity int64, ...) ([]datahub_common.MetricType, bool)
• func ModelCompleteNotification(modelMapper *ModelMapper, datahubGrpcCn *grpc.ClientConn, ...)
• func NewApplicationModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper, ...) *applicationModelJobSender
• func NewClusterModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper, ...) *clusterModelJobSender
• func NewControllerModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper, ...) *controllerModelJobSender
• func NewGPUModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper, ...) *gpuModelJobSender
• func NewModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper, ...) *modelJobSender
• func NewNamespaceModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper, ...) *namespaceModelJobSender
• func NewNodeModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper, ...) *nodeModelJobSender
• func NewPodModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper, ...) *podModelJobSender
• func NewPredictJobSender(datahubGrpcCn *grpc.ClientConn) *predictJobSender
• type Dispatcher
  • func NewDispatcher(datahubGrpcCn *grpc.ClientConn, granularities []string, predictUnits []string, ...) *Dispatcher
  • func (dispatcher *Dispatcher) Start()
• type ModelMapper
  • func NewModelMapper(predictUnitTypes []string, granularities []string) *ModelMapper
  • func (mm *ModelMapper) AddModelInfo(predictUnitType string, granularity string, mInfo *modelInfo)
  • func (mm *ModelMapper) GetModelInfo(predictUnitType string, granularity string, modelID string) *modelInfo
  • func (mm *ModelMapper) IsModelTimeout(predictUnitType string, granularity string, mInfo *modelInfo) bool
  • func (mm *ModelMapper) IsModeling(predictUnitType string, granularity string, mInfo *modelInfo) bool
  • func (mm *ModelMapper) RemoveModelInfo(predictUnitType string, granularity string, modelID string)

Constants

const (
	UnitTypeNode        = "NODE"
	UnitTypePod         = "POD"
	UnitTypeGPU         = "GPU"
	UnitTypeNamespace   = "NAMESPACE"
	UnitTypeApplication = "APPLICATION"
	UnitTypeCluster     = "CLUSTER"
	UnitTypeController  = "CONTROLLER"
)

Functions

func DriftEvaluation

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

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

func NewApplicationModelJobSender

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

func NewClusterModelJobSender

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

func NewControllerModelJobSender

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

func NewGPUModelJobSender

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

func NewModelJobSender

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

func NewNamespaceModelJobSender

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

func NewNodeModelJobSender

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

func NewPodModelJobSender

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

func NewPredictJobSender

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

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

func NewModelMapper

func NewModelMapper(predictUnitTypes []string, granularities []string) *ModelMapper

func (*ModelMapper) AddModelInfo

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

func (*ModelMapper) GetModelInfo

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

func (*ModelMapper) IsModelTimeout

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

func (*ModelMapper) IsModeling

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

func (*ModelMapper) RemoveModelInfo

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