prediction

Documentation

Index

• Constants
• type ContainerRepository
  • func NewContainerRepositoryWithConfig(influxDBCfg influxdb.Config) *ContainerRepository
  • func (r *ContainerRepository) CreateContainerPrediction(in *datahub_v1alpha1.CreatePodPredictionsRequest) error
  • func (r *ContainerRepository) ListContainerPredictionsByRequest(request prediction_dao.ListPodPredictionsRequest) ([]*datahub_v1alpha1.PodPrediction, error)
• type NodeRepository
  • func NewNodeRepositoryWithConfig(influxDBCfg influxdb.Config) *NodeRepository
  • func (r *NodeRepository) CreateNodePrediction(in *datahub_v1alpha1.CreateNodePredictionsRequest) error
  • func (r *NodeRepository) ListNodePredictionsByRequest(request prediction_dao.ListNodePredictionsRequest) ([]*datahub_v1alpha1.NodePrediction, error)

Constants

const (
	// Node is node measurement
	Node influxdb.Measurement = "node"
	// Container is container measurement
	Container influxdb.Measurement = "container"
)

Types

type ContainerRepository

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

ContainerRepository Repository to access containers' prediction data

func NewContainerRepositoryWithConfig

func NewContainerRepositoryWithConfig(influxDBCfg influxdb.Config) *ContainerRepository

NewContainerRepositoryWithConfig New container repository with influxDB configuration

func (*ContainerRepository) CreateContainerPrediction

func (r *ContainerRepository) CreateContainerPrediction(in *datahub_v1alpha1.CreatePodPredictionsRequest) error

func (*ContainerRepository) ListContainerPredictionsByRequest

func (r *ContainerRepository) ListContainerPredictionsByRequest(request prediction_dao.ListPodPredictionsRequest) ([]*datahub_v1alpha1.PodPrediction, error)

ListContainerPredictionsByRequest list containers' prediction from influxDB

type NodeRepository

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

func NewNodeRepositoryWithConfig

func NewNodeRepositoryWithConfig(influxDBCfg influxdb.Config) *NodeRepository

func (*NodeRepository) CreateNodePrediction

func (r *NodeRepository) CreateNodePrediction(in *datahub_v1alpha1.CreateNodePredictionsRequest) error

func (*NodeRepository) ListNodePredictionsByRequest

func (r *NodeRepository) ListNodePredictionsByRequest(request prediction_dao.ListNodePredictionsRequest) ([]*datahub_v1alpha1.NodePrediction, error)