- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 762 for Cfg (0.59 sec)
-
internal/config/etcd/etcd.go
} // New - initialize new etcd client. func New(cfg Config) (*clientv3.Client, error) { if !cfg.Enabled { return nil, nil } cli, err := clientv3.New(cfg.Config) if err != nil { return nil, err } cli.KV = namespace.NewKV(cli.KV, cfg.PathPrefix) cli.Watcher = namespace.NewWatcher(cli.Watcher, cfg.PathPrefix) cli.Lease = namespace.NewLease(cli.Lease, cfg.PathPrefix) return cli, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.8K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/udp.go
return &udpProtocol{e: e} } func (c *udpProtocol) ForwardEcho(ctx context.Context, cfg *Config) (*proto.ForwardEchoResponse, error) { return doForward(ctx, cfg, c.e, c.makeRequest) } func (c *udpProtocol) makeRequest(ctx context.Context, cfg *Config, requestID int) (string, error) { conn, err := newUDPConnection(cfg) if err != nil { return "", err } defer func() { _ = conn.Close() }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 17:19:22 UTC 2022 - 3.4K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/ctrlflow/ctrlflow.go
type declInfo struct { decl *ast.FuncDecl cfg *cfg.CFG // iff decl.Body != nil started bool // to break cycles noReturn bool } type litInfo struct { cfg *cfg.CFG noReturn bool } // FuncDecl returns the control-flow graph for a named function. // It returns nil if decl.Body==nil. func (c *CFGs) FuncDecl(decl *ast.FuncDecl) *cfg.CFG { if decl.Body == nil { return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 09 01:28:01 UTC 2023 - 6.6K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/types.gen.go
Spec: *(cfg.Spec.(*istioioapinetworkingv1alpha3.WorkloadGroup)), }, metav1.UpdateOptions{}) default: return nil, fmt.Errorf("unsupported type: %v", cfg.GroupVersionKind) } } func updateStatus(c kube.Client, cfg config.Config, objMeta metav1.ObjectMeta) (metav1.Object, error) { switch cfg.GroupVersionKind { case gvk.AuthorizationPolicy:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 17:37:32 UTC 2024 - 62.2K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/instance.go
} // New creates a new endpoint Instance. func New(cfg Config) (Instance, error) { if cfg.Port != nil { switch cfg.Port.Protocol { case protocol.HBONE: return newHBONE(cfg), nil case protocol.HTTP, protocol.HTTPS: return newHTTP(cfg), nil case protocol.HTTP2, protocol.GRPC: return newGRPC(cfg), nil case protocol.TCP: return newTCP(cfg), nil case protocol.UDP: return newUDP(cfg), nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 16:20:31 UTC 2023 - 2.1K bytes - Viewed (0) -
cmd/kubeadm/app/images/images.go
func GetKubernetesImage(image string, cfg *kubeadmapi.ClusterConfiguration) string { repoPrefix := cfg.GetControlPlaneImageRepository() kubernetesImageTag := kubeadmutil.KubernetesVersionToImageTag(cfg.KubernetesVersion) return GetGenericImage(repoPrefix, image, kubernetesImageTag) } // GetDNSImage generates and returns the image for CoreDNS. func GetDNSImage(cfg *kubeadmapi.ClusterConfiguration) string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 06:33:37 UTC 2023 - 4.8K bytes - Viewed (0) -
internal/config/notify/config.go
Elasticsearch: make(map[string]target.ElasticsearchArgs), } cfg.NSQ[defaultTarget] = target.NSQArgs{} cfg.AMQP[defaultTarget] = target.AMQPArgs{} cfg.MQTT[defaultTarget] = target.MQTTArgs{} cfg.NATS[defaultTarget] = target.NATSArgs{} cfg.Redis[defaultTarget] = target.RedisArgs{} cfg.MySQL[defaultTarget] = target.MySQLArgs{} cfg.Kafka[defaultTarget] = target.KafkaArgs{} cfg.Webhook[defaultTarget] = target.WebhookArgs{}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 2.8K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/client.go
cfg, err := clientConfigFn() if err != nil { return nil, err } if negotiatedSerializer != nil { cfg.ContentConfig.NegotiatedSerializer = negotiatedSerializer } cfg.GroupVersion = &gv if len(gv.Group) == 0 { cfg.APIPath = "/api" } else { cfg.APIPath = "/apis" } return rest.RESTClientFor(cfg) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:01:18 UTC 2021 - 2.1K bytes - Viewed (0) -
src/cmd/go/internal/work/init.go
} if cfg.BuildBuildmode != "default" && !platform.BuildModeSupported(cfg.BuildToolchainName, cfg.BuildBuildmode, cfg.Goos, cfg.Goarch) { base.Fatalf("-buildmode=%s not supported on %s/%s\n", cfg.BuildBuildmode, cfg.Goos, cfg.Goarch) } if cfg.BuildLinkshared { if !platform.BuildModeSupported(cfg.BuildToolchainName, "shared", cfg.Goos, cfg.Goarch) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 28 19:13:34 UTC 2023 - 12.2K bytes - Viewed (0) -
src/net/tcpconn_keepalive_solaris_test.go
cfg.Interval = oldCfg.Interval cfg.Count = oldCfg.Count case cfg.Interval == -1 && cfg.Count > 0: cfg.Interval = defaultTcpKeepAliveAbortThreshold / time.Duration(cfg.Count) case cfg.Count == -1 && cfg.Interval > 0: cfg.Count = int(defaultTcpKeepAliveAbortThreshold / cfg.Interval) case cfg.Interval > 0 && cfg.Count > 0: // TCP_KEEPALIVE_ABORT_THRESHOLD will be recalculated only when both TCP_KEEPINTVL
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 5.7K bytes - Viewed (0)