ЕСОЗ - публічна документація
Jabba service
Jabba provides api to create a new asynchronous job, which will be stored in PostgreSQL and processed through Kafka. Jabba just a job manager and stores result of callback with meta data. Jobs logic is on the side of the caller.
Currently used for the following:
name |
---|
Deactivate legal entity |
Synchronize legal entity with edr |
Reset persons authentication method |
Terminate declarations |
Deactivate persons |
Unverify legal entity |
Merge legal entities |
Create new Job
The first argument is list of tasks
or one task
map. Task is a map with two atom fields:
:callback
the callback is being invoked. It is called when message consumed from Kafka. The result of the
callback
must return:{:ok, map}
or:ok
in case of success
{:error, map}
in case of error
:name
(optional) - name of the task The second argument defines a jobtype
and could be used as a filter for jobs searching Options:strategy
job processing strategy. Available:
:sequentially
. Read more in about strategy below:meta
additional data for the job that stored in database and could be used as a filter for jobs searching
:name
job name that stored in database
Strategies
:sequentially
Default strategy. Execute each job task step by step. In case of error, task and job will be marked as failed. All tasks after failed task will be marked as
ABORTED
:concurrent
Execute job tasks concurrently. In case of error, task and job will be marked as failed. Returns
{:ok, %Job{}
tuple with job that was created or{:error, term}
tuple with error reason
Examples
iex> Jabba.RPC.create_job( {"il", Core.RPC, :deactivate_legal_entity, ["2e7141ac-d021-448f-a71a-f6ea454a06b8"]}, "deactivation_legal_entity", [ meta: %{ request_id: "197bed61-5e4b-49d1-b064-5830c8f18146", legal_entity_id: "2e7141ac-d021-448f-a71a-f6ea454a06b8" } ] ) {:ok, %{ id: "6868d53f-6e37-46bc-af34-29e650446310", name: "Job name", type: "deactivate_legal_entity", status: "PENDING", strategy: "SEQUENTIALLY", meta: %{}, ended_at: #DateTime<2019-02-04 14:08:42.434612Z>, inserted_at: #DateTime<2019-02-04 14:08:42.434612Z>, updated_at: #DateTime<2019-02-04 14:08:42.434619Z> }}
Get Job by id
Examples
iex> Jabba.RPC.get_job()
{:ok, %{
id: "6868d53f-6e37-46bc-af34-29e650446310",
name: "Job name",
type: "deactivate_legal_entity",
status: "PROCESSED",
strategy: "SEQUENTIALLY",
meta: %{},
ended_at: #DateTime<2019-02-04 14:08:42.434612Z>,
inserted_at: #DateTime<2019-02-04 14:08:42.434612Z>,
updated_at: #DateTime<2019-02-04 14:08:42.434619Z>
}}
Search for Jobs
Check available formats for filter here GitHub - edenlabllc/ecto_filter Available parameters:
Parameter | Type | Example |
---|---|---|
filter |
|
|
order_by |
|
|
cursor |
|
|
Examples
iex> Jabba.RPC.search_jobs([{:status, :equal, "PROCESSED"}], [desc: :status], {0, 10})
{:ok, [%{
id: "6868d53f-6e37-46bc-af34-29e650446310",
name: "Job name",
type: "deactivate_legal_entity",
status: "PROCESSED",
strategy: "SEQUENTIALLY",
meta: %{},
ended_at: #DateTime<2019-02-04 14:08:42.434612Z>,
inserted_at: #DateTime<2019-02-04 14:08:42.434612Z>,
updated_at: #DateTime<2019-02-04 14:08:42.434619Z>
}]}
Search for Tasks
Check available formats for filter here GitHub - edenlabllc/ecto_filter Available parameters:
Parameter | Type | Example |
---|---|---|
filter |
|
|
order_by |
|
|
cursor |
|
|
Examples
Currently used for the following tasks:
Terminate declaration
ЕСОЗ - публічна документація