inspection

package

v0.2.0-beta.2 Latest Latest Go to latest Published: Jun 8, 2022 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tkestack/kstone

Documentation ¶

Index ¶

Constants
type ConsistencyInfo
type RequestInfo
type Server
- func NewInspectionServer(ctx *featureprovider.FeatureContext) (*Server, error)

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
metrics

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