- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for XdsConnection (0.17 sec)
-
security/pkg/nodeagent/sds/sdsservice.go
s.Lock() defer s.Unlock() for _, client := range s.clients { go func(client *Context) { select { case client.XdsConnection().PushCh() <- secretName: case <-client.XdsConnection().StreamDone(): } }(client) } } func (c *Context) XdsConnection() *xds.Connection { return &c.BaseConnection } var connectionNumber = int64(0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/xds/server.go
} func (conn *Connection) MarkInitialized() { close(conn.initialized) } // ConnectionContext is used by the RPC event loop to respond to requests and pushes. type ConnectionContext interface { XdsConnection() *Connection Watcher() Watcher // Initialize checks the first request. Initialize(node *core.Node) error // Close discards the connection. Close() // Process responds to a discovery request.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
deltaStream DeltaDiscoveryStream deltaReqChan chan *discovery.DeltaDiscoveryRequest s *DiscoveryServer ids []string } func (conn *Connection) XdsConnection() *xds.Connection { return &conn.Connection } func (conn *Connection) Proxy() *model.Proxy { return conn.proxy } // Event represents a config or registry event that results in a push.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0)