vendor/go.etcd.io/etcd/server/v3/config/config.go - voltha-go - Gitiles

 // Copyright 2015 The etcd Authors
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
 //
 //     http://www.apache.org/licenses/LICENSE-2.0
 //
 // Unless required by applicable law or agreed to in writing, software
 // distributed under the License is distributed on an "AS IS" BASIS,
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.

 package config

 import (
 	"context"
 	"fmt"
 	"path/filepath"
 	"sort"
 	"strings"
 	"time"

 	"go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc"
 	"go.uber.org/zap"

 	bolt "go.etcd.io/bbolt"
 	"go.etcd.io/etcd/client/pkg/v3/transport"
 	"go.etcd.io/etcd/client/pkg/v3/types"
 	"go.etcd.io/etcd/pkg/v3/featuregate"
 	"go.etcd.io/etcd/pkg/v3/netutil"
 	"go.etcd.io/etcd/server/v3/etcdserver/api/v3discovery"
 	"go.etcd.io/etcd/server/v3/storage/datadir"
 )

 const (
 	grpcOverheadBytes = 512 * 1024
 )

 // ServerConfig holds the configuration of etcd as taken from the command line or discovery.
 type ServerConfig struct {
 	Name string

 	DiscoveryURL   string
 	DiscoveryProxy string
 	DiscoveryCfg   v3discovery.DiscoveryConfig

 	ClientURLs types.URLs
 	PeerURLs   types.URLs
 	DataDir    string
 	// DedicatedWALDir config will make the etcd to write the WAL to the WALDir
 	// rather than the dataDir/member/wal.
 	DedicatedWALDir string

 	SnapshotCount uint64

 	// SnapshotCatchUpEntries is the number of entries for a slow follower
 	// to catch-up after compacting the raft storage entries.
 	// We expect the follower has a millisecond level latency with the leader.
 	// The max throughput is around 10K. Keep a 5K entries is enough for helping
 	// follower to catch up.
 	SnapshotCatchUpEntries uint64

 	MaxSnapFiles uint
 	MaxWALFiles  uint

 	// BackendBatchInterval is the maximum time before commit the backend transaction.
 	BackendBatchInterval time.Duration
 	// BackendBatchLimit is the maximum operations before commit the backend transaction.
 	BackendBatchLimit int

 	// BackendFreelistType is the type of the backend boltdb freelist.
 	BackendFreelistType bolt.FreelistType

 	InitialPeerURLsMap  types.URLsMap
 	InitialClusterToken string
 	NewCluster          bool
 	PeerTLSInfo         transport.TLSInfo

 	CORS map[string]struct{}

 	// HostWhitelist lists acceptable hostnames from client requests.
 	// If server is insecure (no TLS), server only accepts requests
 	// whose Host header value exists in this white list.
 	HostWhitelist map[string]struct{}

 	TickMs        uint
 	ElectionTicks int

 	// InitialElectionTickAdvance is true, then local member fast-forwards
 	// election ticks to speed up "initial" leader election trigger. This
 	// benefits the case of larger election ticks. For instance, cross
 	// datacenter deployment may require longer election timeout of 10-second.
 	// If true, local node does not need wait up to 10-second. Instead,
 	// forwards its election ticks to 8-second, and have only 2-second left
 	// before leader election.
 	//
 	// Major assumptions are that:
 	//  - cluster has no active leader thus advancing ticks enables faster
 	//    leader election, or
 	//  - cluster already has an established leader, and rejoining follower
 	//    is likely to receive heartbeats from the leader after tick advance
 	//    and before election timeout.
 	//
 	// However, when network from leader to rejoining follower is congested,
 	// and the follower does not receive leader heartbeat within left election
 	// ticks, disruptive election has to happen thus affecting cluster
 	// availabilities.
 	//
 	// Disabling this would slow down initial bootstrap process for cross
 	// datacenter deployments. Make your own tradeoffs by configuring
 	// --initial-election-tick-advance at the cost of slow initial bootstrap.
 	//
 	// If single-node, it advances ticks regardless.
 	//
 	// See https://github.com/etcd-io/etcd/issues/9333 for more detail.
 	InitialElectionTickAdvance bool

 	BootstrapTimeout time.Duration

 	AutoCompactionRetention time.Duration
 	AutoCompactionMode      string
 	CompactionBatchLimit    int
 	CompactionSleepInterval time.Duration
 	QuotaBackendBytes       int64
 	MaxTxnOps               uint

 	// MaxRequestBytes is the maximum request size to send over raft.
 	MaxRequestBytes uint

 	// MaxConcurrentStreams specifies the maximum number of concurrent
 	// streams that each client can open at a time.
 	MaxConcurrentStreams uint32

 	WarningApplyDuration        time.Duration
 	WarningUnaryRequestDuration time.Duration

 	StrictReconfigCheck bool

 	// ClientCertAuthEnabled is true when cert has been signed by the client CA.
 	ClientCertAuthEnabled bool

 	AuthToken  string
 	BcryptCost uint
 	TokenTTL   uint

 	// InitialCorruptCheck is true to check data corruption on boot
 	// before serving any peer/client traffic.
 	InitialCorruptCheck  bool
 	CorruptCheckTime     time.Duration
 	CompactHashCheckTime time.Duration

 	// PreVote is true to enable Raft Pre-Vote.
 	PreVote bool

 	// SocketOpts are socket options passed to listener config.
 	SocketOpts transport.SocketOpts

 	// Logger logs server-side operations.
 	Logger *zap.Logger

 	ForceNewCluster bool

 	// LeaseCheckpointInterval time.Duration is the wait duration between lease checkpoints.
 	LeaseCheckpointInterval time.Duration

 	EnableGRPCGateway bool

 	// EnableDistributedTracing enables distributed tracing using OpenTelemetry protocol.
 	EnableDistributedTracing bool
 	// TracerOptions are options for OpenTelemetry gRPC interceptor.
 	TracerOptions []otelgrpc.Option

 	WatchProgressNotifyInterval time.Duration

 	// UnsafeNoFsync disables all uses of fsync.
 	// Setting this is unsafe and will cause data loss.
 	UnsafeNoFsync bool `json:"unsafe-no-fsync"`

 	DowngradeCheckTime time.Duration

 	// MemoryMlock enables mlocking of etcd owned memory pages.
 	// The setting improves etcd tail latency in environments were:
 	//   - memory pressure might lead to swapping pages to disk
 	//   - disk latency might be unstable
 	// Currently all etcd memory gets mlocked, but in future the flag can
 	// be refined to mlock in-use area of bbolt only.
 	MemoryMlock bool `json:"memory-mlock"`

 	// ExperimentalTxnModeWriteWithSharedBuffer enable write transaction to use
 	// a shared buffer in its readonly check operations.
 	// TODO: Delete in v3.7
 	// Deprecated: Use TxnModeWriteWithSharedBuffer Feature Gate instead. Will be decommissioned in v3.7.
 	ExperimentalTxnModeWriteWithSharedBuffer bool `json:"experimental-txn-mode-write-with-shared-buffer"`

 	// BootstrapDefragThresholdMegabytes is the minimum number of megabytes needed to be freed for etcd server to
 	// consider running defrag during bootstrap. Needs to be set to non-zero value to take effect.
 	BootstrapDefragThresholdMegabytes uint `json:"bootstrap-defrag-threshold-megabytes"`

 	// MaxLearners sets a limit to the number of learner members that can exist in the cluster membership.
 	MaxLearners int `json:"max-learners"`

 	// V2Deprecation defines a phase of v2store deprecation process.
 	V2Deprecation V2DeprecationEnum `json:"v2-deprecation"`

 	// ExperimentalLocalAddress is the local IP address to use when communicating with a peer.
 	ExperimentalLocalAddress string `json:"experimental-local-address"`

 	// ServerFeatureGate is a server level feature gate
 	ServerFeatureGate featuregate.FeatureGate

 	// Metrics types of metrics - should be either 'basic' or 'extensive'
 	Metrics string
 }

 // VerifyBootstrap sanity-checks the initial config for bootstrap case
 // and returns an error for things that should never happen.
 func (c *ServerConfig) VerifyBootstrap() error {
 	if err := c.hasLocalMember(); err != nil {
 		return err
 	}
 	if err := c.advertiseMatchesCluster(); err != nil {
 		return err
 	}
 	if CheckDuplicateURL(c.InitialPeerURLsMap) {
 		return fmt.Errorf("initial cluster %s has duplicate url", c.InitialPeerURLsMap)
 	}
 	if c.InitialPeerURLsMap.String() == "" && c.DiscoveryURL == "" {
 		return fmt.Errorf("initial cluster unset and no discovery URL found")
 	}
 	return nil
 }

 // VerifyJoinExisting sanity-checks the initial config for join existing cluster
 // case and returns an error for things that should never happen.
 func (c *ServerConfig) VerifyJoinExisting() error {
 	// The member has announced its peer urls to the cluster before starting; no need to
 	// set the configuration again.
 	if err := c.hasLocalMember(); err != nil {
 		return err
 	}
 	if CheckDuplicateURL(c.InitialPeerURLsMap) {
 		return fmt.Errorf("initial cluster %s has duplicate url", c.InitialPeerURLsMap)
 	}
 	if c.DiscoveryURL != "" {
 		return fmt.Errorf("discovery URL should not be set when joining existing initial cluster")
 	}
 	return nil
 }

 // hasLocalMember checks that the cluster at least contains the local server.
 func (c *ServerConfig) hasLocalMember() error {
 	if urls := c.InitialPeerURLsMap[c.Name]; urls == nil {
 		return fmt.Errorf("couldn't find local name %q in the initial cluster configuration", c.Name)
 	}
 	return nil
 }

 // advertiseMatchesCluster confirms peer URLs match those in the cluster peer list.
 func (c *ServerConfig) advertiseMatchesCluster() error {
 	urls, apurls := c.InitialPeerURLsMap[c.Name], c.PeerURLs.StringSlice()
 	urls.Sort()
 	sort.Strings(apurls)
 	ctx, cancel := context.WithTimeout(context.TODO(), 30*time.Second)
 	defer cancel()
 	ok, err := netutil.URLStringsEqual(ctx, c.Logger, apurls, urls.StringSlice())
 	if ok {
 		return nil
 	}

 	initMap, apMap := make(map[string]struct{}), make(map[string]struct{})
 	for _, url := range c.PeerURLs {
 		apMap[url.String()] = struct{}{}
 	}
 	for _, url := range c.InitialPeerURLsMap[c.Name] {
 		initMap[url.String()] = struct{}{}
 	}

 	var missing []string
 	for url := range initMap {
 		if _, ok := apMap[url]; !ok {
 			missing = append(missing, url)
 		}
 	}
 	if len(missing) > 0 {
 		for i := range missing {
 			missing[i] = c.Name + "=" + missing[i]
 		}
 		mstr := strings.Join(missing, ",")
 		apStr := strings.Join(apurls, ",")
 		return fmt.Errorf("--initial-cluster has %s but missing from --initial-advertise-peer-urls=%s (%w)", mstr, apStr, err)
 	}

 	for url := range apMap {
 		if _, ok := initMap[url]; !ok {
 			missing = append(missing, url)
 		}
 	}
 	if len(missing) > 0 {
 		mstr := strings.Join(missing, ",")
 		umap := types.URLsMap(map[string]types.URLs{c.Name: c.PeerURLs})
 		return fmt.Errorf("--initial-advertise-peer-urls has %s but missing from --initial-cluster=%s", mstr, umap.String())
 	}

 	// resolved URLs from "--initial-advertise-peer-urls" and "--initial-cluster" did not match or failed
 	apStr := strings.Join(apurls, ",")
 	umap := types.URLsMap(map[string]types.URLs{c.Name: c.PeerURLs})
 	return fmt.Errorf("failed to resolve %s to match --initial-cluster=%s (%w)", apStr, umap.String(), err)
 }

 func (c *ServerConfig) MemberDir() string { return datadir.ToMemberDir(c.DataDir) }

 func (c *ServerConfig) WALDir() string {
 	if c.DedicatedWALDir != "" {
 		return c.DedicatedWALDir
 	}
 	return datadir.ToWALDir(c.DataDir)
 }

 func (c *ServerConfig) SnapDir() string { return filepath.Join(c.MemberDir(), "snap") }

 func (c *ServerConfig) ShouldDiscover() bool {
 	return c.DiscoveryURL != "" || len(c.DiscoveryCfg.Endpoints) > 0
 }

 // ReqTimeout returns timeout for request to finish.
 func (c *ServerConfig) ReqTimeout() time.Duration {
 	// 5s for queue waiting, computation and disk IO delay
 	// + 2 * election timeout for possible leader election
 	return 5*time.Second + 2*time.Duration(c.ElectionTicks*int(c.TickMs))*time.Millisecond
 }

 func (c *ServerConfig) ElectionTimeout() time.Duration {
 	return time.Duration(c.ElectionTicks*int(c.TickMs)) * time.Millisecond
 }

 func (c *ServerConfig) PeerDialTimeout() time.Duration {
 	// 1s for queue wait and election timeout
 	return time.Second + time.Duration(c.ElectionTicks*int(c.TickMs))*time.Millisecond
 }

 func CheckDuplicateURL(urlsmap types.URLsMap) bool {
 	um := make(map[string]bool)
 	for _, urls := range urlsmap {
 		for _, url := range urls {
 			u := url.String()
 			if um[u] {
 				return true
 			}
 			um[u] = true
 		}
 	}
 	return false
 }

 func (c *ServerConfig) BootstrapTimeoutEffective() time.Duration {
 	if c.BootstrapTimeout != 0 {
 		return c.BootstrapTimeout
 	}
 	return time.Second
 }

 func (c *ServerConfig) BackendPath() string { return datadir.ToBackendFileName(c.DataDir) }

 func (c *ServerConfig) MaxRequestBytesWithOverhead() uint {
 	return c.MaxRequestBytes + grpcOverheadBytes
 }
	// Copyright 2015 The etcd Authors
	//
	// Licensed under the Apache License, Version 2.0 (the "License");
	// you may not use this file except in compliance with the License.
	// You may obtain a copy of the License at
	//
	// http://www.apache.org/licenses/LICENSE-2.0
	//
	// Unless required by applicable law or agreed to in writing, software
	// distributed under the License is distributed on an "AS IS" BASIS,
	// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	// See the License for the specific language governing permissions and
	// limitations under the License.

	package config

	import (
	"context"
	"fmt"
	"path/filepath"
	"sort"
	"strings"
	"time"

	"go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc"
	"go.uber.org/zap"

	bolt "go.etcd.io/bbolt"
	"go.etcd.io/etcd/client/pkg/v3/transport"
	"go.etcd.io/etcd/client/pkg/v3/types"
	"go.etcd.io/etcd/pkg/v3/featuregate"
	"go.etcd.io/etcd/pkg/v3/netutil"
	"go.etcd.io/etcd/server/v3/etcdserver/api/v3discovery"
	"go.etcd.io/etcd/server/v3/storage/datadir"
	)

	const (
	grpcOverheadBytes = 512 * 1024
	)

	// ServerConfig holds the configuration of etcd as taken from the command line or discovery.
	type ServerConfig struct {
	Name string

	DiscoveryURL string
	DiscoveryProxy string
	DiscoveryCfg v3discovery.DiscoveryConfig

	ClientURLs types.URLs
	PeerURLs types.URLs
	DataDir string
	// DedicatedWALDir config will make the etcd to write the WAL to the WALDir
	// rather than the dataDir/member/wal.
	DedicatedWALDir string

	SnapshotCount uint64

	// SnapshotCatchUpEntries is the number of entries for a slow follower
	// to catch-up after compacting the raft storage entries.
	// We expect the follower has a millisecond level latency with the leader.
	// The max throughput is around 10K. Keep a 5K entries is enough for helping
	// follower to catch up.
	SnapshotCatchUpEntries uint64

	MaxSnapFiles uint
	MaxWALFiles uint

	// BackendBatchInterval is the maximum time before commit the backend transaction.
	BackendBatchInterval time.Duration
	// BackendBatchLimit is the maximum operations before commit the backend transaction.
	BackendBatchLimit int

	// BackendFreelistType is the type of the backend boltdb freelist.
	BackendFreelistType bolt.FreelistType

	InitialPeerURLsMap types.URLsMap
	InitialClusterToken string
	NewCluster bool
	PeerTLSInfo transport.TLSInfo

	CORS map[string]struct{}

	// HostWhitelist lists acceptable hostnames from client requests.
	// If server is insecure (no TLS), server only accepts requests
	// whose Host header value exists in this white list.
	HostWhitelist map[string]struct{}

	TickMs uint
	ElectionTicks int

	// InitialElectionTickAdvance is true, then local member fast-forwards
	// election ticks to speed up "initial" leader election trigger. This
	// benefits the case of larger election ticks. For instance, cross
	// datacenter deployment may require longer election timeout of 10-second.
	// If true, local node does not need wait up to 10-second. Instead,
	// forwards its election ticks to 8-second, and have only 2-second left
	// before leader election.
	//
	// Major assumptions are that:
	// - cluster has no active leader thus advancing ticks enables faster
	// leader election, or
	// - cluster already has an established leader, and rejoining follower
	// is likely to receive heartbeats from the leader after tick advance
	// and before election timeout.
	//
	// However, when network from leader to rejoining follower is congested,
	// and the follower does not receive leader heartbeat within left election
	// ticks, disruptive election has to happen thus affecting cluster
	// availabilities.
	//
	// Disabling this would slow down initial bootstrap process for cross
	// datacenter deployments. Make your own tradeoffs by configuring
	// --initial-election-tick-advance at the cost of slow initial bootstrap.
	//
	// If single-node, it advances ticks regardless.
	//
	// See https://github.com/etcd-io/etcd/issues/9333 for more detail.
	InitialElectionTickAdvance bool

	BootstrapTimeout time.Duration

	AutoCompactionRetention time.Duration
	AutoCompactionMode string
	CompactionBatchLimit int
	CompactionSleepInterval time.Duration
	QuotaBackendBytes int64
	MaxTxnOps uint

	// MaxRequestBytes is the maximum request size to send over raft.
	MaxRequestBytes uint

	// MaxConcurrentStreams specifies the maximum number of concurrent
	// streams that each client can open at a time.
	MaxConcurrentStreams uint32

	WarningApplyDuration time.Duration
	WarningUnaryRequestDuration time.Duration

	StrictReconfigCheck bool

	// ClientCertAuthEnabled is true when cert has been signed by the client CA.
	ClientCertAuthEnabled bool

	AuthToken string
	BcryptCost uint
	TokenTTL uint

	// InitialCorruptCheck is true to check data corruption on boot
	// before serving any peer/client traffic.
	InitialCorruptCheck bool
	CorruptCheckTime time.Duration
	CompactHashCheckTime time.Duration

	// PreVote is true to enable Raft Pre-Vote.
	PreVote bool

	// SocketOpts are socket options passed to listener config.
	SocketOpts transport.SocketOpts

	// Logger logs server-side operations.
	Logger *zap.Logger

	ForceNewCluster bool

	// LeaseCheckpointInterval time.Duration is the wait duration between lease checkpoints.
	LeaseCheckpointInterval time.Duration

	EnableGRPCGateway bool

	// EnableDistributedTracing enables distributed tracing using OpenTelemetry protocol.
	EnableDistributedTracing bool
	// TracerOptions are options for OpenTelemetry gRPC interceptor.
	TracerOptions []otelgrpc.Option

	WatchProgressNotifyInterval time.Duration

	// UnsafeNoFsync disables all uses of fsync.
	// Setting this is unsafe and will cause data loss.
	UnsafeNoFsync bool `json:"unsafe-no-fsync"`

	DowngradeCheckTime time.Duration

	// MemoryMlock enables mlocking of etcd owned memory pages.
	// The setting improves etcd tail latency in environments were:
	// - memory pressure might lead to swapping pages to disk
	// - disk latency might be unstable
	// Currently all etcd memory gets mlocked, but in future the flag can
	// be refined to mlock in-use area of bbolt only.
	MemoryMlock bool `json:"memory-mlock"`

	// ExperimentalTxnModeWriteWithSharedBuffer enable write transaction to use
	// a shared buffer in its readonly check operations.
	// TODO: Delete in v3.7
	// Deprecated: Use TxnModeWriteWithSharedBuffer Feature Gate instead. Will be decommissioned in v3.7.
	ExperimentalTxnModeWriteWithSharedBuffer bool `json:"experimental-txn-mode-write-with-shared-buffer"`

	// BootstrapDefragThresholdMegabytes is the minimum number of megabytes needed to be freed for etcd server to
	// consider running defrag during bootstrap. Needs to be set to non-zero value to take effect.
	BootstrapDefragThresholdMegabytes uint `json:"bootstrap-defrag-threshold-megabytes"`

	// MaxLearners sets a limit to the number of learner members that can exist in the cluster membership.
	MaxLearners int `json:"max-learners"`

	// V2Deprecation defines a phase of v2store deprecation process.
	V2Deprecation V2DeprecationEnum `json:"v2-deprecation"`

	// ExperimentalLocalAddress is the local IP address to use when communicating with a peer.
	ExperimentalLocalAddress string `json:"experimental-local-address"`

	// ServerFeatureGate is a server level feature gate
	ServerFeatureGate featuregate.FeatureGate

	// Metrics types of metrics - should be either 'basic' or 'extensive'
	Metrics string
	}

	// VerifyBootstrap sanity-checks the initial config for bootstrap case
	// and returns an error for things that should never happen.
	func (c *ServerConfig) VerifyBootstrap() error {
	if err := c.hasLocalMember(); err != nil {
	return err
	}
	if err := c.advertiseMatchesCluster(); err != nil {
	return err
	}
	if CheckDuplicateURL(c.InitialPeerURLsMap) {
	return fmt.Errorf("initial cluster %s has duplicate url", c.InitialPeerURLsMap)
	}
	if c.InitialPeerURLsMap.String() == "" && c.DiscoveryURL == "" {
	return fmt.Errorf("initial cluster unset and no discovery URL found")
	}
	return nil
	}

	// VerifyJoinExisting sanity-checks the initial config for join existing cluster
	// case and returns an error for things that should never happen.
	func (c *ServerConfig) VerifyJoinExisting() error {
	// The member has announced its peer urls to the cluster before starting; no need to
	// set the configuration again.
	if err := c.hasLocalMember(); err != nil {
	return err
	}
	if CheckDuplicateURL(c.InitialPeerURLsMap) {
	return fmt.Errorf("initial cluster %s has duplicate url", c.InitialPeerURLsMap)
	}
	if c.DiscoveryURL != "" {
	return fmt.Errorf("discovery URL should not be set when joining existing initial cluster")
	}
	return nil
	}

	// hasLocalMember checks that the cluster at least contains the local server.
	func (c *ServerConfig) hasLocalMember() error {
	if urls := c.InitialPeerURLsMap[c.Name]; urls == nil {
	return fmt.Errorf("couldn't find local name %q in the initial cluster configuration", c.Name)
	}
	return nil
	}

	// advertiseMatchesCluster confirms peer URLs match those in the cluster peer list.
	func (c *ServerConfig) advertiseMatchesCluster() error {
	urls, apurls := c.InitialPeerURLsMap[c.Name], c.PeerURLs.StringSlice()
	urls.Sort()
	sort.Strings(apurls)
	ctx, cancel := context.WithTimeout(context.TODO(), 30*time.Second)
	defer cancel()
	ok, err := netutil.URLStringsEqual(ctx, c.Logger, apurls, urls.StringSlice())
	if ok {
	return nil
	}

	initMap, apMap := make(map[string]struct{}), make(map[string]struct{})
	for _, url := range c.PeerURLs {
	apMap[url.String()] = struct{}{}
	}
	for _, url := range c.InitialPeerURLsMap[c.Name] {
	initMap[url.String()] = struct{}{}
	}

	var missing []string
	for url := range initMap {
	if _, ok := apMap[url]; !ok {
	missing = append(missing, url)
	}
	}
	if len(missing) > 0 {
	for i := range missing {
	missing[i] = c.Name + "=" + missing[i]
	}
	mstr := strings.Join(missing, ",")
	apStr := strings.Join(apurls, ",")
	return fmt.Errorf("--initial-cluster has %s but missing from --initial-advertise-peer-urls=%s (%w)", mstr, apStr, err)
	}

	for url := range apMap {
	if _, ok := initMap[url]; !ok {
	missing = append(missing, url)
	}
	}
	if len(missing) > 0 {
	mstr := strings.Join(missing, ",")
	umap := types.URLsMap(map[string]types.URLs{c.Name: c.PeerURLs})
	return fmt.Errorf("--initial-advertise-peer-urls has %s but missing from --initial-cluster=%s", mstr, umap.String())
	}

	// resolved URLs from "--initial-advertise-peer-urls" and "--initial-cluster" did not match or failed
	apStr := strings.Join(apurls, ",")
	umap := types.URLsMap(map[string]types.URLs{c.Name: c.PeerURLs})
	return fmt.Errorf("failed to resolve %s to match --initial-cluster=%s (%w)", apStr, umap.String(), err)
	}

	func (c *ServerConfig) MemberDir() string { return datadir.ToMemberDir(c.DataDir) }

	func (c *ServerConfig) WALDir() string {
	if c.DedicatedWALDir != "" {
	return c.DedicatedWALDir
	}
	return datadir.ToWALDir(c.DataDir)
	}

	func (c *ServerConfig) SnapDir() string { return filepath.Join(c.MemberDir(), "snap") }

	func (c *ServerConfig) ShouldDiscover() bool {
	return c.DiscoveryURL != "" \|\| len(c.DiscoveryCfg.Endpoints) > 0
	}

	// ReqTimeout returns timeout for request to finish.
	func (c *ServerConfig) ReqTimeout() time.Duration {
	// 5s for queue waiting, computation and disk IO delay
	// + 2 * election timeout for possible leader election
	return 5time.Second + 2time.Duration(c.ElectionTicksint(c.TickMs))time.Millisecond
	}

	func (c *ServerConfig) ElectionTimeout() time.Duration {
	return time.Duration(c.ElectionTicksint(c.TickMs)) time.Millisecond
	}

	func (c *ServerConfig) PeerDialTimeout() time.Duration {
	// 1s for queue wait and election timeout
	return time.Second + time.Duration(c.ElectionTicksint(c.TickMs))time.Millisecond
	}

	func CheckDuplicateURL(urlsmap types.URLsMap) bool {
	um := make(map[string]bool)
	for _, urls := range urlsmap {
	for _, url := range urls {
	u := url.String()
	if um[u] {
	return true
	}
	um[u] = true
	}
	}
	return false
	}

	func (c *ServerConfig) BootstrapTimeoutEffective() time.Duration {
	if c.BootstrapTimeout != 0 {
	return c.BootstrapTimeout
	}
	return time.Second
	}

	func (c *ServerConfig) BackendPath() string { return datadir.ToBackendFileName(c.DataDir) }

	func (c *ServerConfig) MaxRequestBytesWithOverhead() uint {
	return c.MaxRequestBytes + grpcOverheadBytes
	}