clusterstatus

package
v4.2.603+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 30, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
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"
)

Variables

This section is empty.

Functions

This section is empty.

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

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

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

DeleteContainers set containers' field is_deleted to true into container measurement

func (*ContainerRepository) IsTag

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

func (*ContainerRepository) ListContainers

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

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL