- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 46 for ClusterID (0.17 sec)
-
pkg/kube/multicluster/clusterstore.go
c.clusters.Delete(string(clusterID)) if len(c.remoteClusters[secretKey]) == 0 { delete(c.remoteClusters, secretKey) } } func (c *ClusterStore) Get(secretKey string, clusterID cluster.ID) *Cluster { c.RLock() defer c.RUnlock() if _, ok := c.remoteClusters[secretKey]; !ok { return nil } return c.remoteClusters[secretKey][clusterID] }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 07 15:01:12 UTC 2023 - 3.6K bytes - Viewed (0) -
security/pkg/server/ca/authenticate/kubeauth/kube_jwt.go
func (a *KubeJWTAuthenticator) getKubeClient(clusterID cluster.ID) kubernetes.Interface { // first match local/primary cluster // or if clusterID is not sent (we assume that its a single cluster) if a.clusterID == clusterID || clusterID == "" { return a.kubeClient } // secondly try other remote clusters if a.remoteKubeClientGetter != nil { if res := a.remoteKubeClientGetter(clusterID); res != nil { return res } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5K bytes - Viewed (0) -
pilot/pkg/util/informermetric/informerutil.go
func ErrorHandlerForCluster(clusterID cluster.ID) cache.WatchErrorHandler { mu.RLock() handler, ok := handlers[clusterID] mu.RUnlock() if ok { return handler } mu.Lock() defer mu.Unlock() clusterMetric := errorMetric.With(clusterLabel.Value(clusterID.String())) h := func(_ *cache.Reflector, err error) { clusterMetric.Increment()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 1.6K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status_test.go
proxyID string clusterID string version string cdsSyncStatus status.ConfigStatus ldsSyncStatus status.ConfigStatus rdsSyncStatus status.ConfigStatus edsSyncStatus status.ConfigStatus ecdsSyncStatus status.ConfigStatus } func newXdsClientConfig(config clientConfigInput) *status.ClientConfig { meta := model.NodeMetadata{ ClusterID: cluster.ID(config.clusterID),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 6.5K bytes - Viewed (0) -
security/pkg/server/ca/authenticate/kubeauth/kube_jwt_test.go
}{ "No bearer token": { metadata: metadata.MD{ "clusterid": []string{primaryCluster}, "authorization": []string{ "Basic callername", }, }, expectedErrMsg: "target JWT extraction error: no bearer token exists in HTTP authorization header", }, "token not authenticated": { token: invlidToken, metadata: metadata.MD{ "clusterid": []string{primaryCluster}, "authorization": []string{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/mock/discovery_mock.go
"spiffe://cluster.local/ns/default/sa/foo-share", }, ClusterID: "", }) ReplicatedFooServiceV2 = MakeService(ServiceArgs{ Hostname: ReplicatedFooServiceName, Address: "10.3.0.1", ServiceAccounts: []string{ "spiffe://cluster.local/ns/default/sa/foo2", "spiffe://cluster.local/ns/default/sa/foo-share", }, ClusterID: "", })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 23 02:37:56 UTC 2022 - 2.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/mock/discovery_test.go
ServiceAccounts: []string{}, ClusterID: "cluster-1", }) HelloInstanceV0 := MakeIP(HelloService, 0) if HelloInstanceV0 != "10.1.1.0" { t.Fatalf("MakeIP() can not handle ip4 address.") } HelloService1 := MakeService(ServiceArgs{ Hostname: "hello.default.svc.cluster.local", Address: "asa", ServiceAccounts: []string{}, ClusterID: "cluster-1", })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 09 17:33:49 UTC 2023 - 1.6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/cloudproviders.go
} if cloud != nil && !cloud.HasClusterID() { if allowUntaggedCloud { logger.Info("Warning: detected a cluster without a ClusterID. A ClusterID will be required in the future. Please tag your cluster to avoid any future issues") } else { return nil, loopMode, fmt.Errorf("no ClusterID Found. A ClusterID is required for the cloud provider to function properly. This check can be bypassed by setting the allow-untagged-cloud option") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 18:16:32 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kube/multicluster/component.go
type Component[T ComponentConstraint] struct { mu sync.RWMutex constructor func(cluster *Cluster) T clusters map[cluster.ID]T } func (m *Component[T]) ForCluster(clusterID cluster.ID) *T { m.mu.RLock() defer m.mu.RUnlock() t, f := m.clusters[clusterID] if !f { return nil } return &t } func (m *Component[T]) All() []T { m.mu.RLock() defer m.mu.RUnlock() return maps.Values(m.clusters) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.4K bytes - Viewed (0) -
pilot/pkg/credentials/kube/multicluster.go
}) return m } func (m *Multicluster) ForCluster(clusterID cluster.ID) (credentials.Controller, error) { cc := m.component.ForCluster(clusterID) if cc == nil { return nil, fmt.Errorf("cluster %v is not configured", clusterID) } agg := &AggregateController{} agg.controllers = []*CredentialsController{} agg.authController = *cc if clusterID != m.configCluster {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 4.2K bytes - Viewed (0)