1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
% Licensed under the Apache License, Version 2.0 (the "License"); you may not
% use this file except in compliance with the License. You may obtain a copy of
% the License at
%
% http://www.apache.org/licenses/LICENSE-2.0
%
% Unless required by applicable law or agreed to in writing, software
% distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
% WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
% License for the specific language governing permissions and limitations under
% the License.
% JobOpts map/json field definitions
%
-define(OPT_PRIORITY, <<"priority">>).
-define(OPT_DATA, <<"data">>).
-define(OPT_CANCEL, <<"cancel">>).
-define(OPT_RESUBMIT, <<"resubmit">>).
% These might be in a fabric public hrl eventually
%
-define(uint2bin(I), binary:encode_unsigned(I, little)).
-define(bin2uint(I), binary:decode_unsigned(I, little)).
-define(UNSET_VS, {versionstamp, 16#FFFFFFFFFFFFFFFF, 16#FFFF}).
-define(METADATA_VERSION_KEY, <<"$metadata_version_key$">>).
% Data model definitions
%
-define(JOBS, 51). % coordinate with fabric2.hrl
-define(DATA, 1).
-define(PENDING, 2).
-define(WATCHES, 3).
-define(ACTIVITY_TIMEOUT, 4).
-define(ACTIVITY, 5).
% Couch jobs event notifier tag
-define(COUCH_JOBS_EVENT, '$couch_jobs_event').
-type jtx() :: map().
-type job_id() :: binary().
-type job_type() :: tuple() | binary() | non_neg_integer().
-type job_opts() :: map().
-type job_state() :: running | pending | finished.
-type job_priority() :: tuple() | binary() | non_neg_integer().
-type job_subscription() :: {pid(), reference()}.
-type job_callback() :: fun((job_subscription(), job_type(), job_id(),
job_state()) -> ok).
-type worker_lock() :: binary().
|
