predictions

Documentation

Index

• Constants
• type ContainerRepository
  • func NewContainerRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ContainerRepository
  • func (r *ContainerRepository) CreateContainerPrediction(in *ApiPredictions.CreatePodPredictionsRequest) error
  • func (r *ContainerRepository) CreatePredictions(predictions []*DaoPredictionTypes.ContainerPredictionSample) error
  • func (r *ContainerRepository) ListContainerPredictionsByRequest(request DaoPredictionTypes.ListPodPredictionsRequest) ([]*ApiPredictions.PodPrediction, error)
  • func (r *ContainerRepository) ListPredictions(request DaoPredictionTypes.ListPodPredictionsRequest) ([]*DaoPredictionTypes.ContainerPrediction, error)
• type NodeRepository
  • func NewNodeRepositoryWithConfig(influxDBCfg InternalInflux.Config) *NodeRepository
  • func (r *NodeRepository) CreateNodePrediction(in *ApiPredictions.CreateNodePredictionsRequest) error
  • func (r *NodeRepository) CreatePredictions(predictions DaoPredictionTypes.NodePredictionMap) error
  • func (r *NodeRepository) ListNodePredictionsByRequest(request DaoPredictionTypes.ListNodePredictionsRequest) ([]*ApiPredictions.NodePrediction, error)
  • func (r *NodeRepository) ListPredictions(request DaoPredictionTypes.ListNodePredictionsRequest) ([]*DaoPredictionTypes.NodePrediction, error)

Constants

const (
	Node      influxdb.Measurement = "node"
	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 InternalInflux.Config) *ContainerRepository

NewContainerRepositoryWithConfig New container repository with influxDB configuration

func (*ContainerRepository) CreateContainerPrediction

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

func (*ContainerRepository) CreatePredictions

func (r *ContainerRepository) CreatePredictions(predictions []*DaoPredictionTypes.ContainerPredictionSample) error

func (*ContainerRepository) ListContainerPredictionsByRequest

func (r *ContainerRepository) ListContainerPredictionsByRequest(request DaoPredictionTypes.ListPodPredictionsRequest) ([]*ApiPredictions.PodPrediction, error)

ListContainerPredictionsByRequest list containers' prediction from influxDB

func (*ContainerRepository) ListPredictions

func (r *ContainerRepository) ListPredictions(request DaoPredictionTypes.ListPodPredictionsRequest) ([]*DaoPredictionTypes.ContainerPrediction, error)

ListContainerPredictionsByRequest list containers' prediction from influxDB

type NodeRepository

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

func NewNodeRepositoryWithConfig

func NewNodeRepositoryWithConfig(influxDBCfg InternalInflux.Config) *NodeRepository

func (*NodeRepository) CreateNodePrediction

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

func (*NodeRepository) CreatePredictions

func (r *NodeRepository) CreatePredictions(predictions DaoPredictionTypes.NodePredictionMap) error

func (*NodeRepository) ListNodePredictionsByRequest

func (r *NodeRepository) ListNodePredictionsByRequest(request DaoPredictionTypes.ListNodePredictionsRequest) ([]*ApiPredictions.NodePrediction, error)

func (*NodeRepository) ListPredictions

func (r *NodeRepository) ListPredictions(request DaoPredictionTypes.ListNodePredictionsRequest) ([]*DaoPredictionTypes.NodePrediction, error)