- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for group (0.16 sec)
-
istioctl/pkg/workload/workload_test.go
args: strings.Split("group create --name foo --namespace bar --labels app=foo,bar=baz "+ " --annotations annotation=foobar --ports grpc=3550,http=8080 --serviceAccount test", " "), expectedException: false, expectedOutput: customYAML, }, { description: "valid case - create full workload group with shortnames",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
operator/cmd/mesh/operator.go
// limitations under the License. package mesh import ( "github.com/spf13/cobra" "istio.io/istio/istioctl/pkg/cli" ) // OperatorCmd is a group of commands related to installation and management of the operator controller. func OperatorCmd(ctx cli.Context) *cobra.Command { oc := &cobra.Command{ Use: "operator",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Aug 29 14:15:33 GMT 2023 - 1.5K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
func (f *fakeServer) ConstructInitialSnapshot(ambientPods []*corev1.Pod) error { if f.testWG != nil { defer f.testWG.Done() } args := f.Called(ambientPods) return args.Error(0) } // Custom "wait group with timeout" for waiting for fakeServer calls in a goroutine to finish type WaitGroup struct { count int32 done chan struct{} } func NewWaitGroup() *WaitGroup { return &WaitGroup{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers_test.go
ns := scheme.Codecs.WithoutConversion() codec := scheme.Codecs.LegacyCodec(scheme.Scheme.PrioritizedVersionsAllGroups()...) factory.Client = &fake.RESTClient{ GroupVersion: schema.GroupVersion{Group: "", Version: "v1"}, NegotiatedSerializer: ns, Client: fake.CreateHTTPClient(func(req *http.Request) (*http.Response, error) { switch p, m := req.URL.Path, req.Method; {
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) -
operator/cmd/mesh/manifest.go
// limitations under the License. package mesh import ( "github.com/spf13/cobra" "istio.io/istio/istioctl/pkg/cli" ) // ManifestCmd is a group of commands related to manifest generation, installation, diffing and migration. func ManifestCmd(ctx cli.Context) *cobra.Command { mc := &cobra.Command{ Use: "manifest", Short: "Commands related to Istio manifests",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 1.4K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
// Only used if kubebuilder is installed. testenv *envtest.Environment testClient client.Client allNamespacedGVKs = append(helmreconciler.NamespacedResources(), schema.GroupVersionKind{Group: "", Version: "v1", Kind: "Endpoints"}) // CRDs are not in the prune list, but must be considered for tests. allClusterGVKs = helmreconciler.ClusterResources ) func init() { if kubeBuilderInstalled() {
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) -
operator/cmd/mesh/manifest-generate.go
rawOutput = append(rawOutput, mfs...) } objects, err := object.ParseK8sObjectsFromYAMLManifest(strings.Join(rawOutput, helm.YAMLSeparator)) if err != nil { return nil, err } // For a given group of objects, sort in order to avoid missing dependencies, such as creating CRDs first objects.Sort(object.DefaultObjectOrder()) for _, obj := range objects { yml, err := obj.YAML() if err != nil { return nil, err
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_test.go
} } // copied and modified from spire func TestGetContainerIDFromCGroups(t *testing.T) { makeCGroups := func(groupPaths []string) []Cgroup { var out []Cgroup for _, groupPath := range groupPaths { out = append(out, Cgroup{ GroupPath: groupPath, }) } return out } //nolint: lll for _, tt := range []struct { name string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.6K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
return errs } func (v *validator) validateResource(istioNamespace, defaultNamespace string, un *unstructured.Unstructured, writer io.Writer) (validation.Warning, error) { gvk := config.GroupVersionKind{ Group: un.GroupVersionKind().Group, Version: un.GroupVersionKind().Version, Kind: un.GroupVersionKind().Kind, } schema, exists := collections.Pilot.FindByGroupVersionAliasesKind(gvk) if exists {
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/xds/google.go
type hubMembership struct { WorkloadIdentityPool string } func getHubMembership(ctx context.Context, exClient kube.CLIClient) (*hubMembership, error) { client := exClient.Dynamic() gvr := schema.GroupVersionResource{ Group: "hub.gke.io", Version: "v1", Resource: "memberships", } u, err := client.Resource(gvr).Get(ctx, "membership", metav1.GetOptions{}) if err != nil { return nil, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Nov 14 20:23:34 GMT 2022 - 3.4K bytes - Viewed (0)