- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 405 for CLIENT (0.1 sec)
-
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) -
cmd/storage-rest-client.go
func (client *storageRESTClient) String() string { return client.endpoint.String() } // IsOnline - returns whether client failed to connect or not. func (client *storageRESTClient) IsOnline() bool { return client.restClient.IsOnline() || client.IsOnlineWS() } // IsOnlineWS - returns whether websocket client failed to connect or not. func (client *storageRESTClient) IsOnlineWS() bool {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/integTest/groovy/org/gradle/internal/remote/UnicastMessagingIntegrationTest.groovy
} start { client.addIncoming(clientService) client.setupOutgoingService1() client.setupOutgoingService2() client.connection.connect() client.outgoingService1.doStuff("from client 1") client.outgoingService1.doStuff("from client 2") } received.await() client.stop() server.stop() then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 09:21:43 UTC 2024 - 8.9K bytes - Viewed (0) -
staging/publishing/import-restrictions.yaml
- "./staging/src/k8s.io/client-go/tools/record" - "./staging/src/k8s.io/client-go/tools/events" - "./staging/src/k8s.io/client-go/tools/reference" - "./staging/src/k8s.io/client-go/tools/remotecommand" allowedImports: - k8s.io/apimachinery - k8s.io/client-go - k8s.io/klog - k8s.io/utils - baseImportPath: "./staging/src/k8s.io/apiserver" allowedImports: - k8s.io/api
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 13:13:22 UTC 2024 - 7.7K bytes - Viewed (0) -
src/crypto/tls/bogo_config.json
"TLS-ECH-Client-Reject-EarlyDataRejected": "We don't support switiching out ECH configs with this level of granularity", "TLS-ECH-Client-NoNPN": "We don't support NPN", "TLS-ECH-Client-ChannelID": "We don't support sending channel ID", "TLS-ECH-Client-Reject-NoChannelID-TLS13": "We don't support sending channel ID",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 15:52:42 UTC 2024 - 19.3K bytes - Viewed (0) -
platforms/core-execution/workers/src/test/groovy/org/gradle/workers/internal/WorkerDaemonFactoryTest.groovy
then: 1 * clientsManager.reserveNewClient(options) >> client then: 1 * buildOperationRunner.call(_) >> { args -> args[0].call(Stub(BuildOperationContext)) } 1 * client.execute(spec) >> new DefaultWorkResult(true, null) then: 1 * clientsManager.release(client) } def "idle client is reused when daemon is executed"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 19:57:50 UTC 2024 - 4K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
client.RunAndWait(ctx.Done()) go handlers.Start() waitForMockCalls() // wait until pod add was called mt.Assert(EventTotals.Name(), map[string]string{"type": "add"}, monitortest.AtLeast(1)) assertPodAnnotated(t, client, pod) // check expectations on mocked calls fs.AssertExpectations(t) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/example.go
limitations under the License. */ // Code generated by client-gen. DO NOT EDIT. package v1 import ( "context" json "encoding/json" "fmt" "time" v1 "k8s.io/apiextensions-apiserver/examples/client-go/pkg/apis/cr/v1" crv1 "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/applyconfiguration/cr/v1" scheme "k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/scheme"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 8.6K bytes - Viewed (0) -
staging/publishing/rules.yaml
dirs: - staging/src/k8s.io/api library: true - destination: client-go branches: - name: master dependencies: - repository: apimachinery branch: master - repository: api branch: master source: branch: master dirs: - staging/src/k8s.io/client-go smoke-test: | # assumes GO111MODULE=on go build -mod=mod ./...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 09:33:40 UTC 2024 - 57.6K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
}, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "funkyns"}} client := kube.NewFakeClient(ns, pod, podOutOfAmbient) wg, _ := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} dpServer := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, dpServer, "istio-system")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 7.6K bytes - Viewed (0)