- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 4,553 for CLIENT (0.14 sec)
-
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) -
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) -
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/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) -
pkg/kube/kclient/client.go
type Filter = kubetypes.Filter // New returns a Client for the given type. // Internally, this uses a shared informer, so calling this multiple times will share the same internals. func New[T controllers.ComparableObject](c kube.Client) Client[T] { return NewFiltered[T](c, Filter{}) } // NewFiltered returns a Client with some filter applied.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K 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/kubelet/cm/dra/plugin/client.go
Patrick Ohly <******@****.***> 1712753446 +0200
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 2.9K 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/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) -
docs/sts/client-grants.py
with open('/etc/hosts', 'rb') as data: s3.meta.client.upload_fileobj(data, 'testbucket', 'hosts', ExtraArgs={'ServerSideEncryption': 'AES256'}) # Upload with server side encryption, using temporary credentials s3.meta.client.upload_file('/etc/hosts', 'testbucket',
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 1.2K bytes - Viewed (0)