- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 3,531 for CLIENT (0.16 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/kube/client.go
"k8s.io/apiserver/pkg/storage/names" "k8s.io/client-go/discovery" fakediscovery "k8s.io/client-go/discovery/fake" "k8s.io/client-go/dynamic" dynamicfake "k8s.io/client-go/dynamic/fake" "k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes/fake" kubescheme "k8s.io/client-go/kubernetes/scheme" "k8s.io/client-go/metadata" metadatafake "k8s.io/client-go/metadata/fake" "k8s.io/client-go/rest" clienttesting "k8s.io/client-go/testing"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
src/net/http/client.go
"sync" "sync/atomic" "time" ) // A Client is an HTTP client. Its zero value ([DefaultClient]) is a // usable client that uses [DefaultTransport]. // // The [Client.Transport] typically has internal state (cached TCP // connections), so Clients should be reused instead of created as // needed. Clients are safe for concurrent use by multiple goroutines. // // A Client is higher-level than a [RoundTripper] (such as [Transport])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 06:06:11 UTC 2024 - 33.7K 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) -
src/cmd/vendor/golang.org/x/mod/sumdb/client.go
var ErrSecurity = errors.New("security error: misbehaving server") // A Client is a client connection to a checksum database. // All the methods are safe for simultaneous use by multiple goroutines. type Client struct { ops ClientOps // access to operations in the external world didLookup uint32 // one-time initialized data initOnce sync.Once
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 08 17:50:49 UTC 2024 - 19.1K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
} var _ model.ConfigStoreController = &Client{} func New(client kube.Client, opts Option) *Client { schemas := collections.Pilot if features.EnableGatewayAPI { schemas = collections.PilotGatewayAPI() } return NewForSchemas(client, opts, schemas) } func NewForSchemas(client kube.Client, opts Option, schemas collection.Schemas) *Client { schemasByCRDName := map[string]resource.Schema{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
internal/rest/client.go
func (n *NetworkError) Unwrap() error { return n.Err } // Client - http based RPC client. type Client struct { connected int32 // ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG _ int32 // For 64 bits alignment lastConn int64 // HealthCheckFn is the function set to test for health. // If not set the client will not keep track of health. // Calling this returns true or false if the target
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0)