- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for newConnections (0.32 sec)
-
internal/grid/manager.go
if host == o.Local { if found { return nil, fmt.Errorf("grid: local host found multiple times") } found = true // No connection to local. continue } m.targets[host] = newConnection(connectionParams{ ctx: ctx, id: m.ID, local: o.Local, remote: host, dial: o.Dialer, handlers: &m.handlers, auth: o.AddAuth,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 9.8K bytes - Viewed (0) -
internal/grid/connection.go
outgoingBytes func(n int64) // Record outgoing bytes. publisher *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType] blockConnect chan struct{} } // newConnection will create an unconnected connection to a remote. func newConnection(o connectionParams) *Connection { c := &Connection{ state: StateUnconnected, Remote: o.remote, Local: o.local,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
} // Else fallback based on type return xds.IsWildcardTypeURL(w.TypeUrl) } func newDeltaConnection(peerAddr string, stream DeltaDiscoveryStream) *Connection { return &Connection{ Connection: xds.NewConnection(peerAddr, nil), deltaStream: stream, deltaReqChan: make(chan *discovery.DeltaDiscoveryRequest, 1), } } // To satisfy methods that need DiscoveryRequest. Not suitable for real usage
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0)