Documentation ¶
Index ¶
Constants ¶
View Source
const ( Container influxdb.Measurement = "container" Controller influxdb.Measurement = "controller" Application influxdb.Measurement = "application" Namespace influxdb.Measurement = "namespace" Node influxdb.Measurement = "node" Cluster influxdb.Measurement = "cluster" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApplicationRepository ¶
type ApplicationRepository struct {
// contains filtered or unexported fields
}
func NewApplicationRepositoryWithConfig ¶
func NewApplicationRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ApplicationRepository
func (*ApplicationRepository) CreatePredictions ¶
func (r *ApplicationRepository) CreatePredictions(predictions DaoPredictionTypes.ApplicationPredictionMap) error
func (*ApplicationRepository) ListPredictions ¶
func (r *ApplicationRepository) ListPredictions(request DaoPredictionTypes.ListApplicationPredictionsRequest) ([]*DaoPredictionTypes.ApplicationPrediction, error)
type ClusterRepository ¶
type ClusterRepository struct {
// contains filtered or unexported fields
}
func NewClusterRepositoryWithConfig ¶
func NewClusterRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ClusterRepository
func (*ClusterRepository) CreatePredictions ¶
func (r *ClusterRepository) CreatePredictions(predictions DaoPredictionTypes.ClusterPredictionMap) error
func (*ClusterRepository) ListPredictions ¶
func (r *ClusterRepository) ListPredictions(request DaoPredictionTypes.ListClusterPredictionsRequest) ([]*DaoPredictionTypes.ClusterPrediction, error)
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) CreatePredictions ¶
func (r *ContainerRepository) CreatePredictions(predictions []*DaoPredictionTypes.ContainerPredictionSample) error
func (*ContainerRepository) ListPredictions ¶
func (r *ContainerRepository) ListPredictions(request DaoPredictionTypes.ListPodPredictionsRequest) ([]*DaoPredictionTypes.ContainerPrediction, error)
ListContainerPredictionsByRequest list containers' prediction from influxDB
type ControllerRepository ¶
type ControllerRepository struct {
// contains filtered or unexported fields
}
func NewControllerRepositoryWithConfig ¶
func NewControllerRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ControllerRepository
func (*ControllerRepository) CreatePredictions ¶
func (r *ControllerRepository) CreatePredictions(predictions DaoPredictionTypes.ControllerPredictionMap) error
func (*ControllerRepository) ListPredictions ¶
func (r *ControllerRepository) ListPredictions(request DaoPredictionTypes.ListControllerPredictionsRequest) ([]*DaoPredictionTypes.ControllerPrediction, error)
type NamespaceRepository ¶
type NamespaceRepository struct {
// contains filtered or unexported fields
}
func NewNamespaceRepositoryWithConfig ¶
func NewNamespaceRepositoryWithConfig(influxDBCfg InternalInflux.Config) *NamespaceRepository
func (*NamespaceRepository) CreatePredictions ¶
func (r *NamespaceRepository) CreatePredictions(predictions DaoPredictionTypes.NamespacePredictionMap) error
func (*NamespaceRepository) ListPredictions ¶
func (r *NamespaceRepository) ListPredictions(request DaoPredictionTypes.ListNamespacePredictionsRequest) ([]*DaoPredictionTypes.NamespacePrediction, error)
type NodeRepository ¶
type NodeRepository struct {
// contains filtered or unexported fields
}
func NewNodeRepositoryWithConfig ¶
func NewNodeRepositoryWithConfig(influxDBCfg InternalInflux.Config) *NodeRepository
func (*NodeRepository) CreatePredictions ¶
func (r *NodeRepository) CreatePredictions(predictions DaoPredictionTypes.NodePredictionMap) error
func (*NodeRepository) ListPredictions ¶
func (r *NodeRepository) ListPredictions(request DaoPredictionTypes.ListNodePredictionsRequest) ([]*DaoPredictionTypes.NodePrediction, error)
Click to show internal directories.
Click to hide internal directories.