)

func TestStartWithError(t *testing.T) {
	g := NewWithT(t)

	inst := server.New()
	expected := errors.New("fake")
	inst.RunComponent("fake", func(stop <-chan struct{}) error {
		return expected
	})

	stop := newReclosableChannel()
	t.Cleanup(stop.Close)
	g.Expect(inst.Start(stop.c)).To(Equal(expected))
}

func TestStartWithNoError(t *testing.T) {
	g := NewWithT(t)

	inst := server.New()

	"testing"

	. "github.com/onsi/gomega"
)

func TestMetadata_Clone_NilMaps(t *testing.T) {
	g := NewWithT(t)

	m := Metadata{
		FullName: NewFullName("ns1", "rs1"),
		Version:  Version("v1"),
	}

	c := m.Clone()
	g.Expect(m).To(Equal(c))
}

func TestMetadata_Clone_NonNilMaps(t *testing.T) {
	g := NewWithT(t)

	m := Metadata{
		FullName:    NewFullName("ns1", "rs1"),
		Version:     Version("v1"),

spec:
  hosts:
  - some.example.com
  gateways:
  - some-ingress
  http:
  - route:
    - destination:
        host: some.example.internal
`

func TestFileSnapshotNoFilter(t *testing.T) {
	g := NewWithT(t)

	ts := &testState{
		ConfigFiles: map[string][]byte{"gateway.yml": []byte(gatewayYAML)},
	}

	ts.testSetup(t)

	fileWatcher := NewFileSnapshot(ts.rootPath, collection.SchemasFor(), "foo")

	. "github.com/onsi/gomega"

	"istio.io/istio/istioctl/pkg/cli"
	"istio.io/istio/istioctl/pkg/util/testutil"
	"istio.io/istio/pkg/config/analysis/diag"
)

func TestErrorOnIssuesFound(t *testing.T) {
	g := NewWithT(t)

	msgs := []diag.Message{
		diag.NewMessage(
			diag.NewMessageType(diag.Error, "B1", "Template: %q"),
			nil,
			"",
		),
		diag.NewMessage(
			diag.NewMessageType(diag.Warning, "A1", "Template: %q"),

// limitations under the License.

package util

import (
	"testing"

	. "github.com/onsi/gomega"

	"istio.io/istio/pkg/config/resource"
)

func TestGetResourceNameFromHost(t *testing.T) {
	g := NewWithT(t)

	// FQDN, same namespace
	g.Expect(GetResourceNameFromHost("default", "foo.default.svc.cluster.local")).To(Equal(resource.NewFullName("default", "foo")))
	// FQDN, cross namespace

		panic(err)
	}
	if err := yaml.Unmarshal([]byte(testClusterResourcesAnnotations), &testClusterResources.Annotations); err != nil {
		panic(err)
	}
}

func TestGetMatchingPaths(t *testing.T) {
	g := NewWithT(t)

	tests := []struct {
		name    string
		config  string
		want    []string
		wantErr string
	}{
		{
			name:   "wantEmpty",
			config: ``,
			want:   ns1,
		},
		{

				"inbound|10001||":              overrideSettings,
				"inbound|10002||":              basicSettings,
			},
		},
	}
	for name, tt := range cases {
		t.Run(name, func(t *testing.T) {
			g := NewWithT(t)

			clusters := xdstest.ExtractClusters(buildTestClusters(clusterTest{
				t:               t,
				serviceHostname: "*.example.org",
				nodeType:        model.SidecarProxy,
				mesh:            testMesh(),

						Number:   80,
						Protocol: "HTTP2",
						Name:     "http",
					},
					Hosts: []string{"*.example.com"},
				},
			},
		},
	},
}

func TestMonitorForChange(t *testing.T) {
	g := NewWithT(t)

	store := memory.Make(collection.SchemasFor(collections.Gateway))

	var (
		callCount int
		configs   []*config.Config
		err       error
	)

	someConfigFunc := func() ([]*config.Config, error) {

package app

import (
	"testing"

	. "github.com/onsi/gomega"

	"istio.io/istio/pilot/cmd/pilot-agent/options"
)

func TestPilotDefaultDomainKubernetes(t *testing.T) {
	g := NewWithT(t)
	role := &options.ProxyArgs{}
	role.DNSDomain = ""

	domain := getDNSDomain("default", role.DNSDomain)

	g.Expect(domain).To(Equal("default.svc.cluster.local"))

// limitations under the License.

package util

import (
	"testing"

	. "github.com/onsi/gomega"
)

func TestIsExportToAllNamespaces(t *testing.T) {
	g := NewWithT(t)

	// Empty array
	g.Expect(IsExportToAllNamespaces(nil)).To(Equal(true))

	// Array with "*"
	g.Expect(IsExportToAllNamespaces([]string{"*"})).To(Equal(true))

	// Array with "."