- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 366 for connectedAt (0.15 sec)
-
pilot/pkg/xds/debug.go
adsClients.Total = len(connections) for _, c := range connections { adsClient := AdsClient{ ConnectionID: c.ID(), ConnectedAt: c.ConnectedAt(), PeerAddress: c.Peer(), } adsClients.Connected = append(adsClients.Connected, adsClient) } writeJSON(w, adsClients, req) } // adsz implements a status and debug interface for ADS. // It is mapped to /debug/adsz
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
pkg/xds/server.go
} func (conn *Connection) Peer() string { return conn.peerAddr } func (conn *Connection) SetID(id string) { conn.conID = id } func (conn *Connection) ConnectedAt() time.Time { return conn.connectedAt } func (conn *Connection) Stop() { close(conn.stop) } func (conn *Connection) MarkInitialized() { close(conn.initialized) }
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/autoregistration/controller.go
} proxy.SetWorkloadEntry(entryName, autoCreate) c.adsConnections.Connect(conn) err := c.onWorkloadConnect(entryName, proxy, conn.ConnectedAt(), autoCreate) if err != nil { log.Error(err) } return err } // ensureProxyCanControlEntry ensures the connected proxy's identity matches that of the WorkloadEntry it is associating with. func ensureProxyCanControlEntry(proxy *model.Proxy, wle *config.Config) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
pilot/pkg/autoregistration/connections.go
// This interface exists to avoid circular reference to xds.Connection as well // as keeps the API surface scoped to what we need for auto-registration logic. type connection interface { ID() string Proxy() *model.Proxy ConnectedAt() time.Time Stop() } // a single proxy may have multiple connections, so we track them here // when a WorkloadGroup is deleted, we can force disconnects
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3K bytes - Viewed (0) -
tests/fuzz/autoregistration_controller_fuzzer.go
} func (f *fakeConn) ID() string { return fmt.Sprintf("%s-%v", f.proxy.IPAddresses[0], f.connTime) } func (f *fakeConn) Proxy() *model.Proxy { return f.proxy } func (f *fakeConn) ConnectedAt() time.Time { return f.connTime } func (f *fakeConn) Stop() { f.stopped = true } var ( // A valid WorkloadGroup. // This can be modified to have pseudo-random // values for more randomization.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3.4K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
} // check controller annotations if connectedTo != "" { if v := cfg.Annotations[annotation.IoIstioWorkloadController.Name]; v != connectedTo { err = multierror.Append(err, fmt.Errorf("expected WorkloadEntry to be updated by %s; got %s", connectedTo, v)) } if _, ok := cfg.Annotations[annotation.IoIstioConnectedAt.Name]; !ok {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/main/java/org/gradle/api/internal/tasks/userinput/UserQuestions.java
* * @param question The text of the question. * @param defaultValue The option to present to the user as the default choice, and the value to use when not connected to a console * @return the answer or the given default if not connected to a console. */ boolean askBooleanQuestion(String question, boolean defaultValue); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 3.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
assertEvents( "plan 1 TCP connected", "plan 0 cancel", "plan 1 TLS connecting...", "plan 1 TLS connected", "plan 2 TCP connecting...", ) taskFaker.advanceUntil(270.ms) assertEvents( "plan 0 TCP connect canceled", ) taskFaker.advanceUntil(280.ms) assertEvents( "plan 2 TCP connected", "plan 2 TLS connecting...",
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 20.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTree.java
import jcifs.smb1.Config; import jcifs.smb1.UniAddress; import jcifs.smb1.netbios.NbtAddress; class SmbTree { private static int tree_conn_counter; /* 0 - not connected * 1 - connecting * 2 - connected * 3 - disconnecting */ int connectionState; int tid; String share; String service = "?????"; String service0; SmbSession session;
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 8K bytes - Viewed (0) -
internal/rest/client.go
func (c *Client) Close() { atomic.StoreInt32(&c.connected, closed) } // NewClient - returns new REST client. func NewClient(uu *url.URL, tr http.RoundTripper, newAuthToken func(aud string) string) *Client { connected := int32(online) urlStr := uu.String() u, err := url.Parse(urlStr) if err != nil { // Mark offline, with no reconnection attempts. connected = int32(offline) err = &url.Error{URL: urlStr, Err: err}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0)