Documentation ¶
Index ¶
- Constants
- type ContainerRepository
- func (containerRepository *ContainerRepository) CreateContainers(pods []*datahub_v1alpha1.Pod) error
- func (containerRepository *ContainerRepository) DeleteContainers(pods []*datahub_v1alpha1.Pod) error
- func (containerRepository *ContainerRepository) IsTag(column string) bool
- func (containerRepository *ContainerRepository) ListAlamedaContainers(namespace, name string, kind datahub_v1alpha1.Kind, ...) ([]*datahub_v1alpha1.Pod, error)
- func (containerRepository *ContainerRepository) ListPodsContainers(pods []*datahub_v1alpha1.Pod) ([]*cluster_status_entity.ContainerEntity, error)
- type ControllerRepository
- func (c *ControllerRepository) CreateControllers(controllers []*datahub_api.Controller) error
- func (c *ControllerRepository) DeleteControllers(in *datahub_api.DeleteControllersRequest) error
- func (c *ControllerRepository) ListControllers(in *datahub_api.ListControllersRequest) ([]*datahub_api.Controller, error)
- type NodeRepository
- func (nodeRepository *NodeRepository) AddAlamedaNodes(alamedaNodes []*datahub_v1alpha1.Node) error
- func (nodeRepository *NodeRepository) IsTag(column string) bool
- func (nodeRepository *NodeRepository) ListAlamedaNodes(timeRange *datahub_api.TimeRange) ([]*cluster_status_entity.NodeEntity, error)
- func (nodeRepository *NodeRepository) ListNodes(request cluster_status_dao.ListNodesRequest) ([]*cluster_status_entity.NodeEntity, error)
- func (nodeRepository *NodeRepository) RemoveAlamedaNodes(alamedaNodes []*datahub_v1alpha1.Node) error
Constants ¶
View Source
const ( // Node is node measurement Node influxdb.Measurement = "node" // Container is container measurement Container influxdb.Measurement = "container" Controller influxdb.Measurement = "controller" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ContainerRepository ¶
type ContainerRepository struct {
// contains filtered or unexported fields
}
ContainerRepository is used to operate node measurement of cluster_status database
func NewContainerRepository ¶
func NewContainerRepository(influxDBCfg *influxdb.Config) *ContainerRepository
NewContainerRepository creates the ContainerRepository instance
func (*ContainerRepository) CreateContainers ¶
func (containerRepository *ContainerRepository) CreateContainers(pods []*datahub_v1alpha1.Pod) error
CreateContainers add containers information container measurement
func (*ContainerRepository) DeleteContainers ¶
func (containerRepository *ContainerRepository) DeleteContainers(pods []*datahub_v1alpha1.Pod) error
DeleteContainers set containers' field is_deleted to true into container measurement
func (*ContainerRepository) IsTag ¶
func (containerRepository *ContainerRepository) IsTag(column string) bool
IsTag checks the column is tag or not
func (*ContainerRepository) ListAlamedaContainers ¶
func (containerRepository *ContainerRepository) ListAlamedaContainers(namespace, name string, kind datahub_v1alpha1.Kind, timeRange *datahub_v1alpha1.TimeRange) ([]*datahub_v1alpha1.Pod, error)
ListAlamedaContainers list predicted containers have relation with arguments
func (*ContainerRepository) ListPodsContainers ¶
func (containerRepository *ContainerRepository) ListPodsContainers(pods []*datahub_v1alpha1.Pod) ([]*cluster_status_entity.ContainerEntity, error)
ListPodsContainers list containers information container measurement
type ControllerRepository ¶ added in v0.3.9
type ControllerRepository struct {
// contains filtered or unexported fields
}
func NewControllerRepository ¶ added in v0.3.9
func NewControllerRepository(influxDBCfg *influxdb.Config) *ControllerRepository
func (*ControllerRepository) CreateControllers ¶ added in v0.3.9
func (c *ControllerRepository) CreateControllers(controllers []*datahub_api.Controller) error
func (*ControllerRepository) DeleteControllers ¶ added in v0.3.11
func (c *ControllerRepository) DeleteControllers(in *datahub_api.DeleteControllersRequest) error
func (*ControllerRepository) ListControllers ¶ added in v0.3.9
func (c *ControllerRepository) ListControllers(in *datahub_api.ListControllersRequest) ([]*datahub_api.Controller, error)
type NodeRepository ¶
type NodeRepository struct {
// contains filtered or unexported fields
}
func NewNodeRepository ¶
func NewNodeRepository(influxDBCfg *influxdb.Config) *NodeRepository
func (*NodeRepository) AddAlamedaNodes ¶
func (nodeRepository *NodeRepository) AddAlamedaNodes(alamedaNodes []*datahub_v1alpha1.Node) error
AddAlamedaNodes add node information to database
func (*NodeRepository) IsTag ¶
func (nodeRepository *NodeRepository) IsTag(column string) bool
func (*NodeRepository) ListAlamedaNodes ¶
func (nodeRepository *NodeRepository) ListAlamedaNodes(timeRange *datahub_api.TimeRange) ([]*cluster_status_entity.NodeEntity, error)
func (*NodeRepository) ListNodes ¶ added in v0.3.0
func (nodeRepository *NodeRepository) ListNodes(request cluster_status_dao.ListNodesRequest) ([]*cluster_status_entity.NodeEntity, error)
func (*NodeRepository) RemoveAlamedaNodes ¶
func (nodeRepository *NodeRepository) RemoveAlamedaNodes(alamedaNodes []*datahub_v1alpha1.Node) error
Click to show internal directories.
Click to hide internal directories.