plproxy query setup

gistfile1.txt

CREATE FUNCTION "plproxy"."get_cluster_config"(IN cluster_name text, OUT "key" text, OUT val text) RETURNS SETOF "record" 
    AS $BODY$
begin
    key := 'statement_timeout';
    val := 60;
    return next;
    return;
end; $BODY$
    LANGUAGE plpgsql
    COST 100
    ROWS 1000
    CALLED ON NULL INPUT
    SECURITY INVOKER
    VOLATILE;
ALTER FUNCTION "plproxy"."get_cluster_config"(IN cluster_name text, OUT "key" text, OUT val text) OWNER TO "turbo";

CREATE FUNCTION "plproxy"."get_cluster_partitions"(IN cluster_name text) RETURNS SETOF "text" 
    AS $BODY$
BEGIN
    IF cluster_name = 'sem' THEN
        RETURN NEXT 'dbname=kwinsights host=code1 user=turbo';
        RETURN NEXT 'dbname=kwinsights host=code2 user=turbo';
        RETURN NEXT 'dbname=kwinsights host=code5 user=turbo';
        RETURN NEXT 'dbname=kwinsights host=code6 user=turbo';
        RETURN;
    END IF;
    RAISE EXCEPTION 'Unknown cluster';
END;
$BODY$
    LANGUAGE plpgsql
    COST 100
    ROWS 1000
    CALLED ON NULL INPUT
    SECURITY INVOKER
    VOLATILE;
ALTER FUNCTION "plproxy"."get_cluster_partitions"(IN cluster_name text) OWNER TO "turbo";

CREATE FUNCTION "plproxy"."get_cluster_version"(IN cluster_name text) RETURNS "int4" 
    AS $BODY$
BEGIN
    IF cluster_name = 'sem' THEN
        RETURN 1;
    END IF;
    RAISE EXCEPTION 'Unknown cluster';
END;
$BODY$
    LANGUAGE plpgsql
    COST 100
    CALLED ON NULL INPUT
    SECURITY INVOKER
    VOLATILE;
ALTER FUNCTION "plproxy"."get_cluster_version"(IN cluster_name text) OWNER TO "turbo";