- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for WebSocket (0.2 sec)
-
cmd/storage-rest-client.go
if r != nil { readMsgpReaderPool.Put(r) } } func (client *storageRESTClient) ReadVersion(ctx context.Context, origvolume, volume, path, versionID string, opts ReadOptions) (fi FileInfo, err error) { // Use websocket when not reading data. if !opts.ReadData { resp, err := storageReadVersionRPC.Call(ctx, client.gridConn, grid.NewMSSWith(map[string]string{ storageRESTDiskID: *client.diskID.Load(),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
internal/grid/connection.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/endpoint.go
func (l EndpointServerPools) NEndpoints() (count int) { for _, ep := range l { count += len(ep.Endpoints) } return count } // GridHosts will return all peers, including local. // in websocket grid compatible format, The local peer // is returned as a separate string. func (l EndpointServerPools) GridHosts() (gridHosts []string, gridLocal string) { seenHosts := set.NewStringSet() for _, ep := range l {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0)