Documentation ¶
Index ¶
- func GetEtcdClusterMemberStatus(members []kstonev1alpha2.MemberStatus, config *etcd.ClientConfig) ([]kstonev1alpha2.MemberStatus, kstonev1alpha2.EtcdClusterPhase)
- func GetRuntimeEtcdMembers(storageBackend string, endpoints []string, extensionClientURLs string, ...) ([]kstonev1alpha2.MemberStatus, error)
- func GetStorageMemberEndpoints(cluster *kstonev1alpha2.EtcdCluster) []string
- func RegisterEtcdClusterFactory(name kstonev1alpha2.EtcdClusterType, factory EtcdFactory)
- type Cluster
- type ClusterContext
- type EtcdAlarm
- type EtcdFactory
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetEtcdClusterMemberStatus ¶
func GetEtcdClusterMemberStatus( members []kstonev1alpha2.MemberStatus, config *etcd.ClientConfig) ([]kstonev1alpha2.MemberStatus, kstonev1alpha2.EtcdClusterPhase)
GetEtcdClusterMemberStatus check healthy of cluster and member
func GetRuntimeEtcdMembers ¶
func GetRuntimeEtcdMembers( storageBackend string, endpoints []string, extensionClientURLs string, config *etcd.ClientConfig) ([]kstonev1alpha2.MemberStatus, error)
GetRuntimeEtcdMembers get members of etcd
func GetStorageMemberEndpoints ¶
func GetStorageMemberEndpoints(cluster *kstonev1alpha2.EtcdCluster) []string
GetStorageMemberEndpoints get member of cluster status
func RegisterEtcdClusterFactory ¶
func RegisterEtcdClusterFactory(name kstonev1alpha2.EtcdClusterType, factory EtcdFactory)
RegisterEtcdClusterFactory registers the specified cluster provider
Types ¶
type Cluster ¶
type Cluster interface { // BeforeCreate does some things before creating the cluster BeforeCreate(cluster *kstonev1alpha2.EtcdCluster) error // Create creates the cluster Create(cluster *kstonev1alpha2.EtcdCluster) error // AfterCreate does some things after creating the cluster AfterCreate(cluster *kstonev1alpha2.EtcdCluster) error // BeforeUpdate does some things before updating the cluster BeforeUpdate(cluster *kstonev1alpha2.EtcdCluster) error // Update updates the cluster Update(cluster *kstonev1alpha2.EtcdCluster) error // AfterUpdate does some things after updating the cluster AfterUpdate(cluster *kstonev1alpha2.EtcdCluster) error // BeforeDelete does some things before deleting the cluster BeforeDelete(cluster *kstonev1alpha2.EtcdCluster) error // Delete deletes the cluster Delete(cluster *kstonev1alpha2.EtcdCluster) error // AfterDelete does some things after deleting the cluster AfterDelete(cluster *kstonev1alpha2.EtcdCluster) error // Equal checks whether the cluster needs to be updated Equal(cluster *kstonev1alpha2.EtcdCluster) (bool, error) // Status gets the cluster status Status(config *etcd.ClientConfig, cluster *kstonev1alpha2.EtcdCluster) (kstonev1alpha2.EtcdClusterStatus, error) }
Cluster is an abstract, pluggable interface for etcd clusters.
func GetEtcdClusterProvider ¶
func GetEtcdClusterProvider( name kstonev1alpha2.EtcdClusterType, ctx *ClusterContext, ) (Cluster, error)
GetEtcdClusterProvider gets the specified cluster provider
type ClusterContext ¶
type ClusterContext struct { Clientbuilder util.ClientBuilder Client dynamic.Interface }
type EtcdAlarm ¶
func GetEtcdAlarms ¶
func GetEtcdAlarms( endpoints []string, config *etcd.ClientConfig) ([]EtcdAlarm, error)
GetEtcdAlarms get alarm list of etcd
type EtcdFactory ¶
type EtcdFactory func(cluster *ClusterContext) (Cluster, error)
Click to show internal directories.
Click to hide internal directories.