io.picodata.driver.cluster

Class BinaryDiscoveryClusterAddressProvider

java.lang.Object

io.picodata.driver.cluster.AbstractDiscoveryClusterAddressProvider

io.picodata.driver.cluster.BinaryDiscoveryClusterAddressProvider

All Implemented Interfaces:

TarantoolClusterAddressProvider, AutoCloseable

public class BinaryDiscoveryClusterAddressProvider
extends AbstractDiscoveryClusterAddressProvider

Service discovery client connecting to Tarantool via the binary protocol. Gets list of cluster node addresses calling an exposed Lua function.

Expected response format:

 
 127.0.0.1:3301> get_routers()
 ---
 - 36a1a75e-60f0-4400-8bdc-d93e2c5ca54b:
     priority: 1
     status: healthy
     uri: localhost:3301
     uuid: 9a3426db-f8f6-4e9f-ac80-e263527a59bc
   4141912c-34b8-4e40-a17e-7a6d80345954:
     priority: 1
     status: healthy
     uri: localhost:3302
     uuid: 898b4d01-4261-4006-85ea-a3500163cda0
 ...
 
 

Lua function example:

 
  ...
  local function get_routers()
    local cartridge = require('cartridge')
    local function table_contains(table, element)
      for _, value in pairs(table) do
        if value == element then
          return true
        end
      end
      return false
    end

    local servers, err = cartridge.admin_get_servers()
    local routers = {}

    for _, server in pairs(servers) do
      if server.replicaset ~= nil then
        if table_contains(server.replicaset.roles, 'app.roles.custom') then
          routers[server.uuid] = {
              status = server.healthy,
              uuid = server.uuid,
              uri = server.uri,
              priority = server.priority
          }
        end
      end
    end

    return routers
  end
  ...
 
 

Constructor Summary

Constructors

Constructor and Description
BinaryDiscoveryClusterAddressProvider(TarantoolClusterDiscoveryConfig discoveryConfig)

Method Summary

Modifier and Type	Method and Description
void	close()
protected Collection<TarantoolServerAddress>	discoverAddresses()

Methods inherited from class io.picodata.driver.cluster.AbstractDiscoveryClusterAddressProvider

getAddresses, getDiscoveryConfig, getExecutorService, setRefreshCallback, startDiscoveryTask

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BinaryDiscoveryClusterAddressProvider

public BinaryDiscoveryClusterAddressProvider(TarantoolClusterDiscoveryConfig discoveryConfig)

Method Detail

discoverAddresses

protected Collection<TarantoolServerAddress> discoverAddresses()

Specified by:

discoverAddresses in class AbstractDiscoveryClusterAddressProvider

close

public void close()

Specified by:

close in interface TarantoolClusterAddressProvider

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractDiscoveryClusterAddressProvider