Versions in this module Expand all Collapse all v1 v1.0.0 Aug 17, 2023 Changes in this version + const ClusterStateFlagExisting + const ClusterStateFlagNew + const DefaultEnableV2 + const DefaultGRPCKeepAliveInterval + const DefaultGRPCKeepAliveMinTime + const DefaultGRPCKeepAliveTimeout + const DefaultListenClientURLs + const DefaultListenPeerURLs + const DefaultLogOutput + const DefaultMaxRequestBytes + const DefaultMaxSnapshots + const DefaultMaxTxnOps + const DefaultMaxWALs + const DefaultName + const DefaultStrictReconfigCheck + const JournalLogOutput + const StdErrLogOutput + const StdOutLogOutput + var CompactorModePeriodic = v3compactor.ModePeriodic + var CompactorModeRevision = v3compactor.ModeRevision + var DefaultAdvertiseClientURLs = "http://localhost:2379" + var DefaultInitialAdvertisePeerURLs = "http://localhost:2380" + var ErrConflictBootstrapFlags = fmt.Errorf(...) + var ErrUnsetAdvertiseClientURLsFlag = fmt.Errorf(...) + func NewZapCoreLoggerBuilder(lg *zap.Logger, cr zapcore.Core, syncer zapcore.WriteSyncer) func(*Config) error + func WrapCORS(cors map[string]struct{}, h http.Handler) http.Handler + type Config struct + ACUrls []url.URL + APUrls []url.URL + AuthToken string + AuthTokenTTL uint + AutoCompactionMode string + AutoCompactionRetention string + BackendBatchInterval time.Duration + BackendBatchLimit int + BcryptCost uint + CORS map[string]struct{} + CipherSuites []string + ClientAutoTLS bool + ClientTLSInfo transport.TLSInfo + ClusterState string + DNSCluster string + DNSClusterServiceName string + Debug bool + DeprecatedLogOutput []string + Dir string + Dproxy string + Durl string + ElectionMs uint + EnableGRPCGateway bool + EnablePprof bool + EnableV2 bool + ExperimentalBackendFreelistType string + ExperimentalCompactionBatchLimit int + ExperimentalCorruptCheckTime time.Duration + ExperimentalEnableLeaseCheckpoint bool + ExperimentalEnableV2V3 string + ExperimentalInitialCorruptCheck bool + ExperimentalWatchProgressNotifyInterval time.Duration + ForceNewCluster bool + GRPCKeepAliveInterval time.Duration + GRPCKeepAliveMinTime time.Duration + GRPCKeepAliveTimeout time.Duration + HostWhitelist map[string]struct{} + InitialCluster string + InitialClusterToken string + InitialElectionTickAdvance bool + LCUrls []url.URL + LPUrls []url.URL + ListenMetricsUrls []url.URL + ListenMetricsUrlsJSON string + LogLevel string + LogOutputs []string + LogPkgLevels string + Logger string + MaxRequestBytes uint + MaxSnapFiles uint + MaxTxnOps uint + MaxWalFiles uint + Metrics string + Name string + PeerAutoTLS bool + PeerTLSInfo transport.TLSInfo + PreVote bool + QuotaBackendBytes int64 + ServiceRegister func(*grpc.Server) + SnapshotCatchUpEntries uint64 + SnapshotCount uint64 + StrictReconfigCheck bool + TickMs uint + UnsafeNoFsync bool + UserHandlers map[string]http.Handler + WalDir string + ZapLoggerBuilder func(*Config) error + func ConfigFromFile(path string) (*Config, error) + func NewConfig() *Config + func (cfg *Config) ClientSelfCert() (err error) + func (cfg *Config) GetDNSClusterNames() ([]string, error) + func (cfg *Config) PeerSelfCert() (err error) + func (cfg *Config) PeerURLsMapAndToken(which string) (urlsmap types.URLsMap, token string, err error) + func (cfg *Config) UpdateDefaultClusterFromName(defaultInitialCluster string) (string, error) + func (cfg *Config) Validate() error + func (cfg Config) ElectionTicks() int + func (cfg Config) GetLogger() *zap.Logger + func (cfg Config) InitialClusterFromName(name string) (ret string) + func (cfg Config) IsNewCluster() bool + type Etcd struct + Clients []net.Listener + Peers []*peerListener + Server *etcdserver.EtcdServer + func StartEtcd(inCfg *Config) (e *Etcd, err error) + func (e *Etcd) Close() + func (e *Etcd) Config() Config + func (e *Etcd) Err() <-chan error + func (e *Etcd) GetLogger() *zap.Logger