...
1 package entrypoint_test
2
3 import (
4 "testing"
5
6 "github.com/stretchr/testify/assert"
7 "github.com/stretchr/testify/require"
8
9 "github.com/emissary-ingress/emissary/v3/cmd/entrypoint"
10 amb "github.com/emissary-ingress/emissary/v3/pkg/api/getambassador.io/v3alpha1"
11 "github.com/emissary-ingress/emissary/v3/pkg/kates"
12 "github.com/emissary-ingress/emissary/v3/pkg/snapshot/v1"
13 )
14
15 func TestAmbassadorMetaInfo(t *testing.T) {
16 f := entrypoint.RunFake(t, entrypoint.FakeConfig{EnvoyConfig: true}, &snapshot.AmbassadorMetaInfo{ClusterID: "foo"})
17
18 require.NoError(t, f.Upsert(&amb.Mapping{
19 TypeMeta: kates.TypeMeta{Kind: "Mapping"},
20 ObjectMeta: kates.ObjectMeta{Name: "foo"},
21 Spec: amb.MappingSpec{Prefix: "/foo", Service: "1.2.3.4"},
22 }))
23 f.Flush()
24 snap, err := f.GetSnapshot(func(s *snapshot.Snapshot) bool { return true })
25 require.NoError(t, err)
26 assert.NotNil(t, snap)
27 assert.Equal(t, "foo", snap.AmbassadorMeta.ClusterID)
28 }
29
View as plain text