- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Greaves (0.19 sec)
-
cni/pkg/nodeagent/server.go
return s, nil } func (s *Server) Ready() { s.isReady.Store(true) } func (s *Server) NotReady() { s.isReady.Store(false) } // buildKubeClient creates the kube client func buildKubeClient(kubeConfig string) (kube.Client, error) { // Used by validation kubeRestConfig, err := kube.DefaultRestConfig(kubeConfig, "", func(config *rest.Config) { config.QPS = 80
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
helmreconciler.TestMode = true // Add install and controller to the list of commands to run tests against. testedManifestCmds = append(testedManifestCmds, cmdApply, cmdController) } } // recreateTestEnv (re)creates a kubebuilder fake API server environment. This is required for testing of the // controller runtime, which is used in the operator. func recreateTestEnv() error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
istioctl/pkg/authz/analyzer.go
v3 "istio.io/istio/pilot/pkg/xds/v3" ) // Analyzer that can be used to check authorization policy. type Analyzer struct { listenerDump *envoy_admin.ListenersConfigDump } // NewAnalyzer creates a new analyzer for a given pod based on its envoy config. func NewAnalyzer(envoyConfig *configdump.Wrapper) (*Analyzer, error) { listeners, err := envoyConfig.GetDynamicListenerDump(true) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jul 13 01:59:17 GMT 2022 - 2.1K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
_, _ = fmt.Fprintf(writer, "%q has warnings: %v\n", fname, warningToString(w)) } else { _, _ = fmt.Fprintf(writer, "%q is valid\n", fname) } } return nil } // NewValidateCommand creates a new command for validating Istio k8s resources. func NewValidateCommand(ctx cli.Context) *cobra.Command { var filenames []string var referential bool c := &cobra.Command{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
istioctl/pkg/util/configdump/listener.go
return false } return name < l.Name }) if stripVersions { for i := range dal { dal[i].ActiveState.VersionInfo = "" dal[i].ActiveState.LastUpdated = nil dal[i].Name = "" // In Istio 1.5, Envoy creates this; suppress it } } return &admin.ListenersConfigDump{DynamicListeners: dal}, nil } // GetListenerConfigDump retrieves the listener config dump from the ConfigDump
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 2.5K bytes - Viewed (1) -
istioctl/pkg/tag/tag.go
}, } cmd.PersistentFlags().BoolVarP(&skipConfirmation, "skip-confirmation", "y", false, skipConfirmationFlagHelpStr) return cmd } // setTag creates or modifies a revision tag. func setTag(ctx context.Context, kubeClient kube.CLIClient, tagName, revision, istioNS string, generate bool, w, stderr io.Writer) error { opts := &GenerateOptions{ Tag: tagName,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
operator/cmd/mesh/test-util_test.go
type ObjectSet struct { objSlice object.K8sObjects objMap map[string]*object.K8sObject keySlice []string } // NewObjectSet creates a new ObjectSet from objs and returns a pointer to it. func NewObjectSet(objs object.K8sObjects) *ObjectSet { ret := &ObjectSet{} for _, o := range objs { ret.append(o) } return ret }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 15.3K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
return entryCmd } func createCommand(ctx cli.Context) *cobra.Command { createCmd := &cobra.Command{ Use: "create", Short: "Creates a WorkloadGroup resource that provides a template for associated WorkloadEntries", Long: `Creates a WorkloadGroup resource that provides a template for associated WorkloadEntries.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
cni/pkg/util/pluginutil.go
select { case <-w.Events: return nil case err := <-w.Errors: return err case <-ctx.Done(): return ctx.Err() } } func (w *Watcher) Close() { _ = w.watcher.Close() } // Creates a file watcher that watches for any changes to the directory func CreateFileWatcher(paths ...string) (*Watcher, error) { watcher, err := fsnotify.NewWatcher() if err != nil { return nil, fmt.Errorf("watcher create: %v", err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 3.6K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
configSecretKey = "config" ) func remoteSecretNameFromClusterName(clusterName string) string { return remoteSecretPrefix + clusterName } // NewCreateRemoteSecretCommand creates a new command for joining two contexts // together in a multi-cluster mesh. func NewCreateRemoteSecretCommand(ctx cli.Context) *cobra.Command { opts := RemoteSecretOptions{ AuthType: RemoteSecretAuthTypeBearerToken,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0)