inspection

package
v0.2.0-beta.2 Latest Latest
Warning

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

Go to latest
Published: Jun 8, 2022 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultInspectionInterval = 300 * time.Second
	DefaultInspectionPath     = ""
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ConsistencyInfo

type ConsistencyInfo struct {
	Path     string `json:"path,omitempty"`
	Interval int    `json:"interval,omitempty"`
}

type RequestInfo

type RequestInfo struct {
	Path     string `json:"path,omitempty"`
	Interval int    `json:"interval,omitempty"`
	Prefix   bool   `json:"prefix,omitempty"`
}

type Server

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

func NewInspectionServer

func NewInspectionServer(ctx *featureprovider.FeatureContext) (*Server, error)

NewInspectionServer generates the server of inspection

func (*Server) CollectAlarmList

func (c *Server) CollectAlarmList(inspection *kstonev1alpha2.EtcdInspection) error

CollectAlarmList collects the alarms of etcd, and transfer them to prometheus metrics

func (*Server) CollectClusterConsistentData

func (c *Server) CollectClusterConsistentData(inspection *kstonev1alpha2.EtcdInspection) error

CollectClusterConsistentData collects the etcd metadata info, calculate the difference, and transfer them to prometheus metrics

func (*Server) CollectEtcdClusterRequest

func (c *Server) CollectEtcdClusterRequest(inspection *kstonev1alpha2.EtcdInspection) error

CollectEtcdClusterRequest collects request of etcd

func (*Server) CollectMemberHealthy

func (c *Server) CollectMemberHealthy(inspection *kstonev1alpha2.EtcdInspection) error

CollectMemberHealthy collects the health of etcd, and transfer them to prometheus metrics

func (*Server) CreateEtcdInspection

func (c *Server) CreateEtcdInspection(inspection *kstonev1alpha2.EtcdInspection) (*kstonev1alpha2.EtcdInspection, error)

CreateEtcdInspection creates etcdinspection

func (*Server) DeleteEtcdInspection

func (c *Server) DeleteEtcdInspection(namespace, name string) error

DeleteEtcdInspection deletes etcdinspection

func (*Server) Equal

func (c *Server) Equal(cluster *kstonev1alpha2.EtcdCluster, inspectionFeatureName kstonev1alpha2.KStoneFeature) bool

func (*Server) GetEtcdCluster

func (c *Server) GetEtcdCluster(namespace, name string) (*kstonev1alpha2.EtcdCluster, error)

GetEtcdCluster gets etcdcluster

func (*Server) GetEtcdClusterInfo

func (c *Server) GetEtcdClusterInfo(namespace, name string) (*kstonev1alpha2.EtcdCluster, *etcd.ClientConfig, error)

func (*Server) GetEtcdInspection

func (c *Server) GetEtcdInspection(namespace, name string) (*kstonev1alpha2.EtcdInspection, error)

GetEtcdInspection gets etcdinspection

func (*Server) StatBackupFiles

func (c *Server) StatBackupFiles(inspection *kstonev1alpha2.EtcdInspection) error

StatBackupFiles counts the number of backup files in the last day and transfer it to prometheus metrics

func (*Server) Sync

func (c *Server) Sync(cluster *kstonev1alpha2.EtcdCluster, inspectionFeatureName kstonev1alpha2.KStoneFeature) error

func (*Server) Watch

func (c *Server) Watch(cluster *kstonev1alpha2.EtcdCluster, client *clientv3.Client, keyPrefix string) error

Watch watches etcd event

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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