From 60bcaedc43e78e58e2e9c53f3a0333ea8e806f5c Mon Sep 17 00:00:00 2001 From: jm96441n Date: Tue, 21 Nov 2023 10:49:29 -0500 Subject: [PATCH] Undo formatting changes --- agent/consul/state/catalog.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/agent/consul/state/catalog.go b/agent/consul/state/catalog.go index 3b0b230cb8f2..39607fbf1939 100644 --- a/agent/consul/state/catalog.go +++ b/agent/consul/state/catalog.go @@ -4965,22 +4965,19 @@ func cleanupMeshTopology(tx WriteTxn, idx uint64, service *structs.ServiceNode) func insertGatewayServiceTopologyMapping(tx WriteTxn, idx uint64, gs *structs.GatewayService) error { // Only ingress gateways are standalone items in the mesh topology viz - if (gs.GatewayKind != structs.ServiceKindIngressGateway) || gs.Service.Name == structs.WildcardSpecifier { + if gs.GatewayKind != structs.ServiceKindIngressGateway || gs.Service.Name == structs.WildcardSpecifier { return nil } - // HERE mapping := upstreamDownstream{ Upstream: gs.Service, Downstream: gs.Gateway, Refs: make(map[string]struct{}), RaftIndex: gs.RaftIndex, } - if err := tx.Insert(tableMeshTopology, &mapping); err != nil { return fmt.Errorf("failed inserting %s mapping: %s", tableMeshTopology, err) } - if err := indexUpdateMaxTxn(tx, idx, tableMeshTopology); err != nil { return fmt.Errorf("failed updating %s index: %v", tableMeshTopology, err) }