prediction

Documentation

Index

• Constants
• type ContainerRepository
  • func NewContainerRepositoryWithConfig(influxDBCfg influxdb.Config) *ContainerRepository
  • func (r *ContainerRepository) CreateContainerPrediction(containersPrediction []*prediction_dao.ContainerPrediction) error
  • func (r *ContainerRepository) ListContainerPredictionsByRequest(request prediction_dao.ListPodPredictionsRequest) ([]*container_entity.Entity, error)
• type NodeRepository
  • func NewNodeRepositoryWithConfig(influxDBCfg influxdb.Config) *NodeRepository
  • func (r *NodeRepository) CreateNodePrediction(nodePredictions []*prediction_dao.NodePrediction) error
  • func (r *NodeRepository) ListNodePredictionsByRequest(request prediction_dao.ListNodePredictionsRequest) ([]*node_entity.Entity, 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(containersPrediction []*prediction_dao.ContainerPrediction) error

CreateContainerPrediction Create containers' prediction into influxDB

func (*ContainerRepository) ListContainerPredictionsByRequest

func (r *ContainerRepository) ListContainerPredictionsByRequest(request prediction_dao.ListPodPredictionsRequest) ([]*container_entity.Entity, error)

ListContainerPredictionsByRequest list containers' prediction from influxDB

type NodeRepository

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

NodeRepository Repository to access containers' prediction data

func NewNodeRepositoryWithConfig

func NewNodeRepositoryWithConfig(influxDBCfg influxdb.Config) *NodeRepository

NewNodeRepositoryWithConfig New container repository with influxDB configuration

func (*NodeRepository) CreateNodePrediction

func (r *NodeRepository) CreateNodePrediction(nodePredictions []*prediction_dao.NodePrediction) error

CreateNodePrediction Create containers' prediction into influxDB

func (*NodeRepository) ListNodePredictionsByRequest

func (r *NodeRepository) ListNodePredictionsByRequest(request prediction_dao.ListNodePredictionsRequest) ([]*node_entity.Entity, error)

ListNodePredictionsByRequest list containers' prediction from influxDB