Documentation ¶
Index ¶
- Constants
- type ConsistencyInfo
- type RequestInfo
- type Server
- func (c *Server) CollectAlarmList(inspection *kstonev1alpha2.EtcdInspection) error
- func (c *Server) CollectClusterConsistentData(inspection *kstonev1alpha2.EtcdInspection) error
- func (c *Server) CollectEtcdClusterRequest(inspection *kstonev1alpha2.EtcdInspection) error
- func (c *Server) CollectMemberHealthy(inspection *kstonev1alpha2.EtcdInspection) error
- func (c *Server) CreateEtcdInspection(inspection *kstonev1alpha2.EtcdInspection) (*kstonev1alpha2.EtcdInspection, error)
- func (c *Server) DeleteEtcdInspection(namespace, name string) error
- func (c *Server) Equal(cluster *kstonev1alpha2.EtcdCluster, ...) bool
- func (c *Server) GetEtcdCluster(namespace, name string) (*kstonev1alpha2.EtcdCluster, error)
- func (c *Server) GetEtcdClusterInfo(namespace, name string) (*kstonev1alpha2.EtcdCluster, *etcd.ClientConfig, error)
- func (c *Server) GetEtcdInspection(namespace, name string) (*kstonev1alpha2.EtcdInspection, error)
- func (c *Server) StatBackupFiles(inspection *kstonev1alpha2.EtcdInspection) error
- func (c *Server) Sync(cluster *kstonev1alpha2.EtcdCluster, ...) error
- func (c *Server) Watch(cluster *kstonev1alpha2.EtcdCluster, client *clientv3.Client, keyPrefix string) error
Constants ¶
const ( DefaultInspectionInterval = 300 * time.Second DefaultInspectionPath = "" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsistencyInfo ¶
type RequestInfo ¶
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 ¶
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