factory

Documentation

Index

• func CreateOrUpdateClientService(ctx context.Context, cluster *etcdaenixiov1alpha1.EtcdCluster, ...) error
• func CreateOrUpdateClusterStateConfigMap(ctx context.Context, cluster *etcdaenixiov1alpha1.EtcdCluster, ...) error
• func CreateOrUpdateHeadlessService(ctx context.Context, cluster *etcdaenixiov1alpha1.EtcdCluster, ...) error
• func CreateOrUpdatePdb(ctx context.Context, cluster *etcdaenixiov1alpha1.EtcdCluster, ...) error
• func CreateOrUpdateStatefulSet(ctx context.Context, cluster *etcdaenixiov1alpha1.EtcdCluster, ...) error
• func GetClusterStateConfigMapName(cluster *etcdaenixiov1alpha1.EtcdCluster) string
• func GetHeadlessServiceName(cluster *etcdaenixiov1alpha1.EtcdCluster) string
• func GetPVCName(cluster *etcdaenixiov1alpha1.EtcdCluster) string
• func GetServerProtocol(cluster *etcdaenixiov1alpha1.EtcdCluster) string
• func GetServiceName(cluster *etcdaenixiov1alpha1.EtcdCluster) string
• func NewEtcdClientSet(ctx context.Context, cluster *v1alpha1.EtcdCluster, cli client.Client) (*clientv3.Client, []*clientv3.Client, error)
• func UpdatePersistentVolumeClaims(ctx context.Context, cluster *etcdaenixiov1alpha1.EtcdCluster, ...) error
• type LabelsBuilder
  • func NewLabelsBuilder() LabelsBuilder
  • func (b LabelsBuilder) WithInstance(name string) LabelsBuilder
  • func (b LabelsBuilder) WithManagedBy() LabelsBuilder
  • func (b LabelsBuilder) WithName() LabelsBuilder

Functions

func CreateOrUpdateClientService

func CreateOrUpdateClientService(
	ctx context.Context,
	cluster *etcdaenixiov1alpha1.EtcdCluster,
	rclient client.Client,
) error

func CreateOrUpdateClusterStateConfigMap

func CreateOrUpdateClusterStateConfigMap(
	ctx context.Context,
	cluster *etcdaenixiov1alpha1.EtcdCluster,
	rclient client.Client,
) error

func CreateOrUpdateHeadlessService

func CreateOrUpdateHeadlessService(
	ctx context.Context,
	cluster *etcdaenixiov1alpha1.EtcdCluster,
	rclient client.Client,
) error

func CreateOrUpdatePdb

func CreateOrUpdatePdb(
	ctx context.Context,
	cluster *etcdaenixiov1alpha1.EtcdCluster,
	rclient client.Client,
) error

func CreateOrUpdateStatefulSet

func CreateOrUpdateStatefulSet(
	ctx context.Context,
	cluster *etcdaenixiov1alpha1.EtcdCluster,
	rclient client.Client,
) error

func GetClusterStateConfigMapName

func GetClusterStateConfigMapName(cluster *etcdaenixiov1alpha1.EtcdCluster) string

func GetHeadlessServiceName

func GetHeadlessServiceName(cluster *etcdaenixiov1alpha1.EtcdCluster) string

func GetPVCName

func GetPVCName(cluster *etcdaenixiov1alpha1.EtcdCluster) string

func GetServerProtocol

func GetServerProtocol(cluster *etcdaenixiov1alpha1.EtcdCluster) string

func GetServiceName

func GetServiceName(cluster *etcdaenixiov1alpha1.EtcdCluster) string

func NewEtcdClientSet

func NewEtcdClientSet(ctx context.Context, cluster *v1alpha1.EtcdCluster, cli client.Client) (*clientv3.Client, []*clientv3.Client, error)

func UpdatePersistentVolumeClaims

func UpdatePersistentVolumeClaims(ctx context.Context, cluster *etcdaenixiov1alpha1.EtcdCluster, rclient client.Client) error

UpdatePersistentVolumeClaims checks and updates the sizes of PVCs in an EtcdCluster if the specified storage size is larger than the current.

Types

type LabelsBuilder

type LabelsBuilder map[string]string

func NewLabelsBuilder

func NewLabelsBuilder() LabelsBuilder

func (LabelsBuilder) WithInstance

func (b LabelsBuilder) WithInstance(name string) LabelsBuilder

func (LabelsBuilder) WithManagedBy

func (b LabelsBuilder) WithManagedBy() LabelsBuilder

func (LabelsBuilder) WithName

func (b LabelsBuilder) WithName() LabelsBuilder