Packages
bpe
7.5.3
13.5.22-aleph
11.4.16
11.4.15
11.4.14
11.4.13
9.9.7
9.9.6
8.12.4
8.12.3
8.12.1
8.12.0
retired
8.2.1
8.2.0
8.1.0
7.11.0
7.10.4
7.10.3
7.10.2
7.10.1
7.9.1
7.9.0
7.8.2
7.8.1
7.8.0
7.6.4
7.6.3
7.6.2
7.6.1
7.6.0
7.5.15
7.5.14
7.5.13
7.5.12
7.5.11
7.5.10
7.5.9
7.5.8
7.5.7
7.5.6
7.5.5
7.5.3
7.5.2
7.5.1
7.5.0
7.4.11
7.4.10
7.4.9
7.4.8
7.4.7
7.4.6
7.4.5
7.4.4
7.4.3
7.4.2
7.4.1
7.4.0
7.3.0
7.2.8
7.2.7
7.2.6
7.1.6
7.1.5
7.1.4
7.1.3
7.1.2
6.12.7
6.12.6
6.12.5
6.12.3
6.12.2
6.12.1
6.12.0
6.11.0
6.10.0
6.5.3
6.5.2
6.5.1
6.5.0
6.4.0
6.3.0
5.12.0
5.11.4
5.11.3
5.11.2
5.11.1
5.11.0
5.8.7
5.8.6
5.8.5
5.8.4
5.8.3
5.8.2
5.8.1
5.8.0
5.7.0
5.6.0
5.5.2
5.5.1
5.4.0
5.2.0
5.1.3
5.1.2
5.1.1
4.12.4
4.12.3
4.12.2
4.12.1
4.12.0
4.11.8
4.11.7
4.11.6
4.11.5
4.11.4
4.11.3
4.11.2
4.11.1
4.11.0
4.10.24
4.10.23
4.10.22
4.10.21
4.10.20
4.10.19
4.10.18
4.10.17
4.10.16
4.10.15
4.10.14
4.10.13
4.10.12
4.10.11
4.10.10
4.10.9
4.10.8
4.10.7
4.10.6
4.10.5
4.10.4
4.10.3
4.10.2
4.10.1
4.10.0
4.9.18
4.9.17
4.9.16
4.9.15
4.9.14
4.9.13
4.9.12
4.9.11
4.9.10
4.9.9
4.9.8
4.9.7
4.9.6
4.9.5
4.9.4
4.9.3
4.9.2
4.9.1
4.9.0
4.8.1
4.8.0
4.7.5
4.7.3
4.7.2
4.7.1
4.7.0
4.6.0
2.4.0
0.7.16
ERP/1: RTP GST WebRTC ICE SDP H.264 H.265 MP4 MPEG-2 HLS HEVC
Current section
Files
Jump to
Current section
Files
include/bpe.hrl
-ifndef(BPE_HRL).
-define(BPE_HRL, true).
-include_lib("kvs/include/cursors.hrl").
-define(DEFAULT_MODULE, application:get_env(bpe,default_module,bpe_xml)).
-define(TASK, id=[] :: list(),
name=[] :: list() | binary(),
input=[] :: list(),
output=[] :: list(),
prompt=[] :: list(tuple()),
roles=[] :: list(atom()),
etc=[] :: list({term(),term()}) ).
-define(EVENT, id=[] :: list() | atom(),
name=[] :: list() | binary(),
prompt=[] :: list(tuple()),
etc=[] :: list({term(),term()}),
payload=[] :: [] | binary(),
timeout=[] :: [] | #timeout{} ).
-define(CYCLIC, timeDate=[] :: [] | binary(),
timeDuration=[] :: [] | binary(),
timeCycle=[] :: [] | binary() ).
-define(CONDITION_TYPES, [service, compare]).
-record(timeout, { spec= [] :: term() }).
-type condition() :: {compare,BpeDocParam :: {atom(),term()},Field :: integer(), ConstCheckAgainst :: term()}
| {service,atom(),atom()}
| {service,atom()}.
-type callback() :: {callback,atom(),atom()} | {callback,atom()}.
-record(sequenceFlow, { id=[] :: list(),
name=[] :: list() | binary(),
condition=[] :: [] | condition() | binary(),
source=[] :: list(),
target=[] :: list(integer()) | list(list()),
callbacks = [] :: [] | list(callback()) }).
-record(beginEvent , { ?TASK }).
-record(endEvent, { ?TASK }).
-record(task, { ?TASK }).
-record(userTask, { ?TASK }).
-record(serviceTask, { ?TASK }).
-record(receiveTask, { ?TASK, reader=[] :: #reader{} }).
-record(sendTask, { ?TASK, writer=[] :: #writer{} }).
-record(gateway, { ?TASK, type= parallel :: gate(), def=[] :: list() }).
-record(messageEvent, { ?EVENT }).
-record(messageBeginEvent, { ?EVENT }).
-record(boundaryEvent,{ ?EVENT, ?CYCLIC }).
-record(timeoutEvent, { ?EVENT, ?CYCLIC }).
-type tasks() :: #task{} | #serviceTask{} | #userTask{} | #receiveTask{} | #sendTask{} | #beginEvent{} | #endEvent{}.
-type events() :: #messageEvent{} | #boundaryEvent{} | #timeoutEvent{}.
-type procId() :: [] | string() | integer() | {atom(),any()}.
-type gate() :: exclusive | parallel | inclusive | complex | event.
-record(ts, { time= [] :: term() }).
-record(step, { id = 0 :: integer(), proc = "" :: list() }).
-record(role, { id = [] :: list(), name :: binary(), tasks = [] :: term() }).
-record(sched, { id = [] :: [] | #step{},
prev=[] :: [] | integer(),
next=[] :: [] | integer(),
pointer = -1 :: integer(),
state = [] :: list(list()) }).
-record(status , { id = [] :: [] | atom(),
state = [] :: [] | term() }).
-record(executor, { id = [] :: [] | term(),
object = [] :: [] | tuple(),
received = [] :: [] | #ts{},
started = [] :: [] | #ts{},
executed = [] :: [] | #ts{},
status = [] :: [] | #status{} }).
-record(hist, { id = [] :: [] | #step{},
prev = [] :: [] | integer(),
next = [] :: [] | integer(),
name = [] :: [] | binary() | list(),
task = [] :: [] | atom() | list() | #task{} | #sequenceFlow{} | condition(),
docs = [] :: list(tuple()),
time = [] :: [] | #ts{},
executors = [] :: [] | list(#executor{}) }).
-record(process, { id = [] :: procId(),
prev = [] :: [] | integer(),
next = [] :: [] | integer(),
name = [] :: [] | binary() | string() | atom(),
desc = [] :: list() | binary(),
vsn = [] :: term(),
feeds = [] :: list(),
module = [] :: [] | atom(),
roles = [] :: term(),
tasks = [] :: list(tasks()),
events = [] :: list(events()),
flows = [] :: list(#sequenceFlow{}),
docs = [] :: list(tuple()),
options = [] :: term(),
xml = [] :: list(),
svg = [] :: list(),
timer = [] :: [] | reference(),
notifications = [] :: [] | term(),
result = [] :: [] | binary(),
started = [] :: [] | #ts{},
modified = [] :: [] | #ts{},
finished = [] :: [] | #ts{},
monitor = [] :: [] | integer(),
parentMonitor = [] :: [] | integer(),
parent = [] :: [] | procId(),
children = [] :: list(procId()),
beginEvent = [] :: list() | atom(),
endEvent = [] :: list() | atom(),
status = [] :: term(), % future reserved
current = [] :: term(),
rules = [] :: term(),
userStarted = [] :: term(),
userModified = [] :: term(),
userFinished = [] :: term(),
params = [] :: term(),
filters = [] :: term(),
etc = [] :: term(),
flags = [] :: term(),
executors = [] :: list(#executor{})
}).
-record(subProcess, { name=[] :: [] | atom(),
diagram= #process{} :: #process{} }).
-record(procRec, { id = [] :: procId(),
name = [] :: list(),
roles = [] :: list(atom()),
etc = [] :: term() }).
-record(monitor, { id = [] :: procId(),
prev = [] :: [] | integer(),
next = [] :: [] | integer(),
name = [] :: list(),
roles = [] :: list(#role{}),
ogrName = [] :: list(),
status = [] :: term(),
parent = [] :: [] | integer(),
children = [] :: [] | list() }).
-record(continue, { fn = [] :: atom(),
args = [] :: [] | list(),
module = [] :: [] | atom(),
type = bpe :: atom() }).
-record(result, { type = reply :: atom(),
reply = [] :: term(),
state = [] :: term(),
reason = normal :: term(),
continue = [] :: term(),
opt = [] :: term(),
executed = [] :: list(#executor{}) }).
-record('Next', { id=[] :: [] | binary() }).
-record('Proc', { id=[] :: [] | binary() }).
-record('Load', { id=[] :: [] | binary() }).
-record('Hist', { id=[] :: [] | binary() }).
-record('Make', { proc=[] :: [] | #process{} | binary(), docs=[] :: [] | list(tuple()) }).
-record('Amen', { id=[] :: [] | binary(), docs=[] :: [] | list(tuple()) }).
-endif.