- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 938 for rwmutex (0.13 sec)
-
internal/config/subnet/config.go
Proxy string `json:"proxy"` // Transport configured with proxy_url if set optionally. transport http.RoundTripper // The subnet base URL BaseURL string } var configLock sync.RWMutex // Registered indicates if cluster is registered or not func (c *Config) Registered() bool { configLock.RLock() defer configLock.RUnlock() return len(c.APIKey) > 0 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/fake.go
} // a resource manager which instead of managing a discovery document, // simply records the calls to its interface functoins for testing type recorderResourceManager struct { lock sync.RWMutex Actions []recorderResourceManagerAction } var _ ResourceManager = &fakeResourceManager{} var _ ResourceManager = &recorderResourceManager{} // Storage type for a call to the resource manager
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 4.4K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection.go
// This is mostly just for testing cycle *atomic.Int32 electionID string // Store as field for testing le *k8sleaderelection.LeaderElector mu sync.RWMutex } // Run will start leader election, calling all runFns when we become the leader. // If leader election is disabled, it skips straight to the runFns. func (l *LeaderElection) Run(stop <-chan struct{}) { if !l.enabled {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 9.7K bytes - Viewed (0) -
security/pkg/credentialfetcher/plugin/gce.go
// identity provider identityProvider string // token refresh rotationTicker *time.Ticker closing chan bool tokenCache string // mutex lock is required to avoid race condition when updating token file and token cache. tokenMutex sync.RWMutex } // CreateGCEPlugin creates a Google credential fetcher plugin. Return the pointer to the created plugin.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/ready.go
type ready struct { state status // represent the state of the variable generation int // represent the number of times we have transtioned to ready lock sync.RWMutex // protect the state and generation variables restartLock sync.Mutex // protect the transition from ready to pending where the channel is recreated waitCh chan struct{} // blocks until is ready or stopped } func newReady() *ready {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 16 13:32:11 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/security/mock.go
"istio.io/istio/pkg/log" "istio.io/istio/pkg/spiffe" "istio.io/istio/pkg/util/sets" "istio.io/istio/security/pkg/pki/util" ) type DirectSecretManager struct { items map[string]*SecretItem mu sync.RWMutex } var _ SecretManager = &DirectSecretManager{} func NewDirectSecretManager() *DirectSecretManager { return &DirectSecretManager{ items: map[string]*SecretItem{}, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/kubelet/prober/results/results_manager.go
type Update struct { ContainerID kubecontainer.ContainerID Result Result PodUID types.UID } // Manager implementation. type manager struct { // guards the cache sync.RWMutex // map of container ID -> probe Result cache map[kubecontainer.ContainerID]Result // channel of updates updates chan Update } var _ Manager = &manager{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 13 07:12:54 UTC 2019 - 3.4K bytes - Viewed (0) -
pkg/kube/multicluster/clusterstore.go
import ( "sync" "istio.io/istio/pkg/cluster" "istio.io/istio/pkg/log" "istio.io/istio/pkg/util/sets" ) // ClusterStore is a collection of clusters type ClusterStore struct { sync.RWMutex // keyed by secret key(ns/name)->clusterID remoteClusters map[string]map[cluster.ID]*Cluster clusters sets.String } // newClustersStore initializes data struct to store clusters information
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 07 15:01:12 UTC 2023 - 3.6K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/cache/actual_state_of_world.go
// socketFileToInfo is a map containing the set of successfully registered plugins // The keys are plugin socket file paths. The values are PluginInfo objects socketFileToInfo map[string]PluginInfo sync.RWMutex } var _ ActualStateOfWorld = &actualStateOfWorld{} // PluginInfo holds information of a plugin type PluginInfo struct { SocketPath string Timestamp time.Time Handler PluginHandler
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 24 21:20:24 UTC 2022 - 4.1K bytes - Viewed (0) -
internal/event/targetlist.go
currentSendCalls atomic.Int64 totalEvents atomic.Int64 eventsSkipped atomic.Int64 eventsErrorsTotal atomic.Int64 sync.RWMutex targets map[TargetID]Target queue chan asyncEvent ctx context.Context statLock sync.RWMutex targetStats map[TargetID]targetStat } type targetStat struct { // The number of concurrent async Send calls per targets currentSendCalls int64
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0)