dispatcher

Documentation

Index

• Constants
• func NewModelJobSender(datahubGrpcCn *grpc.ClientConn, modelMapper *ModelMapper) *modelJobSender
• 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) 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"
)

Functions

func NewModelJobSender

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

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) *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) 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)