Privatix network
General
Search…
develop
What is Privatix Network
​Privatix core
Privatix core
Software components
Concepts
Messaging
Payments
Ethereum
Jobs
Jobs
Other
Service
Support
Install
Feedback
Knowledge base
Requirements for Agent and Client
How to get PRIX
What is Simple and Advanced client modes
How to run a node
How to buy VPN service
How to open ports for Agent
How to customize offering (for CLI)
How to withdraw funds
Traffic prices formation
How to "clean up"
Disclaimer for Agents
Tems of use
Powered By GitBook
Jobs
​Jobs plays important role in application workflows. They are created by:
Creator
Description
user
by user through UI API
billing monitor
by billing monitor
ethereum monitor
by ethereum monitor
job
by another job
session server
by session server triggered by adapter, on service status change

Names

Jobs names are defined in data model and mapped to job types​
Job type is all jobs with same name.

Job type configuration

Each job type may have its custom configuration taken from privatix core config.

Job type configurable parameters

TryLimit - Maximum retry count
TryPeriod - Delay between retries
FirstStartDelay - Delay on first start
Duplicated - Allow duplicate of job type per object

Job type configuration example

1
"clientPreChannelCreate": {
2
"TryLimit": 3,
3
"TryPeriod": 60000,
4
"FirstStartDelay": 25000,
5
"Duplicated": true
6
}
Copied!

Job structure

1
type Job struct {
2
ID string `reform:"id,pk"`
3
Type string `reform:"type"`
4
Status string `reform:"status"`
5
RelatedType string `reform:"related_type"`
6
RelatedID string `reform:"related_id"`
7
CreatedAt time.Time `reform:"created_at"`
8
NotBefore time.Time `reform:"not_before"`
9
CreatedBy string `reform:"created_by"`
10
TryCount uint8 `reform:"try_count"`
11
Data []byte `reform:"data"`
Copied!
where
ID - uuid
Type - job type
Status - Job status
RelatedType - related object type​
RelatedID - database id of related object
CreatedAt - time when job was created. Organize sequence
NotBefore - delaying start of job
CreatedBy - who produced this job
TryCount - number of times was job executed
Data - additional data that can be processed during job execution
Each job is related to some object using RelatedType and RelatedID. It may also have some data that is stored in Data.
Jobs can be scheduled to start at specific time using NotBefore. They can be retried several times when TryCount didn't reached TryLimit of job type configuration.

Job queue

Job queue is implemented using database table. Its configuration is done in core config.

Job queue configuration

1
type Config struct {
2
CollectJobs uint // Number of jobs to process for collect-iteration.
3
CollectPeriod uint // Collect-iteration period, in milliseconds.
4
WorkerBufLen uint // Worker buffer length.
5
Workers uint // Number of workers, 0 means number of CPUs.
6
​
7
TypeConfig // Default type configuration.
8
Types map[string]TypeConfig // Type-specific overrides.
9
}
Copied!
Function queue.Add() will check, if desired job can be created, create it or return an error.
Job queue workers - are threads, that periodically scans job queue, retrieves jobs that should be processed and executes them. Workers can run in parallel, can retrieve error codes from underlying functions. Number of workers are defined in dappctrl.config.json. Jobs that relates to same object are processed by single worker, preventing race.
Job queue gets jobs from database table jobs. Jobs related to single object (e.g. particular offering) processed sequentially, but jobs for different objects (e.g. two different offerings) maybe processed in parallel. Sequence is defined using sorting by CreatedAt field.

Job status

Status
Description
Active
Processing or to be processed
Failed
Permanently failed. Retry threshold is reached.
Cancelled
Will be excluded from processing. If still running, result will be ignored (don't care).
Done
Successfully finished.

Job workflow schema

​view schema​

Job handlers

When job executed its job handler is invoked.

Agent jobs

AgentAfterChannelCreate

AgentAfterChannelCreate - registers client and creates AgentPreEndpointMsgCreate job.
Created by:
  • Ethereum monitor events LogChannelCreated or LogOfferingPopedUp

AgentAfterChannelTopUp

AgentAfterChannelTopUp - updates deposit of a channel in Agents database.
Created by:
  • Ethereum monitor event LogChannelToppedUp

AgentAfterUncooperativeCloseRequest

AgentAfterUncooperativeCloseRequest - sets channel's status to challenge period.
Created by:
  • Ethereum monitor event LogChannelCloseRequested

AgentAfterUncooperativeClose

AgentAfterUncooperativeClose - marks channel closed uncooperatively.
Created by:
  • Ethereum monitor event LogUnCooperativeChannelClose

AgentAfterCooperativeClose

AgentAfterCooperativeClose - marks channel as closed cooperatively.
Created by:
  • Ethereum monitor event LogUnCooperativeChannelClose

AgentPreServiceSuspend

AgentPreServiceSuspend - marks service as suspended.
Created by:
  • UI API method changeChannelStatus
  • Agent billing monitor VerifyBillingLags()

AgentPreServiceUnsuspend

AgentPreServiceUnsuspend - marks service as active.
Created by:
  • UI API method changeChannelStatus
  • Agent billing monitor VerifySuspendedChannelsAndTryToUnsuspend()

AgentPreServiceTerminate

AgentPreServiceTerminate - terminates the service.
Created by:
  • UI API method changeChannelStatus
  • Agent billing monitor VerifyUnitsBasedChannels()
  • Agent billing monitor VerifyChannelsForInactivity()
  • Agent billing monitor VerifySuspendedChannelsAndTryToTerminate()

AgentPreEndpointMsgCreate

AgentPreEndpointMsgCreate - prepares endpoint message to be sent to client.
Created by:
  • Job AgentAfterChannelCreate

AgentPreOfferingMsgBCPublish

AgentPreOfferingMsgBCPublish - publishes offering to blockchain.
Created by:
  • UI API method ChangeOfferingStatus

AgentAfterOfferingMsgBCPublish

AgentAfterOfferingMsgBCPublish - updates offering status and account balance.
Created by:
  • Ethereum monitor event LogOfferingCreated

AgentPreOfferingPopUp

AgentPreOfferingPopUp - pop ups an offering.
Created by:
  • UI API method ChangeOfferingStatus

AgentAfterOfferingPopUp

AgentAfterOfferingPopUp - updates the block number when the offering was popped up.
Created by:
  • Ethereum monitor event LogOfferingPopedUp

AgentPreOfferingDelete

AgentPreOfferingDelete - calls PSC remove an offering.
Created by:
  • UI API method ChangeOfferingStatus

AgentAfterOfferingDelete

AgentAfterOfferingDelete - set offering status to 'remove'
Created by:
  • Ethereum monitor event LogOfferingDeleted

Client jobs

ClientAfterOfferingDelete

ClientAfterOfferingDelete - sets offer status to remove
Created by:
  • Ethereum monitor event LogOfferingDeleted

ClientAfterOfferingPopUp

ClientAfterOfferingPopUp - updates offering in DB or retrieves from Agent and stores in DB.
Created by:
  • Ethereum monitor event LogOfferingPopedUp

ClientPreChannelCreate

ClientPreChannelCreate - triggers a channel creation.
Created by:
  • UI API method acceptOffering

ClientAfterChannelCreate

ClientAfterChannelCreate - activates channel and triggers access message retrieval
Created by:
  • Ethereum monitor event LogChannelCreated

ClientEndpointCreate

ClientEndpointCreate - decodes endpoint message, saves it in the DB and triggers product configuration.
Created by:
  • Job ClientAfterChannelCreate

ClientAfterUncooperativeClose

ClientAfterUncooperativeClose - changes channel status to closed uncooperatively.
Created by:
  • Ethereum monitor event LogUnCooperativeChannelClose

ClientAfterCooperativeClose

ClientAfterCooperativeClose - changes channel status to closed cooperatively and launches termination of service.
Created by:
  • Ethereum monitor event LogCooperativeChannelClose

ClientPreUncooperativeClose

ClientPreUncooperativeClose - terminates service.
Created by:
  • Job ClientAfterUncooperativeCloseRequest

ClientPreChannelTopUp

ClientPreChannelTopUp - checks client balance and creates transaction to increase channel deposit.
Created by:
  • UI API method TopUpChannel

ClientAfterChannelTopUp

ClientAfterChannelTopUp - updates deposit of a channel in local DB.
Created by:
  • Ethereum monitor event LogChannelToppedUp

ClientPreUncooperativeCloseRequest

ClientPreUncooperativeCloseRequest - requests uncooperative close of channel. Challenge period started.
Created by:
  • UI API method changeChannelStatus

ClientAfterUncooperativeCloseRequest

ClientAfterUncooperativeCloseRequest - waits for channel to close uncooperatively, starts the service termination process.
Created by:
  • Ethereum monitor event LogUnCooperativeChannelClose

ClientPreServiceTerminate

ClientPreServiceTerminate - terminates service.
Created by:
  • Job ClientAfterCooperativeClose
  • Client billing postPayload()
  • Client billing processChannel()
  • UI API method ChangeChannelStatus

ClientPreServiceSuspend

ClientPreServiceSuspend - suspends service.
Created by:
  • UI API method ChangeChannelStatus

ClientPreServiceUnsuspend

ClientPreServiceUnsuspend - activates service.
Created by:
  • UI API method ChangeChannelStatus

ClientAfterOfferingMsgBCPublish

ClientAfterOfferingMsgBCPublish - creates offering.
Created by:
  • Ethereum monitor event LogOfferingCreated

ClientCompleteServiceTransition

ClientCompleteServiceTransition - complete service state transition. Service status changes.
Created by:
  • Session server (adapter)

Common jobs

PreAccountAddBalanceApprove

PreAccountAddBalanceApprove - approve balance if amount exists.
Created by:
  • UI API method transferTokens

PreAccountAddBalance

PreAccountAddBalance - adds balance to PSC.
Created by:
  • Ethereum monitor PTC event Approval

AfterAccountAddBalance

AfterAccountAddBalance - updates PSC and PTC balance of an account.
Created by:
  • Ethereum monitor PTC event Transfer

PreAccountReturnBalance

PreAccountReturnBalance - returns from PSC to PTC.
Created by:
  • UI API method transferTokens

AfterAccountReturnBalance

AfterAccountReturnBalance - updates PSC and PTC balance of an account.
Created by:
  • Ethereum monitor PTC event Transfer

AccountUpdateBalances

AccountUpdateBalances - updates PTC, PSC and ETH account balance values.
Created by:
  • Job AgentAfterUncooperativeClose
  • Job AgentAfterCooperativeClose
  • Job AgentAfterOfferingMsgBCPublish
  • Job AgentAfterOfferingDelete
  • Job ClientAfterUncooperativeClose
  • Job ClientAfterCooperativeClose
  • Job ClientAfterChannelCreate
  • Job afterChannelTopUp
  • UI API ImportAccountFromHex
  • UI API ImportAccountFromJSON
  • UI API UpdateBalance

DecrementCurrentSupply

DecrementCurrentSupply - finds offering and decrements its current supply for Client.
Created by:
  • Ethereum monitor event LogChannelCreated

IncrementCurrentSupply

IncrementCurrentSupply - finds offering and increments its current supply for Client.
Previous
Jobs
Next
Other
Last modified 2yr ago
Copy link
Contents
Names
Job type configuration
Job structure
Job queue
Job status
Job handlers
Agent jobs
Client jobs
Common jobs