- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 184 for iovecs (0.13 sec)
-
internal/event/target/kafka.go
EnvKafkaProducerCompressionCodec = "MINIO_NOTIFY_KAFKA_PRODUCER_COMPRESSION_CODEC" EnvKafkaProducerCompressionLevel = "MINIO_NOTIFY_KAFKA_PRODUCER_COMPRESSION_LEVEL" ) var codecs = map[string]sarama.CompressionCodec{ "none": sarama.CompressionNone, "gzip": sarama.CompressionGZIP, "snappy": sarama.CompressionSnappy, "lz4": sarama.CompressionLZ4, "zstd": sarama.CompressionZSTD, }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/controlplane/instance_test.go
server, storageConfig := etcd3testing.NewUnsecuredEtcd3TestClientServer(t) config := &Config{ ControlPlane: controlplaneapiserver.Config{ Generic: genericapiserver.NewConfig(legacyscheme.Codecs), Extra: controlplaneapiserver.Extra{ APIResourceConfigSource: DefaultAPIResourceConfigSource(), }, }, Extra: Extra{ APIServerServicePort: 443, MasterCount: 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/tensorflow/utils/tf_to_uniform_attribute_utils.cc
attrs.push_back(rewriter.getNamedAttr( attr_minmax, rewriter.getI64IntegerAttr(quant_val))); } } return success(); } // This LogicalResult covers both the hybrid and fully quantized op cases. LogicalResult FillAttributesForUniformQuantizedDotOp( PatternRewriter& rewriter, Operation* op, llvm::StringMap<Attribute>& identifier_to_attr,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 18.7K bytes - Viewed (0) -
pkg/apis/apps/v1beta1/defaults_test.go
} }) } } func roundTrip(t *testing.T, obj runtime.Object) runtime.Object { data, err := runtime.Encode(legacyscheme.Codecs.LegacyCodec(SchemeGroupVersion), obj) if err != nil { t.Errorf("%v\n %#v", err, obj) return nil } obj2, err := runtime.Decode(legacyscheme.Codecs.UniversalDecoder(), data) if err != nil { t.Errorf("%v\nData: %s\nSource: %#v", err, string(data), obj) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 17.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go
) var scheme = runtime.NewScheme() var codecs = runtimeserializer.NewCodecFactory(scheme) const discoveryPath = "/apis" func init() { utilruntime.Must(apidiscoveryv2.AddToScheme(scheme)) utilruntime.Must(apidiscoveryv2beta1.AddToScheme(scheme)) // Register conversion for apidiscovery utilruntime.Must(apidiscoveryv2conversion.RegisterConversions(scheme)) codecs = runtimeserializer.NewCodecFactory(scheme) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 28.6K bytes - Viewed (0) -
cmd/kube-scheduler/app/server.go
requestInfoResolver := &apirequest.RequestInfoFactory{} failedHandler := genericapifilters.Unauthorized(scheme.Codecs) handler = genericapifilters.WithAuthorization(handler, authz, scheme.Codecs) handler = genericapifilters.WithAuthentication(handler, authn, failedHandler, nil, nil) handler = genericapifilters.WithRequestInfo(handler, requestInfoResolver)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config_test.go
} } } } func TestNewWithDelegate(t *testing.T) { _, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancelCause(ctx) defer cancel(errors.New("test is done")) delegateConfig := NewConfig(codecs) delegateConfig.ExternalAddress = "192.168.10.4:443" delegateConfig.PublicAddress = netutils.ParseIPSloppy("192.168.10.4") delegateConfig.LegacyAPIGroupPrefixes = sets.NewString("/api")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 13.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/serving_test.go
cliflag "k8s.io/component-base/cli/flag" "k8s.io/klog/v2/ktesting" netutils "k8s.io/utils/net" ) func setUp(t *testing.T) server.Config { scheme := runtime.NewScheme() codecs := serializer.NewCodecFactory(scheme) config := server.NewConfig(codecs) return *config } type TestCertSpec struct { host string names, ips []string // in certificate } type NamedTestCertSpec struct { TestCertSpec
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 15:52:39 UTC 2024 - 13.8K bytes - Viewed (0) -
docs/pt/docs/alternatives.md
Isso acontece porquê quando alguém fala sobre a versão 2.0 é comum dizer "Swagger", e para a versão 3+, "OpenAPI". !!! check "**FastAPI** inspirado para" Adotar e usar um padrão aberto para especificações API, ao invés de algum esquema customizado. E integrar ferramentas de interface para usuários baseado nos padrões: * <a href="https://github.com/swagger-api/swagger-ui" class="external-link" target="_blank">Swagger UI</a>
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Fri Mar 22 01:42:11 UTC 2024 - 25.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/internal/passes/clustering_passes.td
} def XlaBroadcastPass : Pass<"tf-xla-broadcast", "mlir::func::FuncOp"> { let summary = "Moves a broadcast from host into XLA, encoded as XlaAllReduce"; let description = [{ This pass moves brodcasts from host TF ops into XLA. This enables use of the inter-device network, which is faster than the inter-host network.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 30 02:01:13 UTC 2024 - 19.8K bytes - Viewed (0)