clusterstatus

Documentation

Index

• Constants
• type ApplicationRepository
  • func NewApplicationRepository(influxDBCfg InternalInflux.Config) *ApplicationRepository
  • func (p *ApplicationRepository) CreateApplications(applications []*DaoClusterTypes.Application) error
  • func (p *ApplicationRepository) DeleteApplications(request *DaoClusterTypes.DeleteApplicationsRequest) error
  • func (p *ApplicationRepository) ListApplications(request *DaoClusterTypes.ListApplicationsRequest) ([]*DaoClusterTypes.Application, error)
• type ClusterRepository
  • func NewClusterRepository(influxDBCfg InternalInflux.Config) *ClusterRepository
  • func (p *ClusterRepository) CreateClusters(clusters []*DaoClusterTypes.Cluster) error
  • func (p *ClusterRepository) DeleteClusters(request *DaoClusterTypes.DeleteClustersRequest) error
  • func (p *ClusterRepository) ListClusters(request *DaoClusterTypes.ListClustersRequest) ([]*DaoClusterTypes.Cluster, error)
• type ContainerRepository
  • func NewContainerRepository(influxDBCfg InternalInflux.Config) *ContainerRepository
  • func (p *ContainerRepository) ClusterNamespacePodName(values map[string]string) string
  • func (p *ContainerRepository) CreateContainers(containers map[string][]*DaoClusterTypes.Container) error
  • func (p *ContainerRepository) DeleteContainers(request DaoClusterTypes.DeleteContainersRequest) error
  • func (p *ContainerRepository) IsTag(column string) bool
  • func (p *ContainerRepository) ListContainers(request DaoClusterTypes.ListContainersRequest) (map[string][]*DaoClusterTypes.Container, error)
• type ControllerRepository
  • func NewControllerRepository(influxDBCfg InternalInflux.Config) *ControllerRepository
  • func (p *ControllerRepository) CreateControllers(controllers []*DaoClusterTypes.Controller) error
  • func (p *ControllerRepository) DeleteControllers(request *DaoClusterTypes.DeleteControllersRequest) error
  • func (p *ControllerRepository) ListControllers(request *DaoClusterTypes.ListControllersRequest) ([]*DaoClusterTypes.Controller, error)
• type NamespaceRepository
  • func NewNamespaceRepository(influxDBCfg InternalInflux.Config) *NamespaceRepository
  • func (p *NamespaceRepository) CreateNamespaces(namespaces []*DaoClusterTypes.Namespace) error
  • func (p *NamespaceRepository) DeleteNamespaces(request *DaoClusterTypes.DeleteNamespacesRequest) error
  • func (p *NamespaceRepository) ListNamespaces(request *DaoClusterTypes.ListNamespacesRequest) ([]*DaoClusterTypes.Namespace, error)
• type NodeRepository
  • func NewNodeRepository(influxDBCfg InternalInflux.Config) *NodeRepository
  • func (p *NodeRepository) CreateNodes(nodes []*DaoClusterTypes.Node) error
  • func (p *NodeRepository) DeleteNodes(request *DaoClusterTypes.DeleteNodesRequest) error
  • func (p *NodeRepository) IsTag(column string) bool
  • func (p *NodeRepository) ListNodes(request *DaoClusterTypes.ListNodesRequest) ([]*DaoClusterTypes.Node, error)
• type PodRepository
  • func NewPodRepository(influxDBCfg InternalInflux.Config) *PodRepository
  • func (p *PodRepository) CreatePods(pods []*DaoClusterTypes.Pod) error
  • func (p *PodRepository) DeletePods(request *DaoClusterTypes.DeletePodsRequest) error
  • func (p *PodRepository) IsTag(column string) bool
  • func (p *PodRepository) ListPods(request *DaoClusterTypes.ListPodsRequest) ([]*DaoClusterTypes.Pod, error)

Constants

const (
	Container   influxdb.Measurement = "container"
	Pod         influxdb.Measurement = "pod"
	Controller  influxdb.Measurement = "controller"
	Application influxdb.Measurement = "application"
	Namespace   influxdb.Measurement = "namespace"
	Node        influxdb.Measurement = "node"
	Cluster     influxdb.Measurement = "cluster"
)

Types

type ApplicationRepository

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

func NewApplicationRepository

func NewApplicationRepository(influxDBCfg InternalInflux.Config) *ApplicationRepository

func (*ApplicationRepository) CreateApplications

func (p *ApplicationRepository) CreateApplications(applications []*DaoClusterTypes.Application) error

func (*ApplicationRepository) DeleteApplications

func (p *ApplicationRepository) DeleteApplications(request *DaoClusterTypes.DeleteApplicationsRequest) error

func (*ApplicationRepository) ListApplications

func (p *ApplicationRepository) ListApplications(request *DaoClusterTypes.ListApplicationsRequest) ([]*DaoClusterTypes.Application, error)

type ClusterRepository

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

func NewClusterRepository

func NewClusterRepository(influxDBCfg InternalInflux.Config) *ClusterRepository

func (*ClusterRepository) CreateClusters

func (p *ClusterRepository) CreateClusters(clusters []*DaoClusterTypes.Cluster) error

func (*ClusterRepository) DeleteClusters

func (p *ClusterRepository) DeleteClusters(request *DaoClusterTypes.DeleteClustersRequest) error

func (*ClusterRepository) ListClusters

func (p *ClusterRepository) ListClusters(request *DaoClusterTypes.ListClustersRequest) ([]*DaoClusterTypes.Cluster, error)

type ContainerRepository

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

func NewContainerRepository

func NewContainerRepository(influxDBCfg InternalInflux.Config) *ContainerRepository

func (*ContainerRepository) ClusterNamespacePodName

func (p *ContainerRepository) ClusterNamespacePodName(values map[string]string) string

func (*ContainerRepository) CreateContainers

func (p *ContainerRepository) CreateContainers(containers map[string][]*DaoClusterTypes.Container) error

CreateContainers add containers information container measurement

func (*ContainerRepository) DeleteContainers

func (p *ContainerRepository) DeleteContainers(request DaoClusterTypes.DeleteContainersRequest) error

DeleteContainers set containers' field is_deleted to true into container measurement

func (*ContainerRepository) IsTag

func (p *ContainerRepository) IsTag(column string) bool

func (*ContainerRepository) ListContainers

func (p *ContainerRepository) ListContainers(request DaoClusterTypes.ListContainersRequest) (map[string][]*DaoClusterTypes.Container, error)

ListContainers list predicted containers have relation with arguments

type ControllerRepository

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

func NewControllerRepository

func NewControllerRepository(influxDBCfg InternalInflux.Config) *ControllerRepository

func (*ControllerRepository) CreateControllers

func (p *ControllerRepository) CreateControllers(controllers []*DaoClusterTypes.Controller) error

func (*ControllerRepository) DeleteControllers

func (p *ControllerRepository) DeleteControllers(request *DaoClusterTypes.DeleteControllersRequest) error

func (*ControllerRepository) ListControllers

func (p *ControllerRepository) ListControllers(request *DaoClusterTypes.ListControllersRequest) ([]*DaoClusterTypes.Controller, error)

type NamespaceRepository

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

func NewNamespaceRepository

func NewNamespaceRepository(influxDBCfg InternalInflux.Config) *NamespaceRepository

func (*NamespaceRepository) CreateNamespaces

func (p *NamespaceRepository) CreateNamespaces(namespaces []*DaoClusterTypes.Namespace) error

func (*NamespaceRepository) DeleteNamespaces

func (p *NamespaceRepository) DeleteNamespaces(request *DaoClusterTypes.DeleteNamespacesRequest) error

func (*NamespaceRepository) ListNamespaces

func (p *NamespaceRepository) ListNamespaces(request *DaoClusterTypes.ListNamespacesRequest) ([]*DaoClusterTypes.Namespace, error)

type NodeRepository

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

func NewNodeRepository

func NewNodeRepository(influxDBCfg InternalInflux.Config) *NodeRepository

func (*NodeRepository) CreateNodes

func (p *NodeRepository) CreateNodes(nodes []*DaoClusterTypes.Node) error

func (*NodeRepository) DeleteNodes

func (p *NodeRepository) DeleteNodes(request *DaoClusterTypes.DeleteNodesRequest) error

func (*NodeRepository) IsTag

func (p *NodeRepository) IsTag(column string) bool

func (*NodeRepository) ListNodes

func (p *NodeRepository) ListNodes(request *DaoClusterTypes.ListNodesRequest) ([]*DaoClusterTypes.Node, error)

type PodRepository

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

func NewPodRepository

func NewPodRepository(influxDBCfg InternalInflux.Config) *PodRepository

func (*PodRepository) CreatePods

func (p *PodRepository) CreatePods(pods []*DaoClusterTypes.Pod) error

func (*PodRepository) DeletePods

func (p *PodRepository) DeletePods(request *DaoClusterTypes.DeletePodsRequest) error

func (*PodRepository) IsTag

func (p *PodRepository) IsTag(column string) bool

func (*PodRepository) ListPods

func (p *PodRepository) ListPods(request *DaoClusterTypes.ListPodsRequest) ([]*DaoClusterTypes.Pod, error)