mirror of https://github.com/citusdata/citus.git
Fix whitespace
parent
e822d6c9e5
commit
e80a89ccc5
|
@ -2,14 +2,14 @@ SET search_path = 'pg_catalog';
|
||||||
DROP VIEW IF EXISTS pg_catalog.citus_nodes;
|
DROP VIEW IF EXISTS pg_catalog.citus_nodes;
|
||||||
|
|
||||||
CREATE OR REPLACE VIEW citus.citus_nodes AS
|
CREATE OR REPLACE VIEW citus.citus_nodes AS
|
||||||
SELECT
|
SELECT
|
||||||
nodename,
|
nodename,
|
||||||
nodeport,
|
nodeport,
|
||||||
CASE
|
CASE
|
||||||
WHEN groupid = 0 THEN 'coordinator'
|
WHEN groupid = 0 THEN 'coordinator'
|
||||||
ELSE 'worker'
|
ELSE 'worker'
|
||||||
END AS role,
|
END AS role,
|
||||||
isactive AS active
|
isactive AS active
|
||||||
FROM pg_dist_node;
|
FROM pg_dist_node;
|
||||||
|
|
||||||
ALTER VIEW citus.citus_nodes SET SCHEMA pg_catalog;
|
ALTER VIEW citus.citus_nodes SET SCHEMA pg_catalog;
|
||||||
|
|
|
@ -2,14 +2,14 @@ SET search_path = 'pg_catalog';
|
||||||
DROP VIEW IF EXISTS pg_catalog.citus_nodes;
|
DROP VIEW IF EXISTS pg_catalog.citus_nodes;
|
||||||
|
|
||||||
CREATE OR REPLACE VIEW citus.citus_nodes AS
|
CREATE OR REPLACE VIEW citus.citus_nodes AS
|
||||||
SELECT
|
SELECT
|
||||||
nodename,
|
nodename,
|
||||||
nodeport,
|
nodeport,
|
||||||
CASE
|
CASE
|
||||||
WHEN groupid = 0 THEN 'coordinator'
|
WHEN groupid = 0 THEN 'coordinator'
|
||||||
ELSE 'worker'
|
ELSE 'worker'
|
||||||
END AS role,
|
END AS role,
|
||||||
isactive AS active
|
isactive AS active
|
||||||
FROM pg_dist_node;
|
FROM pg_dist_node;
|
||||||
|
|
||||||
ALTER VIEW citus.citus_nodes SET SCHEMA pg_catalog;
|
ALTER VIEW citus.citus_nodes SET SCHEMA pg_catalog;
|
||||||
|
|
|
@ -137,18 +137,21 @@ class Message:
|
||||||
|
|
||||||
class SharedMessage(Message, metaclass=MessageMeta):
|
class SharedMessage(Message, metaclass=MessageMeta):
|
||||||
"A message which could be sent by either the frontend or the backend"
|
"A message which could be sent by either the frontend or the backend"
|
||||||
|
|
||||||
_msgtypes = dict()
|
_msgtypes = dict()
|
||||||
_classes = dict()
|
_classes = dict()
|
||||||
|
|
||||||
|
|
||||||
class FrontendMessage(Message, metaclass=MessageMeta):
|
class FrontendMessage(Message, metaclass=MessageMeta):
|
||||||
"A message which will only be sent be a backend"
|
"A message which will only be sent be a backend"
|
||||||
|
|
||||||
_msgtypes = dict()
|
_msgtypes = dict()
|
||||||
_classes = dict()
|
_classes = dict()
|
||||||
|
|
||||||
|
|
||||||
class BackendMessage(Message, metaclass=MessageMeta):
|
class BackendMessage(Message, metaclass=MessageMeta):
|
||||||
"A message which will only be sent be a frontend"
|
"A message which will only be sent be a frontend"
|
||||||
|
|
||||||
_msgtypes = dict()
|
_msgtypes = dict()
|
||||||
_classes = dict()
|
_classes = dict()
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue