Versions in this module Expand all Collapse all v1 v1.21.9 Jan 25, 2022 Changes in this version + const ControlPlaneLabel + const EtcdRoleLabel + const MasterLabel + var AddressKey = version.Program + "/apiaddresses" + var NodeAddressAnnotation = "etcd." + version.Program + ".cattle.io/node-address" + var NodeNameAnnotation = "etcd." + version.Program + ".cattle.io/node-name" + func DBDir(config *config.Control) string + func GetAPIServerURLFromETCD(ctx context.Context, cfg *config.Control) (string, error) + func GetAdvertiseAddress(advertiseIP string) (string, error) + func GetClient(ctx context.Context, runtime *config.ControlRuntime, endpoints ...string) (*etcd.Client, error) + func RegisterMemberHandlers(ctx context.Context, etcd *ETCD, nodes controllerv1.NodeController) + func RegisterMetadataHandlers(ctx context.Context, etcd *ETCD, nodes controllerv1.NodeController) + func ResetFile(config *config.Control) string + type ETCD struct + func NewETCD() *ETCD + func (e *ETCD) DeleteSnapshots(ctx context.Context, snapshots []string) error + func (e *ETCD) EndpointName() string + func (e *ETCD) GetMembersClientURLs(ctx context.Context) ([]string, error) + func (e *ETCD) GetMembersNames(ctx context.Context) ([]string, error) + func (e *ETCD) IsInitialized(ctx context.Context, config *config.Control) (bool, error) + func (e *ETCD) ListSnapshots(ctx context.Context) (map[string]snapshotFile, error) + func (e *ETCD) PruneSnapshots(ctx context.Context) error + func (e *ETCD) ReconcileSnapshotData(ctx context.Context) error + func (e *ETCD) Register(ctx context.Context, config *config.Control, handler http.Handler) (http.Handler, error) + func (e *ETCD) RemovePeer(ctx context.Context, name, address string, allowSelfRemoval bool) error + func (e *ETCD) RemoveSelf(ctx context.Context) error + func (e *ETCD) Reset(ctx context.Context, rebootstrap func() error) error + func (e *ETCD) Restore(ctx context.Context) error + func (e *ETCD) SetControlConfig(config *config.Control) + func (e *ETCD) Snapshot(ctx context.Context, config *config.Control) error + func (e *ETCD) Start(ctx context.Context, clientAccessInfo *clientaccess.Info) error + func (e *ETCD) Test(ctx context.Context) error + type Members struct + Members []*etcdserverpb.Member + func ClientURLs(ctx context.Context, clientAccessInfo *clientaccess.Info, selfIP string) ([]string, Members, error) + type NodeControllerGetter func() controllerv1.NodeController + type Proxy interface + ETCDAddresses func() []string + ETCDServerURL func() string + ETCDURL func() string + Update func(addresses []string) + func NewETCDProxy(ctx context.Context, enabled bool, dataDir, etcdURL string) (Proxy, error) + type S3 struct + func NewS3(ctx context.Context, config *config.Control) (*S3, error) + func (s *S3) Download(ctx context.Context) error