- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Codec (0.13 sec)
-
istioctl/pkg/util/handlers/handlers_test.go
case p == "/namespaces/istio-system/deployments/foo" && m == "GET": body := cmdtesting.ObjBody(codec, attachDeploy("istio-system")) return &http.Response{StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: body}, nil case p == "/namespaces/test/deployments/foo" && m == "GET": body := cmdtesting.ObjBody(codec, attachDeploy("test"))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 18:17:49 GMT 2023 - 6.6K bytes - Viewed (0) -
istioctl/pkg/internaldebug/internal-debug_test.go
tf := cmdtesting.NewTestFactory() _, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer, Resp: &http.Response{ StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: cmdtesting.ObjBody(codec, cmdtesting.NewInternalType("", "", "foo")), }, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 4.5K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
"istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/config/labels" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/multicluster" "istio.io/istio/pkg/log" ) var ( codec runtime.Codec scheme *runtime.Scheme tokenWaitBackoff = time.Second ) func init() { scheme = runtime.NewScheme() utilruntime.Must(v1.AddToScheme(scheme)) opt := json.SerializerOptions{ Yaml: true,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
case errLockConflict.Error(): return errLockConflict case errLockNotFound.Error(): return errLockNotFound } return err } // Call makes a REST call to the remote endpoint using the msgp codec func (restClient *ReconnectRESTClient) Call(method string, args LockArgs) (status bool, err error) { buf, err := args.MarshalMsg(nil) if err != nil { return false, err } body := bytes.NewReader(buf)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 20 17:36:09 GMT 2022 - 4.4K bytes - Viewed (0) -
internal/event/target/kafka.go
KafkaClientTLSCert = "client_tls_cert" KafkaClientTLSKey = "client_tls_key" KafkaVersion = "version" KafkaBatchSize = "batch_size" KafkaCompressionCodec = "compression_codec" KafkaCompressionLevel = "compression_level" EnvKafkaEnable = "MINIO_NOTIFY_KAFKA_ENABLE" EnvKafkaBrokers = "MINIO_NOTIFY_KAFKA_BROKERS"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
istioctl/pkg/cli/mock_test.go
tf := cmdtesting.NewTestFactory() _, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer, Resp: &http.Response{ StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: cmdtesting.ObjBody(codec, cmdtesting.NewInternalType("", "", "foo")), }, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.3K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig_test.go
tf := cmdtesting.NewTestFactory() _, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer, Resp: &http.Response{ StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: cmdtesting.ObjBody(codec, cmdtesting.NewInternalType("", "", "foo")), }, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 3.8K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig_test.go
tf := cmdtesting.NewTestFactory() _, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer, Resp: &http.Response{ StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: cmdtesting.ObjBody(codec, cmdtesting.NewInternalType("", "", "foo")), }, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 8.9K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus_test.go
tf := cmdtesting.NewTestFactory() _, _, codec := cmdtesting.NewExternalScheme() tf.UnstructuredClient = &fake.RESTClient{ NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer, Resp: &http.Response{ StatusCode: http.StatusOK, Header: cmdtesting.DefaultHeader(), Body: cmdtesting.ObjBody(codec, cmdtesting.NewInternalType("", "", "foo")), }, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 5.5K bytes - Viewed (0) -
src/cmd/api/testdata/src/pkg/p1/p1.go
func Bar2(x int8, y int16, z int64) (uint8, uint64) {} func BarE() Error {} func unexported(x int8, y int16, z int64) {} func TakesFunc(f func(dontWantName int) int) type Codec struct { Func func(x int, y int) (z int) } type SI struct { I int } var SIVal = SI{} var SIPtr = &SI{} var SIPtr2 *SI type T struct { common } type B struct {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Dec 02 16:29:41 GMT 2022 - 3.3K bytes - Viewed (0)