Module: Schematic::DataStream

Defined in:
lib/schematic/datastream/merge.rb,
lib/schematic/datastream/client.rb,
lib/schematic/datastream/resource_cache.rb,
lib/schematic/datastream/websocket_client.rb

Defined Under Namespace

Modules: Merge Classes: Client, EvaluationError, ResourceCache, WebSocketClient

Constant Summary collapse

DEFAULT_CACHE_TTL =

24 hours in seconds

86_400
MAX_CACHE_TTL =

30 days in seconds

30 * 86_400
DEFAULT_CACHE_SIZE =
1000
RESOURCE_TIMEOUT =

seconds

30
REPLICATOR_HEALTH_URL =
"http://localhost:8090/ready"
REPLICATOR_HEALTH_INTERVAL =

seconds

30
WRITE_WAIT =

seconds

10
PONG_WAIT =

seconds

60
PING_PERIOD =

seconds (PONG_WAIT * 9/10)

54
MAX_RECONNECT_ATTEMPTS =
10
MIN_RECONNECT_DELAY =

seconds

1
MAX_RECONNECT_DELAY =

seconds

30
ENTITY_TYPE_COMPANY =
"rulesengine.Company"
ENTITY_TYPE_COMPANIES =
"rulesengine.Companies"
ENTITY_TYPE_USER =
"rulesengine.User"
ENTITY_TYPE_USERS =
"rulesengine.Users"
ENTITY_TYPE_FLAG =
"rulesengine.Flag"
ENTITY_TYPE_FLAGS =
"rulesengine.Flags"
MESSAGE_TYPE_FULL =
"full"
MESSAGE_TYPE_PARTIAL =
"partial"
MESSAGE_TYPE_DELETE =
"delete"
MESSAGE_TYPE_ERROR =
"error"