@@ -8,8 +8,8 @@ from .serializer import JSONSerializer, Deserializer, DEFAULT_SERIALIZERS
|
|||||||
from .exceptions import ConnectionError, TransportError, SerializationError, \
|
from .exceptions import ConnectionError, TransportError, SerializationError, \
|
||||||
ConnectionTimeout, ImproperlyConfigured
|
ConnectionTimeout, ImproperlyConfigured
|
||||||
|
|
||||||
# get ip/port from "inet[wind/127.0.0.1:9200]"
|
# get ip/port from "127.0.0.1:9200"
|
||||||
ADDRESS_RE = re.compile(r'/(?P<host>[\.:0-9a-f]*):(?P<port>[0-9]+)\]?$')
|
ADDRESS_RE = re.compile(r'^(?P<host>[\.:0-9a-f]*):(?P<port>[0-9]+)?$')
|
||||||
|
|
||||||
|
|
||||||
def get_host_info(node_info, host):
|
def get_host_info(node_info, host):
|
||||||
|
|||||||
@@ -29,11 +29,11 @@ CLUSTER_NODES = '''{
|
|||||||
"nodes" : {
|
"nodes" : {
|
||||||
"wE_6OGBNSjGksbONNncIbg" : {
|
"wE_6OGBNSjGksbONNncIbg" : {
|
||||||
"name" : "Nightwind",
|
"name" : "Nightwind",
|
||||||
"transport_address" : "inet[/127.0.0.1:9300]",
|
"transport_address" : "127.0.0.1:9300",
|
||||||
"hostname" : "wind",
|
"hostname" : "wind",
|
||||||
"version" : "0.20.4",
|
"version" : "0.20.4",
|
||||||
"http_address" : "inet[/1.1.1.1:123]",
|
"http_address" : "1.1.1.1:123",
|
||||||
"thrift_address" : "/1.1.1.1:9500]"
|
"thrift_address" : "1.1.1.1:9500"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}'''
|
}'''
|
||||||
|
|||||||
Reference in New Issue
Block a user