const ClusterStateFlagNew … const ClusterStateFlagExisting … const DefaultName … const DefaultMaxSnapshots … const DefaultMaxWALs … const DefaultMaxTxnOps … const DefaultWarningApplyDuration … const DefaultMaxRequestBytes … const DefaultMaxConcurrentStreams … const DefaultGRPCKeepAliveMinTime … const DefaultGRPCKeepAliveInterval … const DefaultGRPCKeepAliveTimeout … const DefaultDowngradeCheckTime … const DefaultListenPeerURLs … const DefaultListenClientURLs … const DefaultLogOutput … const JournalLogOutput … const StdErrLogOutput … const StdOutLogOutput … const DefaultLogRotationConfig … const ExperimentalDistributedTracingAddress … const ExperimentalDistributedTracingServiceName … const DefaultStrictReconfigCheck … const DefaultEnableV2 … const maxElectionMs … const freelistArrayType … var ErrConflictBootstrapFlags … var ErrUnsetAdvertiseClientURLsFlag … var ErrLogRotationInvalidLogOutput … var DefaultInitialAdvertisePeerURLs … var DefaultAdvertiseClientURLs … var defaultHostname … var defaultHostStatus … var getCluster … var CompactorModePeriodic … var CompactorModeRevision … func init() { … } type Config … type configYAML … type configJSON … type securityConfig … // NewConfig creates a new Config populated with default values. func NewConfig() *Config { … } func ConfigFromFile(path string) (*Config, error) { … } func (cfg *configYAML) configFromFile(path string) error { … } func updateCipherSuites(tls *transport.TLSInfo, ss []string) error { … } func updateMinMaxVersions(info *transport.TLSInfo, min, max string) { … } // Validate ensures that '*embed.Config' fields are properly configured. func (cfg *Config) Validate() error { … } // PeerURLsMapAndToken sets up an initial peer URLsMap and cluster token for bootstrap or discovery. func (cfg *Config) PeerURLsMapAndToken(which string) (urlsmap types.URLsMap, token string, err error) { … } // GetDNSClusterNames uses DNS SRV records to get a list of initial nodes for cluster bootstrapping. // This function will return a list of one or more nodes, as well as any errors encountered while // performing service discovery. // Note: Because this checks multiple sets of SRV records, discovery should only be considered to have // failed if the returned node list is empty. func (cfg *Config) GetDNSClusterNames() ([]string, error) { … } func (cfg Config) InitialClusterFromName(name string) (ret string) { … } func (cfg Config) IsNewCluster() bool { … } func (cfg Config) ElectionTicks() int { … } func (cfg Config) V2DeprecationEffective() config.V2DeprecationEnum { … } func (cfg Config) defaultPeerHost() bool { … } func (cfg Config) defaultClientHost() bool { … } func (cfg *Config) ClientSelfCert() (err error) { … } func (cfg *Config) PeerSelfCert() (err error) { … } // UpdateDefaultClusterFromName updates cluster advertise URLs with, if available, default host, // if advertise URLs are default values(localhost:2379,2380) AND if listen URL is 0.0.0.0. // e.g. advertise peer URL localhost:2380 or listen peer URL 0.0.0.0:2380 // then the advertise peer host would be updated with machine's default host, // while keeping the listen URL's port. // User can work around this by explicitly setting URL with 127.0.0.1. // It returns the default hostname, if used, and the error, if any, from getting the machine's default host. // TODO: check whether fields are set instead of whether fields have default value func (cfg *Config) UpdateDefaultClusterFromName(defaultInitialCluster string) (string, error) { … } // checkBindURLs returns an error if any URL uses a domain name. func checkBindURLs(urls []url.URL) error { … } func checkHostURLs(urls []url.URL) error { … } func (cfg *Config) getAdvertisePeerUrls() (ss []string) { … } func (cfg *Config) getListenPeerUrls() (ss []string) { … } func (cfg *Config) getAdvertiseClientUrls() (ss []string) { … } func (cfg *Config) getListenClientUrls() (ss []string) { … } func (cfg *Config) getListenClientHttpUrls() (ss []string) { … } func (cfg *Config) getMetricsURLs() (ss []string) { … } func parseBackendFreelistType(freelistType string) bolt.FreelistType { … }
Codebase Browser
kubernetes