- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 938 for rwmutex (0.16 sec)
-
pkg/kubelet/cm/memorymanager/state/state_checkpoint.go
"k8s.io/klog/v2" "k8s.io/kubernetes/pkg/kubelet/checkpointmanager" "k8s.io/kubernetes/pkg/kubelet/checkpointmanager/errors" ) var _ State = &stateCheckpoint{} type stateCheckpoint struct { sync.RWMutex cache State policyName string checkpointManager checkpointmanager.CheckpointManager checkpointName string }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 16:05:48 UTC 2022 - 5.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service.go
) // The gRPC implementation for envelope.Service. type gRPCService struct { kmsClient kmsapi.KeyManagementServiceClient connection *grpc.ClientConn callTimeout time.Duration mux sync.RWMutex versionChecked bool } // NewGRPCService returns an envelope.Service which use gRPC to communicate the remote KMS provider.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 00:47:46 UTC 2023 - 4.4K bytes - Viewed (0) -
internal/logger/reqinfo.go
Region string `json:"-"` Owner bool `json:"-"` AuthType string `json:"-"` tags []KeyVal // Any additional info not accommodated by above fields sync.RWMutex } // NewReqInfo : func NewReqInfo(remoteHost, userAgent, deploymentID, requestID, api, bucket, object string) *ReqInfo { return &ReqInfo{ RemoteHost: remoteHost, UserAgent: userAgent,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/configuration/configuration_manager.go
// if the configuration is regarded as ready. ready bool mergedConfiguration runtime.Object lastErr error // lock must be hold when reading/writing the data fields of poller. lock sync.RWMutex } func newPoller(get getFunc) *poller { p := poller{ get: get, interval: defaultInterval, failureThreshold: defaultFailureThreshold,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 06 02:02:38 UTC 2017 - 4.3K bytes - Viewed (0) -
internal/config/lambda/event/targetlist.go
type TargetStat struct { ID TargetID ActiveRequests int64 TotalRequests int64 FailedRequests int64 } // TargetList - holds list of targets indexed by target ID. type TargetList struct { sync.RWMutex targets map[TargetID]Target } // Add - adds unique target to target list. func (list *TargetList) Add(targets ...Target) error { list.Lock() defer list.Unlock() for _, target := range targets {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Mar 07 16:12:41 UTC 2023 - 4.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/index.go
return &index{ keyFunc: indexKey, keyToInstance: make(map[string]*model.WorkloadInstance), ipToKeys: make(MultiValueMap), } } // index implements Index. type index struct { mu sync.RWMutex // key function keyFunc func(*model.WorkloadInstance) string // map of namespace/name -> workload instance keyToInstance map[string]*model.WorkloadInstance // map of ip -> set of namespace/name
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 16 05:45:36 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/kubelet/container/testing/os.go
MkdirAllFn func(string, os.FileMode) error SymlinkFn func(string, string) error GlobFn func(string, string) bool HostName string Removes []string Files map[string][]*os.FileInfo FilesLock sync.RWMutex } // Mkdir is a fake call that just returns nil. func (f *FakeOS) MkdirAll(path string, perm os.FileMode) error { if f.MkdirAllFn != nil { return f.MkdirAllFn(path, perm) } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 07 13:37:31 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/kubelet/cm/dra/state/state_checkpoint.go
PodUIDs sets.Set[string] // CDIDevices is a map of DriverName --> CDI devices returned by the // GRPC API call NodePrepareResource CDIDevices map[string][]string } type stateCheckpoint struct { sync.RWMutex checkpointManager checkpointmanager.CheckpointManager checkpointName string } // NewCheckpointState creates new State for keeping track of claim info with checkpoint backend
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:27 UTC 2024 - 4.3K bytes - Viewed (0) -
pilot/pkg/config/memory/store.go
data map[config.GroupVersionKind]map[string]map[string]any skipValidation bool mutex sync.RWMutex } func (cr *store) Schemas() collection.Schemas { return cr.schemas } func (cr *store) Get(kind config.GroupVersionKind, name, namespace string) *config.Config { cr.mutex.RLock() defer cr.mutex.RUnlock() _, ok := cr.data[kind] if !ok { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 26 01:14:27 UTC 2023 - 6.3K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
Cache map[string]*BucketReplicationStats mostRecentStats BucketStatsMap registry metrics.Registry sync.RWMutex // mutex for Cache mostRecentStatsMu sync.Mutex // mutex for mostRecentStats wlock sync.RWMutex // mutex for active workers movingAvgTicker *time.Ticker // Ticker for calculating moving averages wTimer *time.Ticker // ticker for calculating active workers
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.4K bytes - Viewed (0)