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)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.