}
  }

  /** Open connections to [address], if required by the address policy. */
  fun scheduleOpener(address: Address) {
    addressStates[address]?.scheduleOpener()
  }

  fun scheduleCloser() {
    cleanupQueue.schedule(cleanupTask)
  }

  /**
   * Ensure enough connections open to [address] to satisfy its [ConnectionPool.AddressPolicy].

	// when in an environment that doesn't support LoadBalancer).
	TCPAddresses() ([]string, []int)
	// DiscoveryAddresses returns the external XDS (15012) address on the ingress gateway (or the NodePort address,
	// when in an environment that doesn't support LoadBalancer).
	DiscoveryAddresses() []netip.AddrPort

              "endpoint": {
                "address":{
                  "socket_address": {"address": "accesslog-service", "port_value": 15000}
                }
              }
            }]
          }]
        }
      }
      
    ],
    "listeners":[
      {
        "address": {
          "socket_address": {
            "protocol": "TCP",
            "address": "0.0.0.0",
            

              "endpoint": {
                "address":{
                  "socket_address": {"address": "accesslog-service", "port_value": 15000}
                }
              }
            }]
          }]
        }
      }
      
    ],
    "listeners":[
      {
        "address": {
          "socket_address": {
            "protocol": "TCP",
            "address": "0.0.0.0",
            

            "lb_endpoints": [{
              "endpoint": {
                "address":{
                  "socket_address": {"address": "localhost", "port_value": 6000}
                }
              }
            }]
          }]
        }
      }
      
      
    ],
    "listeners":[
      {
        "address": {
          "socket_address": {
            "protocol": "TCP",

            "lb_endpoints": [{
              "endpoint": {
                "address":{
                  "socket_address": {"address": "localhost", "port_value": 8126}
                }
              }
            }]
          }]
        }
      }
      
      
    ],
    "listeners":[
      {
        "address": {
          "socket_address": {
            "protocol": "TCP",

    InetAddress address = InetAddress.getByName("255.255.255.254");
    assertFalse(InetAddresses.isMaximum(address));

    address = InetAddress.getByName("255.255.255.255");
    assertTrue(InetAddresses.isMaximum(address));

    address = InetAddress.getByName("ffff:ffff:ffff:ffff:ffff:ffff:ffff:fffe");
    assertFalse(InetAddresses.isMaximum(address));

 */
@ServiceScope(Scope.Global.class)
public interface MessagingClient {
    /**
     * Creates a connection to the given address. Blocks until the connection has been established.
     *
     * @param address The address to connect to.
     */
    ObjectConnection getConnection(Address address);

            "lb_endpoints": [{
              "endpoint": {
                "address":{
                  "socket_address": {"address": "localhost", "port_value": 6000}
                }
              }
            }]
          }]
        }
      }
      
      
    ],
    "listeners":[
      {
        "address": {
          "socket_address": {
            "protocol": "TCP",

	s.assertEvent(t, s.podXdsName("pod1"))

	// lookup by address should return the pod's address info (ignore the workload entry with similar address)
	assert.Equal(t, s.lookup(s.addrXdsName("140.140.0.10")), []model.AddressInfo{{
		Address: &workloadapi.Address{
			Type: &workloadapi.Address_Workload{
				Workload: &workloadapi.Workload{
					Uid:               s.podXdsName("pod1"),