Luna Streams v.0.5.2 documentation
Index
Contents
Index
_
|
A
|
B
|
C
|
D
|
G
|
H
|
I
|
L
|
M
|
N
|
P
|
R
|
S
|
U
_
_iAmMaster (luna_streams.app.streams_processes.master.MasterProcess attribute)
_masterFuture (luna_streams.app.streams_processes.master.MasterProcess attribute)
A
autorestartStreams() (luna_streams.db.context.DBContext method)
B
blockStreams() (luna_streams.db.context.DBContext method)
C
checkStreamAllowedForUpdate() (luna_streams.db.context.DBContext method)
configs.config
module
context (luna_streams.db.context.SingleProcessLock attribute)
countGroups() (luna_streams.db.context.DBContext method)
countStreams() (luna_streams.db.context.DBContext method)
createGroup() (luna_streams.db.context.DBContext method)
createStream() (luna_streams.db.context.DBContext method)
currentDBTimestamp (luna_streams.db.context.SingleProcessLock attribute)
D
DB_CONNECT_TIMEOUT (in module configs.config)
DBContext (class in luna_streams.db.context)
DBJob (class in luna_streams.app.streams_processes.master)
deleteStreamsByDeleteFilters() (luna_streams.db.context.DBContext method)
deleteStreamsLogs() (luna_streams.db.context.DBContext method)
denyStreamAutoRestart() (luna_streams.db.context.DBContext static method)
downgradeStreamStatus() (luna_streams.db.context.DBContext method)
G
GEO_POSITION_COLUMN_TYPE (in module configs.config)
getGeoPosition() (luna_streams.db.context.DBContext method)
getGroups() (luna_streams.db.context.DBContext method)
getPreview() (luna_streams.db.context.DBContext method)
getStreams() (luna_streams.db.context.DBContext method)
getStreamsLogs() (luna_streams.db.context.DBContext method)
getStreamsQueue() (luna_streams.db.context.DBContext method)
H
heartbeat() (luna_streams.db.context.SingleProcessLock method)
heartbeatInterval (luna_streams.app.streams_processes.master.MasterProcess attribute)
I
initSDO() (luna_streams.db.context.DBContext class method)
L
linkStreamsToGroup() (luna_streams.db.context.DBContext method)
lockContext (luna_streams.app.streams_processes.master.MasterProcess attribute)
lockProcess() (luna_streams.db.context.SingleProcessLock method)
logger (luna_streams.app.streams_processes.master.MasterProcess attribute)
(luna_streams.db.context.SingleProcessLock attribute)
luna_streams.app.streams_processes.master
module
luna_streams.db.context
module
M
MASTER_HEARTBEAT_INTERVAL (in module configs.config)
MasterProcess (class in luna_streams.app.streams_processes.master)
MAX_ARRAY_LEN_FILTERS (in module configs.config)
module
configs.config
luna_streams.app.streams_processes.master
luna_streams.db.context
N
name (luna_streams.db.context.SingleProcessLock attribute)
P
prepareSearchQueryFilters() (luna_streams.db.context.DBContext static method)
pullStreamsQueue() (luna_streams.db.context.DBContext method)
putStream() (luna_streams.db.context.DBContext method)
R
removeGroup() (luna_streams.db.context.DBContext method)
removeStreams() (luna_streams.db.context.DBContext method)
S
saveFeedback() (luna_streams.db.context.DBContext method)
scheduler (luna_streams.app.streams_processes.master.MasterProcess attribute)
sessionId (luna_streams.app.streams_processes.master.MasterProcess attribute)
shutdown() (luna_streams.app.streams_processes.master.MasterProcess method)
SingleProcessLock (class in luna_streams.db.context)
STREAM_AUTORESTARTER_INTERVAL (in module configs.config)
STREAM_DOWNGRADE_INTERVAL (in module configs.config)
U
unlinkStreamsFromGroup() (luna_streams.db.context.DBContext method)
updateGroup() (luna_streams.db.context.DBContext method)
updateStream() (luna_streams.db.context.DBContext method)
Contents