kubernetes/vendor/go.etcd.io/etcd/server/v3/embed/etcd.go

const reservedInternalFDNum …

type Etcd …

type peerListener …

// StartEtcd launches the etcd server and HTTP handlers for client/server communication.
// The returned Etcd.Server is not guaranteed to have joined the cluster. Wait
// on the Etcd.Server.ReadyNotify() channel to know when it completes and is ready for use.
func StartEtcd(inCfg *Config) (e *Etcd, err error) { … }

func print(lg *zap.Logger, ec Config, sc config.ServerConfig, memberInitialized bool) { … }

// Config returns the current configuration.
func (e *Etcd) Config() Config { … }

// Close gracefully shuts down all servers/listeners.
// Client requests will be terminated with request timeout.
// After timeout, enforce remaning requests be closed immediately.
func (e *Etcd) Close() { … }

func stopServers(ctx context.Context, ss *servers) { … }

// Err - return channel used to report errors during etcd run/shutdown.
// Since etcd 3.5 the channel is being closed when the etcd is over.
func (e *Etcd) Err() <-chan error { … }

func configurePeerListeners(cfg *Config) (peers []*peerListener, err error) { … }

// configure peer handlers after rafthttp.Transport started
func (e *Etcd) servePeers() (err error) { … }

func configureClientListeners(cfg *Config) (sctxs map[string]*serveCtx, err error) { … }

func resolveUrl(u url.URL) (addr string, secure bool, network string) { … }

func (e *Etcd) serveClients() (err error) { … }

func (e *Etcd) grpcGatewayDial(splitHttp bool) (grpcDial func(ctx context.Context) (*grpc.ClientConn, error)) { … }

func (e *Etcd) pickGrpcGatewayServeContext(splitHttp bool) *serveCtx { … }

var ErrMissingClientTLSInfoForMetricsURL …

func (e *Etcd) createMetricsListener(murl url.URL) (net.Listener, error) { … }

func (e *Etcd) serveMetrics() (err error) { … }

func (e *Etcd) errHandler(err error) { … }

// GetLogger returns the logger.
func (e *Etcd) GetLogger() *zap.Logger { … }

func parseCompactionRetention(mode, retention string) (ret time.Duration, err error) { … }