- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for newKube (0.2 sec)
-
pkg/test/framework/components/zipkin/zipkin.go
type Trace struct { Spans []Span } // New returns a new instance of zipkin. func New(ctx resource.Context, c Config) (i Instance, err error) { return newKube(ctx, c) } // NewOrFail returns a new zipkin instance or fails test. func NewOrFail(t *testing.T, ctx resource.Context, c Config) Instance { t.Helper() i, err := New(ctx, c) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 23 01:09:12 UTC 2021 - 2K bytes - Viewed (0) -
pkg/test/framework/components/gcemetadata/gcemetadata.go
// Cluster to be used in a multicluster environment Cluster cluster.Cluster } // New returns a new instance of stackdriver. func New(ctx resource.Context, c Config) (i Instance, err error) { return newKube(ctx, c) } // NewOrFail returns a new GCE Metadata Server instance or fails test. func NewOrFail(t test.Failer, ctx resource.Context, c Config) Instance { t.Helper() i, err := New(ctx, c) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/test/framework/components/prometheus/prometheus.go
// If true, connect to an existing prometheus rather than creating a new one SkipDeploy bool } // New returns a new instance of prometheus. func New(ctx resource.Context, c Config) (i Instance, err error) { return newKube(ctx, c) } // NewOrFail returns a new Prometheus instance or fails test. func NewOrFail(t test.Failer, ctx resource.Context, c Config) Instance { t.Helper() i, err := New(ctx, c) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 02 02:57:50 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/test/framework/components/istioctl/istioctl.go
// Cluster to be used in a multicluster environment Cluster cluster.Cluster } // New returns a new instance of "istioctl". func New(ctx resource.Context, cfg Config) (i Instance, err error) { return newKube(ctx, cfg) } // NewOrFail returns a new instance of "istioctl". func NewOrFail(t test.Failer, c resource.Context, config Config) Instance { i, err := New(c, config) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 14 22:20:09 UTC 2022 - 1.9K bytes - Viewed (0) -
pkg/test/framework/components/registryredirector/registryredirector.go
Image string } // New returns a new instance of registry redirector. func New(ctx resource.Context, c Config) (i Instance, err error) { return newKube(ctx, c) } // NewOrFail returns a new registry redirector instance or fails test. func NewOrFail(t test.Failer, ctx resource.Context, c Config) Instance { t.Helper() i, err := New(ctx, c) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 12 04:46:04 UTC 2022 - 2K bytes - Viewed (0) -
pkg/test/framework/components/gcemetadata/kube.go
_ io.Closer = &kubeComponent{} ) type kubeComponent struct { id resource.ID ns namespace.Instance cluster cluster.Cluster address string addressVM string } func newKube(ctx resource.Context, cfg Config) (Instance, error) { c := &kubeComponent{ cluster: ctx.Clusters().GetOrDefault(cfg.Cluster), } c.id = ctx.TrackResource(c) var err error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 3.4K bytes - Viewed (0) -
pkg/test/framework/components/istioctl/kube.go
kubeconfig string } // Filenamer is an interface to avoid importing kubecluster package, instead build our own interface // to extract kube context type Filenamer interface { Filename() string } func newKube(ctx resource.Context, config Config) (Instance, error) { fn, ok := ctx.Clusters().GetOrDefault(config.Cluster).(Filenamer) if !ok { return nil, fmt.Errorf("cluster does not support fetching kube config") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/test/framework/components/registryredirector/kube.go
_ io.Closer = &kubeComponent{} ) type kubeComponent struct { id resource.ID ns namespace.Instance cluster cluster.Cluster address string forwarder kube.PortForwarder } func newKube(ctx resource.Context, cfg Config) (Instance, error) { c := &kubeComponent{ cluster: ctx.Clusters().GetOrDefault(cfg.Cluster), } c.id = ctx.TrackResource(c) var err error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 00:53:57 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/test/framework/components/namespace/namespace.go
} }() if ctx.Settings().StableNamespaces { return Claim(ctx, cfg) } cfg.overwriteRevisionIfEmpty(ctx.Settings().Revisions.Default()) return newKube(ctx, cfg) } // NewOrFail calls New and fails test if it returns error func NewOrFail(t test.Failer, ctx resource.Context, nsConfig Config) Instance { t.Helper() i, err := New(ctx, nsConfig) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Dec 21 18:12:14 UTC 2023 - 4.6K bytes - Viewed (0) -
pkg/test/framework/components/prometheus/kube.go
} if err := ctx.ConfigKube().YAML(ns, yaml).Apply(apply.NoCleanup); err != nil { return err } ctx.CleanupConditionally(func() { _ = ctx.ConfigKube().YAML(ns, yaml).Delete() }) return nil } func newKube(ctx resource.Context, cfgIn Config) (Instance, error) { c := &kubeComponent{ clusters: ctx.Clusters(), } c.id = ctx.TrackResource(c) c.api = make(map[string]prometheusApiV1.API)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.3K bytes - Viewed (0)