status-im
/
consul
mirror of https://github.com/status-im/consul.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #10843 from hashicorp/partitions/rename-default 

oss: Rename default partition
This commit is contained in:
Kyle Havlovitz 2021-08-12 14:45:53 -07:00 committed by GitHub
parent 3e2ec34409 073b6c8411
commit fa5df0349d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
8 changed files with 62 additions and 47 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
agent/structs/config_entry_intentions_test.go
View File

@ -1296,6 +1296,7 @@ func TestMigrateIntentions(t *testing.T) {
} }
anyTime := time.Now().UTC() anyTime := time.Now().UTC()
entMeta := NodeEnterpriseMetaInDefaultPartition()
cases := map[string]testcase{ cases := map[string]testcase{
"nil": {}, "nil": {},
@ -1320,11 +1321,13 @@ func TestMigrateIntentions(t *testing.T) {
{ {
Kind: ServiceIntentions, Kind: ServiceIntentions,
Name: "bar", Name: "bar",
EnterpriseMeta: *entMeta,
Sources: []*SourceIntention{ Sources: []*SourceIntention{
{ {
LegacyID: legacyIDs[0], LegacyID: legacyIDs[0],
Description: "desc", Description: "desc",
Name: "foo", Name: "foo",
EnterpriseMeta: *entMeta,
Type: IntentionSourceConsul, Type: IntentionSourceConsul,
Action: IntentionActionAllow, Action: IntentionActionAllow,
LegacyMeta: map[string]string{ LegacyMeta: map[string]string{
@ -1372,11 +1375,13 @@ func TestMigrateIntentions(t *testing.T) {
{ {
Kind: ServiceIntentions, Kind: ServiceIntentions,
Name: "bar", Name: "bar",
EnterpriseMeta: *entMeta,
Sources: []*SourceIntention{ Sources: []*SourceIntention{
{ {
LegacyID: legacyIDs[0], LegacyID: legacyIDs[0],
Description: "desc", Description: "desc",
Name: "foo", Name: "foo",
EnterpriseMeta: *entMeta,
Type: IntentionSourceConsul, Type: IntentionSourceConsul,
Action: IntentionActionAllow, Action: IntentionActionAllow,
LegacyMeta: map[string]string{ LegacyMeta: map[string]string{
@ -1389,6 +1394,7 @@ func TestMigrateIntentions(t *testing.T) {
LegacyID: legacyIDs[1], LegacyID: legacyIDs[1],
Description: "desc2", Description: "desc2",
Name: "*", Name: "*",
EnterpriseMeta: *entMeta,
Type: IntentionSourceConsul, Type: IntentionSourceConsul,
Action: IntentionActionDeny, Action: IntentionActionDeny,
LegacyMeta: map[string]string{ LegacyMeta: map[string]string{
@ -1436,11 +1442,13 @@ func TestMigrateIntentions(t *testing.T) {
{ {
Kind: ServiceIntentions, Kind: ServiceIntentions,
Name: "bar", Name: "bar",
EnterpriseMeta: *entMeta,
Sources: []*SourceIntention{ Sources: []*SourceIntention{
{ {
LegacyID: legacyIDs[0], LegacyID: legacyIDs[0],
Description: "desc", Description: "desc",
Name: "foo", Name: "foo",
EnterpriseMeta: *entMeta,
Type: IntentionSourceConsul, Type: IntentionSourceConsul,
Action: IntentionActionAllow, Action: IntentionActionAllow,
LegacyMeta: map[string]string{ LegacyMeta: map[string]string{
@ -1454,11 +1462,13 @@ func TestMigrateIntentions(t *testing.T) {
{ {
Kind: ServiceIntentions, Kind: ServiceIntentions,
Name: "bar2", Name: "bar2",
EnterpriseMeta: *entMeta,
Sources: []*SourceIntention{ Sources: []*SourceIntention{
{ {
LegacyID: legacyIDs[1], LegacyID: legacyIDs[1],
Description: "desc2", Description: "desc2",
Name: "*", Name: "*",
EnterpriseMeta: *entMeta,
Type: IntentionSourceConsul, Type: IntentionSourceConsul,
Action: IntentionActionDeny, Action: IntentionActionDeny,
LegacyMeta: map[string]string{ LegacyMeta: map[string]string{

4
agent/structs/structs_oss.go
View File

@ -80,11 +80,11 @@ func (m *EnterpriseMeta) NamespaceOrEmpty() string {
} }
func (m *EnterpriseMeta) PartitionOrDefault() string { func (m *EnterpriseMeta) PartitionOrDefault() string {
return "" return "default"
} }
func PartitionOrDefault(_ string) string { func PartitionOrDefault(_ string) string {
return "" return "default"
} }
func (m *EnterpriseMeta) PartitionOrEmpty() string { func (m *EnterpriseMeta) PartitionOrEmpty() string {

16
api/catalog_test.go
View File

@ -1153,8 +1153,8 @@ func TestAPI_CatalogGatewayServices_Terminating(t *testing.T) {
expect := []*GatewayService{ expect := []*GatewayService{
{ {
Service: CompoundServiceName{Name: "api", Namespace: defaultNamespace}, Service: CompoundServiceName{Name: "api", Namespace: defaultNamespace, Partition: defaultPartition},
Gateway: CompoundServiceName{Name: "terminating", Namespace: defaultNamespace}, Gateway: CompoundServiceName{Name: "terminating", Namespace: defaultNamespace, Partition: defaultPartition},
GatewayKind: ServiceKindTerminatingGateway, GatewayKind: ServiceKindTerminatingGateway,
CAFile: "api/ca.crt", CAFile: "api/ca.crt",
CertFile: "api/client.crt", CertFile: "api/client.crt",
@ -1162,8 +1162,8 @@ func TestAPI_CatalogGatewayServices_Terminating(t *testing.T) {
SNI: "my-domain", SNI: "my-domain",
}, },
{ {
Service: CompoundServiceName{Name: "redis", Namespace: defaultNamespace}, Service: CompoundServiceName{Name: "redis", Namespace: defaultNamespace, Partition: defaultPartition},
Gateway: CompoundServiceName{Name: "terminating", Namespace: defaultNamespace}, Gateway: CompoundServiceName{Name: "terminating", Namespace: defaultNamespace, Partition: defaultPartition},
GatewayKind: ServiceKindTerminatingGateway, GatewayKind: ServiceKindTerminatingGateway,
CAFile: "ca.crt", CAFile: "ca.crt",
CertFile: "client.crt", CertFile: "client.crt",
@ -1221,15 +1221,15 @@ func TestAPI_CatalogGatewayServices_Ingress(t *testing.T) {
expect := []*GatewayService{ expect := []*GatewayService{
{ {
Service: CompoundServiceName{Name: "api", Namespace: defaultNamespace}, Service: CompoundServiceName{Name: "api", Namespace: defaultNamespace, Partition: defaultPartition},
Gateway: CompoundServiceName{Name: "ingress", Namespace: defaultNamespace}, Gateway: CompoundServiceName{Name: "ingress", Namespace: defaultNamespace, Partition: defaultPartition},
GatewayKind: ServiceKindIngressGateway, GatewayKind: ServiceKindIngressGateway,
Protocol: "tcp", Protocol: "tcp",
Port: 8888, Port: 8888,
}, },
{ {
Service: CompoundServiceName{Name: "redis", Namespace: defaultNamespace}, Service: CompoundServiceName{Name: "redis", Namespace: defaultNamespace, Partition: defaultPartition},
Gateway: CompoundServiceName{Name: "ingress", Namespace: defaultNamespace}, Gateway: CompoundServiceName{Name: "ingress", Namespace: defaultNamespace, Partition: defaultPartition},
GatewayKind: ServiceKindIngressGateway, GatewayKind: ServiceKindIngressGateway,
Protocol: "tcp", Protocol: "tcp",
Port: 9999, Port: 9999,

1
api/health_test.go
View File

@ -223,6 +223,7 @@ func TestAPI_HealthChecks(t *testing.T) {
ServiceName: "foo", ServiceName: "foo",
ServiceTags: []string{"bar"}, ServiceTags: []string{"bar"},
Type: "ttl", Type: "ttl",
Partition: defaultPartition,
Namespace: defaultNamespace, Namespace: defaultNamespace,
}, },
} }

1
api/oss_test.go
View File

@ -3,3 +3,4 @@
package api package api
var defaultNamespace = "" var defaultNamespace = ""
var defaultPartition = ""

5
api/txn_test.go
View File

@ -181,6 +181,7 @@ func TestAPI_ClientTxn(t *testing.T) {
ID: "foo1", ID: "foo1",
CreateIndex: ret.Results[3].Service.CreateIndex, CreateIndex: ret.Results[3].Service.CreateIndex,
ModifyIndex: ret.Results[3].Service.CreateIndex, ModifyIndex: ret.Results[3].Service.CreateIndex,
Partition: defaultPartition,
Namespace: defaultNamespace, Namespace: defaultNamespace,
}, },
}, },
@ -199,6 +200,7 @@ func TestAPI_ClientTxn(t *testing.T) {
DeregisterCriticalServiceAfterDuration: 20 * time.Second, DeregisterCriticalServiceAfterDuration: 20 * time.Second,
}, },
Type: "tcp", Type: "tcp",
Partition: defaultPartition,
Namespace: defaultNamespace, Namespace: defaultNamespace,
CreateIndex: ret.Results[4].Check.CreateIndex, CreateIndex: ret.Results[4].Check.CreateIndex,
ModifyIndex: ret.Results[4].Check.CreateIndex, ModifyIndex: ret.Results[4].Check.CreateIndex,
@ -219,13 +221,14 @@ func TestAPI_ClientTxn(t *testing.T) {
DeregisterCriticalServiceAfterDuration: 160 * time.Second, DeregisterCriticalServiceAfterDuration: 160 * time.Second,
}, },
Type: "tcp", Type: "tcp",
Partition: defaultPartition,
Namespace: defaultNamespace, Namespace: defaultNamespace,
CreateIndex: ret.Results[4].Check.CreateIndex, CreateIndex: ret.Results[4].Check.CreateIndex,
ModifyIndex: ret.Results[4].Check.CreateIndex, ModifyIndex: ret.Results[4].Check.CreateIndex,
}, },
}, },
} }
require.Equal(t, ret.Results, expected) require.Equal(t, expected, ret.Results)
retry.Run(t, func(r *retry.R) { retry.Run(t, func(r *retry.R) {
// Run a read-only transaction. // Run a read-only transaction.

2
test/integration/connect/envoy/case-basic/verify.bats
View File

@ -39,7 +39,7 @@ load helpers
@test "s1 proxy should have been configured with one rbac listener filter at L4" { @test "s1 proxy should have been configured with one rbac listener filter at L4" {
LISTEN_FILTERS=$(get_envoy_listener_filters localhost:19000) LISTEN_FILTERS=$(get_envoy_listener_filters localhost:19000)
PUB=$(echo "$LISTEN_FILTERS" | grep -E "^public_listener:" | cut -f 2 -d ' ' ) PUB=$(echo "$LISTEN_FILTERS" | grep -E "^public_listener:" | cut -f 2 -d ' ' )
UPS=$(echo "$LISTEN_FILTERS" | grep -E "^(\/default\/)?s2:" | cut -f 2 -d ' ' ) UPS=$(echo "$LISTEN_FILTERS" | grep -E "^(default\/default\/)?s2:" | cut -f 2 -d ' ' )
echo "LISTEN_FILTERS = $LISTEN_FILTERS" echo "LISTEN_FILTERS = $LISTEN_FILTERS"
echo "PUB = $PUB" echo "PUB = $PUB"

4
test/integration/connect/envoy/case-http/verify.bats
View File

@ -36,7 +36,7 @@ load helpers
@test "s1 proxy should have been configured with http connection managers" { @test "s1 proxy should have been configured with http connection managers" {
LISTEN_FILTERS=$(get_envoy_listener_filters localhost:19000) LISTEN_FILTERS=$(get_envoy_listener_filters localhost:19000)
PUB=$(echo "$LISTEN_FILTERS" | grep -E "^public_listener:" | cut -f 2 -d ' ' ) PUB=$(echo "$LISTEN_FILTERS" | grep -E "^public_listener:" | cut -f 2 -d ' ' )
UPS=$(echo "$LISTEN_FILTERS" | grep -E "^(\/default\/)?s2:" | cut -f 2 -d ' ' ) UPS=$(echo "$LISTEN_FILTERS" | grep -E "^(default\/default\/)?s2:" | cut -f 2 -d ' ' )
echo "LISTEN_FILTERS = $LISTEN_FILTERS" echo "LISTEN_FILTERS = $LISTEN_FILTERS"
echo "PUB = $PUB" echo "PUB = $PUB"
@ -59,7 +59,7 @@ load helpers
@test "s1 proxy should have been configured with http rbac filters" { @test "s1 proxy should have been configured with http rbac filters" {
HTTP_FILTERS=$(get_envoy_http_filters localhost:19000) HTTP_FILTERS=$(get_envoy_http_filters localhost:19000)
PUB=$(echo "$HTTP_FILTERS" | grep -E "^public_listener:" | cut -f 2 -d ' ' ) PUB=$(echo "$HTTP_FILTERS" | grep -E "^public_listener:" | cut -f 2 -d ' ' )
UPS=$(echo "$HTTP_FILTERS" | grep -E "^(\/default\/)?s2:" | cut -f 2 -d ' ' ) UPS=$(echo "$HTTP_FILTERS" | grep -E "^(default\/default\/)?s2:" | cut -f 2 -d ' ' )
echo "HTTP_FILTERS = $HTTP_FILTERS" echo "HTTP_FILTERS = $HTTP_FILTERS"
echo "PUB = $PUB" echo "PUB = $PUB"