- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,774 for CLIENT (0.11 sec)
-
security/pkg/nodeagent/caclient/providers/citadel/client.go
) const ( bearerTokenPrefix = "Bearer " ) var citadelClientLog = log.RegisterScope("citadelclient", "citadel client debugging") type CitadelClient struct { // It means enable tls connection to Citadel if this is not nil. tlsOpts *TLSOptions client pb.IstioCertificateServiceClient conn *grpc.ClientConn provider credentials.PerRPCCredentials opts *security.Options }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 4.9K bytes - Viewed (0) -
pkg/controller/podautoscaler/metrics/client.go
customapi "k8s.io/metrics/pkg/apis/custom_metrics/v1beta2" metricsapi "k8s.io/metrics/pkg/apis/metrics/v1beta1" resourceclient "k8s.io/metrics/pkg/client/clientset/versioned/typed/metrics/v1beta1" customclient "k8s.io/metrics/pkg/client/custom_metrics" externalclient "k8s.io/metrics/pkg/client/external_metrics" ) const ( metricServerDefaultMetricWindow = time.Minute )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 16 20:17:52 UTC 2023 - 7.8K bytes - Viewed (0) -
src/net/rpc/client.go
Close() error } func (client *Client) send(call *Call) { client.reqMutex.Lock() defer client.reqMutex.Unlock() // Register this call. client.mutex.Lock() if client.shutdown || client.closing { client.mutex.Unlock() call.Error = ErrShutdown call.done() return } seq := client.seq client.seq++ client.pending[seq] = call client.mutex.Unlock() // Encode and send the request.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9K bytes - Viewed (0) -
fess-crawler-lasta/src/main/resources/crawler/client.xml
<property name="charset">"UTF-8"</property> </component> <component name="crawlerClientCreator" class="org.codelibs.fess.crawler.client.CrawlerClientCreator"> </component> <component name="clientFactory" class="org.codelibs.fess.crawler.client.CrawlerClientFactory" instance="prototype"> <postConstruct name="addClient"> <arg>["http:.*", "https:.*"]</arg>
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Tue Aug 08 12:54:47 UTC 2023 - 2.8K 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) -
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/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)