- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 173 for clientV3 (0.14 sec)
-
src/net/rpc/jsonrpc/client.go
return c.c.Close() } // NewClient returns a new [rpc.Client] to handle requests to the // set of services at the other end of the connection. func NewClient(conn io.ReadWriteCloser) *rpc.Client { return rpc.NewClientWithCodec(NewClientCodec(conn)) } // Dial connects to a JSON-RPC server at the specified network address. func Dial(network, address string) (*rpc.Client, error) { conn, err := net.Dial(network, address)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/client.go
limitations under the License. */ package resource import ( "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/client-go/rest" ) // TODO require negotiatedSerializer. leaving it optional lets us plumb current behavior and deal with the difference after major plumbing is complete
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:01:18 UTC 2021 - 2.1K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/client.go
"google.golang.org/grpc/credentials/insecure" "k8s.io/cri-client/pkg/util" "k8s.io/kubelet/pkg/apis/podresources/v1" "k8s.io/kubelet/pkg/apis/podresources/v1alpha1" ) // Note: Consumers of the pod resources API should not be importing this package. // They should copy paste the function in their project. // GetV1alpha1Client returns a client for the PodResourcesLister grpc service // Note: This is deprecated
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 2.5K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/client.go
func NewPluginClient(r string, socketPath string, h ClientHandler) Client { return &client{ resource: r, socket: socketPath, handler: h, } } // Connect is for establishing a gRPC connection between device manager and device plugin. func (c *client) Connect() error { client, conn, err := dial(c.socket) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 21:35:13 UTC 2023 - 3.8K bytes - Viewed (0) -
samples/tlssurvey/src/main/kotlin/okhttp3/survey/types/Client.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.survey.types data class Client( val userAgent: String, val version: String, val platform: String? = null, val enabled: List<SuiteId> = listOf(), val supported: List<SuiteId> = listOf(), ) { val nameAndVersion: String
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Apr 02 01:44:15 UTC 2024 - 883 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/client.go
if err != nil { return nil, err } if client, ok := cm.cache.Get(string(cacheKey)); ok { return client.(*rest.RESTClient), nil } cfg, err := cm.hookClientConfig(cc) if err != nil { return nil, err } client, err := rest.UnversionedRESTClientFor(cfg) if err == nil { cm.cache.Add(string(cacheKey), client) } return client, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 09:09:10 UTC 2024 - 7.3K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
Xiaopeng Han <******@****.***> 1703025762 +0800
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/test/loadbalancersim/mesh/client.go
) type ClientSettings struct { RPS int Locality locality.Instance } type Client struct { mesh *Instance s ClientSettings } func (c *Client) Mesh() *Instance { return c.mesh } func (c *Client) Locality() locality.Instance { return c.s.Locality } func (c *Client) SendRequests(conn network.Connection, numRequests int, done func()) { go func() { wg := sync.WaitGroup{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 03 18:19:25 UTC 2022 - 1.5K bytes - Viewed (0) -
pkg/test/echo/client.go
if err != nil { return nil, err } client := proto.NewEchoTestServiceClient(conn) return &Client{ conn: conn, client: client, }, nil } // Close the EchoClient and free any resources. func (c *Client) Close() error { if c.conn != nil { return c.conn.Close() } return nil } func (c *Client) Echo(ctx context.Context, request *proto.EchoRequest) (Response, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 4.1K bytes - Viewed (0) -
internal/config/identity/openid/providercfg.go
} req.Header.Set("Content-Type", "application/x-www-form-urlencoded") if accessToken != "" { req.Header.Set("Authorization", "Bearer "+accessToken) } client := &http.Client{ Transport: transport, } resp, err := client.Do(req) if err != nil { return nil, err } defer xhttp.DrainBody(resp.Body) if resp.StatusCode != http.StatusOK { // uncomment this for debugging when needed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0)