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 AppRepository ¶
type AppRepository struct {
// contains filtered or unexported fields
}
func NewAppRepository ¶
func NewAppRepository(influxDBCfg *InternalInflux.Config) *AppRepository
func (*AppRepository) CreatePlannings ¶
func (c *AppRepository) CreatePlannings(plannings []*ApiPlannings.ApplicationPlanning) error
func (*AppRepository) ListPlannings ¶
func (c *AppRepository) ListPlannings(in *ApiPlannings.ListApplicationPlanningsRequest) ([]*ApiPlannings.ApplicationPlanning, error)
type ClusterRepository ¶
type ClusterRepository struct {
// contains filtered or unexported fields
}
func NewClusterRepository ¶
func NewClusterRepository(influxDBCfg *InternalInflux.Config) *ClusterRepository
func (*ClusterRepository) CreatePlannings ¶
func (c *ClusterRepository) CreatePlannings(plannings []*ApiPlannings.ClusterPlanning) error
func (*ClusterRepository) ListPlannings ¶
func (c *ClusterRepository) ListPlannings(in *ApiPlannings.ListClusterPlanningsRequest) ([]*ApiPlannings.ClusterPlanning, error)
type ContainerRepository ¶
type ContainerRepository struct {
// contains filtered or unexported fields
}
ContainerRepository is used to operate container measurement of planning database
func NewContainerRepository ¶
func NewContainerRepository(influxDBCfg *InternalInflux.Config) *ContainerRepository
NewContainerRepository creates the ContainerRepository instance
func (*ContainerRepository) CreateContainerPlannings ¶
func (c *ContainerRepository) CreateContainerPlannings(in *ApiPlannings.CreatePodPlanningsRequest) error
CreateContainerPlannings add containers plannings
func (*ContainerRepository) IsTag ¶
func (c *ContainerRepository) IsTag(column string) bool
IsTag checks the column is tag or not
func (*ContainerRepository) ListContainerPlannings ¶
func (c *ContainerRepository) ListContainerPlannings(in *ApiPlannings.ListPodPlanningsRequest) ([]*ApiPlannings.PodPlanning, error)
ListContainerPlannings list container plannings
type ControllerRepository ¶
type ControllerRepository struct {
// contains filtered or unexported fields
}
func NewControllerRepository ¶
func NewControllerRepository(influxDBCfg *InternalInflux.Config) *ControllerRepository
func (*ControllerRepository) CreateControllerPlannings ¶
func (c *ControllerRepository) CreateControllerPlannings(controllerPlannings []*ApiPlannings.ControllerPlanning) error
func (*ControllerRepository) ListControllerPlannings ¶
func (c *ControllerRepository) ListControllerPlannings(in *ApiPlannings.ListControllerPlanningsRequest) ([]*ApiPlannings.ControllerPlanning, error)
type NamespaceRepository ¶
type NamespaceRepository struct {
// contains filtered or unexported fields
}
func NewNamespaceRepository ¶
func NewNamespaceRepository(influxDBCfg *InternalInflux.Config) *NamespaceRepository
func (*NamespaceRepository) CreatePlannings ¶
func (c *NamespaceRepository) CreatePlannings(plannings []*ApiPlannings.NamespacePlanning) error
func (*NamespaceRepository) ListPlannings ¶
func (c *NamespaceRepository) ListPlannings(in *ApiPlannings.ListNamespacePlanningsRequest) ([]*ApiPlannings.NamespacePlanning, error)
type NodeRepository ¶
type NodeRepository struct {
// contains filtered or unexported fields
}
func NewNodeRepository ¶
func NewNodeRepository(influxDBCfg *InternalInflux.Config) *NodeRepository
func (*NodeRepository) CreatePlannings ¶
func (c *NodeRepository) CreatePlannings(plannings []*ApiPlannings.NodePlanning) error
func (*NodeRepository) ListPlannings ¶
func (c *NodeRepository) ListPlannings(in *ApiPlannings.ListNodePlanningsRequest) ([]*ApiPlannings.NodePlanning, error)
Click to show internal directories.
Click to hide internal directories.