luxolus
/
open-consul
2
0
Fork 0
Code Issues 1 Pull Requests Packages Releases Wiki Activity

Rename peering internal to ~ 

sync ENT to 5679392c81

Signed-off-by: acpana <8968914+acpana@users.noreply.github.com>
This commit is contained in:
acpana 2022-07-21 10:51:05 -07:00
parent ba7f3fbebc
commit b847f656a8
No known key found for this signature in database
GPG Key ID: 21CC0F2B42CEA01D
2 changed files with 41 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

80
agent/consul/state/catalog_oss_test.go
View File

@ -34,11 +34,11 @@ func testIndexerTableChecks() map[string]indexerTestCase {
Node: "NoDe",
CheckID: "CheckId",
},
expected: []byte("internal\x00node\x00checkid\x00"),
expected: []byte("~\x00node\x00checkid\x00"),
},
write: indexValue{
source: obj,
expected: []byte("internal\x00node\x00checkid\x00"),
expected: []byte("~\x00node\x00checkid\x00"),
},
prefix: []indexValue{
{
@ -47,7 +47,7 @@ func testIndexerTableChecks() map[string]indexerTestCase {
},
{
source: Query{Value: "nOdE"},
expected: []byte("internal\x00node\x00"),
expected: []byte("~\x00node\x00"),
},
},
extra: []indexerTestCase{
@ -77,11 +77,11 @@ func testIndexerTableChecks() map[string]indexerTestCase {
indexStatus: {
read: indexValue{
source: Query{Value: "PASSING"},
expected: []byte("internal\x00passing\x00"),
expected: []byte("~\x00passing\x00"),
},
write: indexValue{
source: obj,
expected: []byte("internal\x00passing\x00"),
expected: []byte("~\x00passing\x00"),
},
extra: []indexerTestCase{
{
@ -99,11 +99,11 @@ func testIndexerTableChecks() map[string]indexerTestCase {
indexService: {
read: indexValue{
source: Query{Value: "ServiceName"},
expected: []byte("internal\x00servicename\x00"),
expected: []byte("~\x00servicename\x00"),
},
write: indexValue{
source: obj,
expected: []byte("internal\x00servicename\x00"),
expected: []byte("~\x00servicename\x00"),
},
extra: []indexerTestCase{
{
@ -124,11 +124,11 @@ func testIndexerTableChecks() map[string]indexerTestCase {
Node: "NoDe",
Service: "SeRvIcE",
},
expected: []byte("internal\x00node\x00service\x00"),
expected: []byte("~\x00node\x00service\x00"),
},
write: indexValue{
source: obj,
expected: []byte("internal\x00node\x00service\x00"),
expected: []byte("~\x00node\x00service\x00"),
},
extra: []indexerTestCase{
{
@ -152,11 +152,11 @@ func testIndexerTableChecks() map[string]indexerTestCase {
source: Query{
Value: "NoDe",
},
expected: []byte("internal\x00node\x00"),
expected: []byte("~\x00node\x00"),
},
write: indexValue{
source: obj,
expected: []byte("internal\x00node\x00"),
expected: []byte("~\x00node\x00"),
},
extra: []indexerTestCase{
{
@ -272,11 +272,11 @@ func testIndexerTableNodes() map[string]indexerTestCase {
indexID: {
read: indexValue{
source: Query{Value: "NoDeId"},
expected: []byte("internal\x00nodeid\x00"),
expected: []byte("~\x00nodeid\x00"),
},
write: indexValue{
source: &structs.Node{Node: "NoDeId"},
expected: []byte("internal\x00nodeid\x00"),
expected: []byte("~\x00nodeid\x00"),
},
prefix: []indexValue{
{
@ -289,11 +289,11 @@ func testIndexerTableNodes() map[string]indexerTestCase {
},
{
source: Query{Value: "NoDeId"},
expected: []byte("internal\x00nodeid\x00"),
expected: []byte("~\x00nodeid\x00"),
},
{
source: Query{},
expected: []byte("internal\x00"),
expected: []byte("~\x00"),
},
},
extra: []indexerTestCase{
@ -322,27 +322,27 @@ func testIndexerTableNodes() map[string]indexerTestCase {
indexUUID: {
read: indexValue{
source: Query{Value: uuid},
expected: append([]byte("internal\x00"), uuidBuf...),
expected: append([]byte("~\x00"), uuidBuf...),
},
write: indexValue{
source: &structs.Node{
ID: types.NodeID(uuid),
Node: "NoDeId",
},
expected: append([]byte("internal\x00"), uuidBuf...),
expected: append([]byte("~\x00"), uuidBuf...),
},
prefix: []indexValue{
{ // partial length
source: Query{Value: uuid[:6]},
expected: append([]byte("internal\x00"), uuidBuf[:3]...),
expected: append([]byte("~\x00"), uuidBuf[:3]...),
},
{ // full length
source: Query{Value: uuid},
expected: append([]byte("internal\x00"), uuidBuf...),
expected: append([]byte("~\x00"), uuidBuf...),
},
{
source: Query{},
expected: []byte("internal\x00"),
expected: []byte("~\x00"),
},
},
extra: []indexerTestCase{
@ -382,7 +382,7 @@ func testIndexerTableNodes() map[string]indexerTestCase {
Key: "KeY",
Value: "VaLuE",
},
expected: []byte("internal\x00KeY\x00VaLuE\x00"),
expected: []byte("~\x00KeY\x00VaLuE\x00"),
},
writeMulti: indexValueMulti{
source: &structs.Node{
@ -393,8 +393,8 @@ func testIndexerTableNodes() map[string]indexerTestCase {
},
},
expected: [][]byte{
[]byte("internal\x00MaP-kEy-1\x00mAp-VaL-1\x00"),
[]byte("internal\x00mAp-KeY-2\x00MaP-vAl-2\x00"),
[]byte("~\x00MaP-kEy-1\x00mAp-VaL-1\x00"),
[]byte("~\x00mAp-KeY-2\x00MaP-vAl-2\x00"),
},
},
extra: []indexerTestCase{
@ -449,11 +449,11 @@ func testIndexerTableServices() map[string]indexerTestCase {
Node: "NoDeId",
Service: "SeRvIcE",
},
expected: []byte("internal\x00nodeid\x00service\x00"),
expected: []byte("~\x00nodeid\x00service\x00"),
},
write: indexValue{
source: obj,
expected: []byte("internal\x00nodeid\x00service\x00"),
expected: []byte("~\x00nodeid\x00service\x00"),
},
prefix: []indexValue{
{
@ -466,11 +466,11 @@ func testIndexerTableServices() map[string]indexerTestCase {
},
{
source: Query{},
expected: []byte("internal\x00"),
expected: []byte("~\x00"),
},
{
source: Query{Value: "NoDeId"},
expected: []byte("internal\x00nodeid\x00"),
expected: []byte("~\x00nodeid\x00"),
},
},
extra: []indexerTestCase{
@ -505,11 +505,11 @@ func testIndexerTableServices() map[string]indexerTestCase {
source: Query{
Value: "NoDeId",
},
expected: []byte("internal\x00nodeid\x00"),
expected: []byte("~\x00nodeid\x00"),
},
write: indexValue{
source: obj,
expected: []byte("internal\x00nodeid\x00"),
expected: []byte("~\x00nodeid\x00"),
},
extra: []indexerTestCase{
{
@ -530,11 +530,11 @@ func testIndexerTableServices() map[string]indexerTestCase {
indexService: {
read: indexValue{
source: Query{Value: "ServiceName"},
expected: []byte("internal\x00servicename\x00"),
expected: []byte("~\x00servicename\x00"),
},
write: indexValue{
source: obj,
expected: []byte("internal\x00servicename\x00"),
expected: []byte("~\x00servicename\x00"),
},
extra: []indexerTestCase{
{
@ -552,14 +552,14 @@ func testIndexerTableServices() map[string]indexerTestCase {
indexConnect: {
read: indexValue{
source: Query{Value: "ConnectName"},
expected: []byte("internal\x00connectname\x00"),
expected: []byte("~\x00connectname\x00"),
},
write: indexValue{
source: &structs.ServiceNode{
ServiceName: "ConnectName",
ServiceConnect: structs.ServiceConnect{Native: true},
},
expected: []byte("internal\x00connectname\x00"),
expected: []byte("~\x00connectname\x00"),
},
extra: []indexerTestCase{
{
@ -571,7 +571,7 @@ func testIndexerTableServices() map[string]indexerTestCase {
DestinationServiceName: "ConnectName",
},
},
expected: []byte("internal\x00connectname\x00"),
expected: []byte("~\x00connectname\x00"),
},
},
{
@ -621,13 +621,13 @@ func testIndexerTableServices() map[string]indexerTestCase {
indexKind: {
read: indexValue{
source: Query{Value: "connect-proxy"},
expected: []byte("internal\x00connect-proxy\x00"),
expected: []byte("~\x00connect-proxy\x00"),
},
write: indexValue{
source: &structs.ServiceNode{
ServiceKind: structs.ServiceKindConnectProxy,
},
expected: []byte("internal\x00connect-proxy\x00"),
expected: []byte("~\x00connect-proxy\x00"),
},
extra: []indexerTestCase{
{
@ -636,7 +636,7 @@ func testIndexerTableServices() map[string]indexerTestCase {
ServiceName: "ServiceName",
ServiceKind: structs.ServiceKindTypical,
},
expected: []byte("internal\x00\x00"),
expected: []byte("~\x00\x00"),
},
},
{
@ -694,18 +694,18 @@ func testIndexerTableServiceVirtualIPs() map[string]indexerTestCase {
Name: "foo",
},
},
expected: []byte("internal\x00foo\x00"),
expected: []byte("~\x00foo\x00"),
},
write: indexValue{
source: obj,
expected: []byte("internal\x00foo\x00"),
expected: []byte("~\x00foo\x00"),
},
prefix: []indexValue{
{
source: Query{
Value: "foo",
},
expected: []byte("internal\x00foo\x00"),
expected: []byte("~\x00foo\x00"),
},
{
source: Query{

2
agent/structs/structs.go
View File

@ -88,7 +88,7 @@ const (
const (
// LocalPeerKeyword is a reserved keyword used for indexing in the state store for objects in the local peer.
LocalPeerKeyword = "internal"
LocalPeerKeyword = "~"
// DefaultPeerKeyword is the PeerName to use to refer to the local
// cluster's own data, rather than replicated peered data.