kstone

Documentation

Index

• Constants
• type EtcdClusterKstone
  • func (c *EtcdClusterKstone) AfterCreate(cluster *kstonev1alpha1.EtcdCluster) error
  • func (c *EtcdClusterKstone) AfterDelete(cluster *kstonev1alpha1.EtcdCluster) error
  • func (c *EtcdClusterKstone) AfterUpdate(cluster *kstonev1alpha1.EtcdCluster) error
  • func (c *EtcdClusterKstone) BeforeCreate(cluster *kstonev1alpha1.EtcdCluster) error
  • func (c *EtcdClusterKstone) BeforeDelete(cluster *kstonev1alpha1.EtcdCluster) error
  • func (c *EtcdClusterKstone) BeforeUpdate(cluster *kstonev1alpha1.EtcdCluster) error
  • func (c *EtcdClusterKstone) Create(cluster *kstonev1alpha1.EtcdCluster) error
  • func (c *EtcdClusterKstone) Delete(cluster *kstonev1alpha1.EtcdCluster) error
  • func (c *EtcdClusterKstone) Equal(cluster *kstonev1alpha1.EtcdCluster) (bool, error)
  • func (c *EtcdClusterKstone) Status(tlsConfig *transport.TLSInfo, cluster *kstonev1alpha1.EtcdCluster) (kstonev1alpha1.EtcdClusterStatus, error)
  • func (c *EtcdClusterKstone) Update(cluster *kstonev1alpha1.EtcdCluster) error

Constants

const (
	AnnoImportedURI = "importedAddr"
)

Types

type EtcdClusterKstone

type EtcdClusterKstone struct {
	// contains filtered or unexported fields
}

EtcdClusterKstone is responsible for synchronizing kstone.tkestack.io/etcdcluster to kstone-etcd-operator

func (*EtcdClusterKstone) AfterCreate

func (c *EtcdClusterKstone) AfterCreate(cluster *kstonev1alpha1.EtcdCluster) error

AfterCreate handles etcdcluster after created

func (*EtcdClusterKstone) AfterDelete

func (c *EtcdClusterKstone) AfterDelete(cluster *kstonev1alpha1.EtcdCluster) error

AfterDelete handles etcdcluster after deleted

func (*EtcdClusterKstone) AfterUpdate

func (c *EtcdClusterKstone) AfterUpdate(cluster *kstonev1alpha1.EtcdCluster) error

AfterUpdate handles etcdcluster after updated

func (*EtcdClusterKstone) BeforeCreate

func (c *EtcdClusterKstone) BeforeCreate(cluster *kstonev1alpha1.EtcdCluster) error

func (*EtcdClusterKstone) BeforeDelete

func (c *EtcdClusterKstone) BeforeDelete(cluster *kstonev1alpha1.EtcdCluster) error

BeforeDelete handles etcdcluster before deleted

func (*EtcdClusterKstone) BeforeUpdate

func (c *EtcdClusterKstone) BeforeUpdate(cluster *kstonev1alpha1.EtcdCluster) error

BeforeUpdate handles etcdcluster before updated

func (*EtcdClusterKstone) Create

func (c *EtcdClusterKstone) Create(cluster *kstonev1alpha1.EtcdCluster) error

Create creates an etcd cluster

func (*EtcdClusterKstone) Delete

func (c *EtcdClusterKstone) Delete(cluster *kstonev1alpha1.EtcdCluster) error

Delete handles delete

func (*EtcdClusterKstone) Equal

func (c *EtcdClusterKstone) Equal(cluster *kstonev1alpha1.EtcdCluster) (bool, error)

Equal checks etcdcluster, if not equal, sync etcdclusters.etcd.tkestack.io if equal, nothing to do

func (*EtcdClusterKstone) Status

func (c *EtcdClusterKstone) Status(tlsConfig *transport.TLSInfo, cluster *kstonev1alpha1.EtcdCluster) (kstonev1alpha1.EtcdClusterStatus, error)

Status checks etcd member and returns new status

func (*EtcdClusterKstone) Update

func (c *EtcdClusterKstone) Update(cluster *kstonev1alpha1.EtcdCluster) error

Update updates cluster of kstone-etcd-operator