- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for secretHandler (0.12 sec)
-
pilot/pkg/config/kube/gateway/controller.go
namespaceHandler model.EventHandler // Gateway-api types reference secrets directly, so we need access to these credentialsController credentials.MulticlusterController secretHandler model.EventHandler // the cluster where the gateway-api controller runs cluster cluster.ID // domain stores the cluster domain, typically cluster.local domain string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
security/pkg/nodeagent/cache/secretcache.go
sc.certMutex.Lock() defer sc.certMutex.Unlock() sc.secretHandler = h } func (sc *SecretManagerClient) OnSecretUpdate(resourceName string) { sc.certMutex.RLock() defer sc.certMutex.RUnlock() if sc.secretHandler != nil { sc.secretHandler(resourceName) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 04 08:29:46 UTC 2024 - 28.2K bytes - Viewed (0) -
pilot/pkg/credentials/kube/multicluster.go
} func (m *Multicluster) AddSecretHandler(h func(name string, namespace string)) { // Intentionally no lock. The controller today requires that handlers are registered before execution and not in parallel. m.secretHandlers = append(m.secretHandlers, h) } type AggregateController struct { // controllers to use to look up certs. Generally this will consistent of the primary (config) cluster // and a single remote cluster where the proxy resides
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 4.2K bytes - Viewed (0) -
pkg/adsc/delta_test.go
}) secretsHandler := Register(func(ctx HandlerContext, resourceName string, resourceVersion string, resourceEntity *tls.Secret, event Event) { }) handlers := []Option{ clusterHandler, Watch[*cluster.Cluster]("*"), listenerHandler, Watch[*listener.Listener]("*"), endpointsHandler, routesHandler, secretsHandler, } descs := []struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/adsc/delta.go
// // handlers := []Option{ // clusterHandler, // Watch[*cluster.Cluster]("*"), // listenerHandler, // Watch[*listener.Listener]("*"), // endpointsHandler, // routesHandler, // secretsHandler, // } // // client := NewDelta("localhost:8080", handlers...) // // It means that the client will watch all clusters and listeners, and trigger resource events for
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 20.4K bytes - Viewed (0)