clusterstatus

Documentation

Index

• Constants
• type ContainerRepository
  • func NewContainerRepository(influxDBCfg *influxdb.Config) *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 NewControllerRepository(influxDBCfg *influxdb.Config) *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 NewNodeRepository(influxDBCfg *influxdb.Config) *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

const (
	// Node is node measurement
	Node influxdb.Measurement = "node"
	// Container is container measurement
	Container  influxdb.Measurement = "container"
	Controller influxdb.Measurement = "controller"
)

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

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

func NewControllerRepository

func NewControllerRepository(influxDBCfg *influxdb.Config) *ControllerRepository

func (*ControllerRepository) CreateControllers

func (c *ControllerRepository) CreateControllers(controllers []*datahub_api.Controller) error

func (*ControllerRepository) DeleteControllers

func (c *ControllerRepository) DeleteControllers(in *datahub_api.DeleteControllersRequest) error

func (*ControllerRepository) ListControllers

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

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