CREATEFUNCTION_possible_args() RETURNS jsonbAS

$BODY$

RETURNjson_build_object(

RETURNjsonb_build_object(

'node','node name (default: master)',

'name','job name',

'comments','some comments on job',

IF N>0 THEN

EXECUTE'SELECT array_agg(lll) FROM (SELECT distinct(date_trunc(''min'', unnest::timestamp with time zone)) as lll FROM unnest($1) ORDER BY date_trunc(''min'', unnest::timestamp with time zone)) as Z'

INTO dates USING dates;

cron := COALESCE(cron,'{}'::jsonb)||json_build_object('dates', array_to_json(dates))::jsonb;

cron := COALESCE(cron,'{}'::jsonb)||jsonb_build_object('dates', array_to_json(dates));

END IF;

clean_cron :='{}'::jsonb;

FOR nameINSELECT*FROM unnest('{dates, crontab, onstart, days, hours, wdays, months, minutes}'::text[])

LOOP

CREATEFUNCTIONcreate_job(crontext, commandtext, nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('cron', cron,'command', command,'node', node)::jsonb);

RETURN create_job(jsonb_build_object('cron', cron,'command', command,'node', node));

END

$BODY$

LANGUAGE plpgsql

CREATEFUNCTIONcreate_job(dttimestamp with time zone, commandtext, nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('date', dt::text,'command', command,'node', node)::jsonb);

RETURN create_job(jsonb_build_object('date', dt::text,'command', command,'node', node));

END

$BODY$

LANGUAGE plpgsql

CREATEFUNCTIONcreate_job(dtstimestamp with time zone[], commandtext, nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('dates', array_to_json(dts),'command', command,'node', node)::jsonb);

RETURN create_job(jsonb_build_object('dates', array_to_json(dts),'command', command,'node', node));

END

$BODY$

LANGUAGE plpgsql

CREATEFUNCTIONcreate_job(crontext, commandstext[], nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('cron', cron,'commands', array_to_json(commands),'node', node)::jsonb);

RETURN create_job(jsonb_build_object('cron', cron,'commands', array_to_json(commands),'node', node));

END

$BODY$

LANGUAGE plpgsql

CREATEFUNCTIONcreate_job(dttimestamp with time zone, commandstext[], nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('date', dt::text,'commands', array_to_json(commands),'node', node)::jsonb);

RETURN create_job(jsonb_build_object('date', dt::text,'commands', array_to_json(commands),'node', node));

END

$BODY$

LANGUAGE plpgsql

CREATEFUNCTIONcreate_job(dtstimestamp with time zone[], commandstext[], nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('dates', array_to_json(dts),'commands', array_to_json(commands),'node', node)::jsonb);

RETURN create_job(jsonb_build_object('dates', array_to_json(dts),'commands', array_to_json(commands),'node', node));

END

$BODY$

LANGUAGE plpgsql

LANGUAGE plpgsql

SECURITY DEFINERset search_pathFROM CURRENT;

CREATEFUNCTIONset_job_attribute(jobIdinteger, nametext, value jsonb) RETURNSbooleanAS

$BODY$

IF name<>'rule' THEN

RAISE EXCEPTION'key % cannot have a jsonb value. Only "rule" allowed', name;

END IF;

RETURN set_job_attributes(jobId, jsonb_build_object(name, value));

END

$BODY$

LANGUAGE plpgsql

SECURITY DEFINERset search_pathFROM CURRENT;

CREATEFUNCTIONset_job_attribute(jobIdinteger, nametext, value anyarray) RETURNSbooleanAS

$BODY$

IF name<>'dates'AND name<>'commands' THEN

RAISE EXCEPTION'key % cannot have an array value. Only dates, commands allowed', name;

END IF;

RETURN set_job_attributes(jobId,json_build_object(name, array_to_json(value))::jsonb);

RETURN set_job_attributes(jobId,jsonb_build_object(name, array_to_json(value)));

END

$BODY$

LANGUAGE plpgsql

attrs jsonb;

IF name='dates'OR name='commands' THEN

attrs := json_build_object(name, array_to_json(value::text[]));

attrs := jsonb_build_object(name, array_to_json(value::text[]));

ELSIF name='rule' THEN

attrs := jsonb_build_object('rule', value::jsonb);

ELSE

attrs :=json_build_object(name, value);

attrs :=jsonb_build_object(name, value);

END IF;

RETURN set_job_attributes(jobId, attrs);

END