clusterprovider

Documentation

Index

• func GetEtcdClusterMemberStatus(members []kstonev1alpha1.MemberStatus, tls *transport.TLSInfo) ([]kstonev1alpha1.MemberStatus, kstonev1alpha1.EtcdClusterPhase)
• func GetRuntimeEtcdMembers(endpoints []string, extensionClientURLs string, tls *transport.TLSInfo) ([]kstonev1alpha1.MemberStatus, error)
• func GetStorageMemberEndpoints(cluster *kstonev1alpha1.EtcdCluster) []string
• func RegisterEtcdClusterFactory(name kstonev1alpha1.EtcdClusterType, factory EtcdFactory)
• type Cluster
  • func GetEtcdClusterProvider(name kstonev1alpha1.EtcdClusterType, ctx *ClusterContext) (Cluster, error)
• type ClusterContext
• type EtcdAlarm
  • func GetEtcdAlarms(endpoints []string, tls *transport.TLSInfo) ([]EtcdAlarm, error)
• type EtcdFactory

Functions

func GetEtcdClusterMemberStatus

func GetEtcdClusterMemberStatus(
	members []kstonev1alpha1.MemberStatus,
	tls *transport.TLSInfo) ([]kstonev1alpha1.MemberStatus, kstonev1alpha1.EtcdClusterPhase)

GetEtcdClusterMemberStatus check healthy of cluster and member

func GetRuntimeEtcdMembers

func GetRuntimeEtcdMembers(
	endpoints []string,
	extensionClientURLs string,
	tls *transport.TLSInfo) ([]kstonev1alpha1.MemberStatus, error)

GetRuntimeEtcdMembers get members of etcd

func GetStorageMemberEndpoints

func GetStorageMemberEndpoints(cluster *kstonev1alpha1.EtcdCluster) []string

GetStorageMemberEndpoints get member of cluster status

func RegisterEtcdClusterFactory

func RegisterEtcdClusterFactory(name kstonev1alpha1.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 *kstonev1alpha1.EtcdCluster) error
	// Create creates the cluster
	Create(cluster *kstonev1alpha1.EtcdCluster) error
	// AfterCreate does some things after creating the cluster
	AfterCreate(cluster *kstonev1alpha1.EtcdCluster) error

	// BeforeUpdate does some things before updating the cluster
	BeforeUpdate(cluster *kstonev1alpha1.EtcdCluster) error
	// Update updates the cluster
	Update(cluster *kstonev1alpha1.EtcdCluster) error
	// AfterUpdate does some things after updating the cluster
	AfterUpdate(cluster *kstonev1alpha1.EtcdCluster) error

	// BeforeDelete does some things before deleting the cluster
	BeforeDelete(cluster *kstonev1alpha1.EtcdCluster) error
	// Delete deletes the cluster
	Delete(cluster *kstonev1alpha1.EtcdCluster) error
	// AfterDelete does some things after deleting the cluster
	AfterDelete(cluster *kstonev1alpha1.EtcdCluster) error

	// Equal checks whether the cluster needs to be updated
	Equal(cluster *kstonev1alpha1.EtcdCluster) (bool, error)

	// Status gets the cluster status
	Status(tlsConfig *transport.TLSInfo, cluster *kstonev1alpha1.EtcdCluster) (kstonev1alpha1.EtcdClusterStatus, error)
}

Cluster is an abstract, pluggable interface for etcd clusters.

func GetEtcdClusterProvider

func GetEtcdClusterProvider(
	name kstonev1alpha1.EtcdClusterType,
	ctx *ClusterContext,
) (Cluster, error)

GetEtcdClusterProvider gets the specified cluster provider

type ClusterContext

type ClusterContext struct {
	Clientbuilder util.ClientBuilder
	Client        dynamic.Interface
}

type EtcdAlarm

type EtcdAlarm struct {
	MemberID  uint64
	AlarmType string
}

func GetEtcdAlarms

func GetEtcdAlarms(
	endpoints []string,
	tls *transport.TLSInfo) ([]EtcdAlarm, error)

GetEtcdAlarms get alarm list of etcd

type EtcdFactory

type EtcdFactory func(cluster *ClusterContext) (Cluster, error)