Luna Streams v.1.1.18 documentation
Index
Contents
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
_
_iAmMaster (luna_streams.app.streams_processes.master.MasterProcess attribute)
_masterFuture (luna_streams.app.streams_processes.master.MasterProcess attribute)
A
additionalFields (luna_streams.crutches_on_wheels.cow.monitoring.points.RequestErrorMonitoringPoint attribute)
(luna_streams.crutches_on_wheels.cow.monitoring.points.RequestMonitoringPoint attribute)
additionalTags (luna_streams.crutches_on_wheels.cow.monitoring.points.RequestErrorMonitoringPoint attribute)
(luna_streams.crutches_on_wheels.cow.monitoring.points.RequestMonitoringPoint attribute)
addPointsToBuffer() (luna_streams.crutches_on_wheels.cow.monitoring.influx_adapter.InfluxMonitoringAdapter method)
AiohttpClientError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
ApplicationServerError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
asDict() (luna_streams.crutches_on_wheels.cow.errors.errors.ErrorInfo method)
autorestartStreams() (luna_streams.db.context.DBContext method)
B
BaseMonitoringPoint (class in luna_streams.crutches_on_wheels.cow.monitoring.points)
BaseRequestMonitoringPoint (class in luna_streams.crutches_on_wheels.cow.monitoring.points)
blockStreams() (luna_streams.db.context.DBContext method)
bucket (luna_streams.crutches_on_wheels.cow.monitoring.influx_adapter.InfluxMonitoringAdapter attribute)
buildInfluxFormats() (luna_streams.crutches_on_wheels.cow.monitoring.points.MonitoringPointInfluxFormatBuilder class method)
C
checkStreamAllowedForUpdate() (luna_streams.db.context.DBContext method)
clearBuffer() (luna_streams.crutches_on_wheels.cow.monitoring.influx_adapter.InfluxMonitoringAdapter method)
close() (luna_streams.app.streams_processes.master.MasterProcess method)
(luna_streams.db.context.DBContext method)
configs.config
module
ConfiguratorError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
context (luna_streams.db.context.SingleProcessLock attribute)
convertFieldsToInfluxLineProtocol() (luna_streams.crutches_on_wheels.cow.monitoring.influx_adapter.InfluxMonitoringAdapter static method)
convertFieldsToInfluxLineProtocolNoExtra() (luna_streams.crutches_on_wheels.cow.monitoring.points.MonitoringPointInfluxFormatBuilder static method)
convertFieldsToInfluxLineProtocolWithExtra() (luna_streams.crutches_on_wheels.cow.monitoring.points.MonitoringPointInfluxFormatBuilder static method)
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)
createStreamV2() (luna_streams.db.context.DBContext method)
currentDBTimestamp (luna_streams.db.context.SingleProcessLock attribute)
D
DataBaseError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
DataForMonitoring (class in luna_streams.crutches_on_wheels.cow.monitoring.points)
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)
description (luna_streams.crutches_on_wheels.cow.errors.errors.ErrorInfo attribute)
detail (luna_streams.crutches_on_wheels.cow.errors.errors.ErrorInfo attribute)
downgradeStreamStatus() (luna_streams.db.context.DBContext method)
E
Error (class in luna_streams.crutches_on_wheels.cow.errors.errors)
errorCode (luna_streams.crutches_on_wheels.cow.errors.errors.ErrorInfo attribute)
(luna_streams.crutches_on_wheels.cow.monitoring.points.RequestErrorMonitoringPoint attribute)
ErrorInfo (class in luna_streams.crutches_on_wheels.cow.errors.errors)
eventTime (luna_streams.crutches_on_wheels.cow.monitoring.points.BaseMonitoringPoint attribute)
executionTime (luna_streams.crutches_on_wheels.cow.monitoring.points.RequestMonitoringPoint attribute)
F
fields (luna_streams.crutches_on_wheels.cow.monitoring.points.BaseMonitoringPoint property)
(luna_streams.crutches_on_wheels.cow.monitoring.points.BaseRequestMonitoringPoint property)
(luna_streams.crutches_on_wheels.cow.monitoring.points.RequestErrorMonitoringPoint property)
(luna_streams.crutches_on_wheels.cow.monitoring.points.RequestMonitoringPoint property)
format() (luna_streams.crutches_on_wheels.cow.errors.errors.ErrorInfo method)
fromDict() (luna_streams.crutches_on_wheels.cow.errors.errors.ErrorInfo class method)
G
generateError() (luna_streams.crutches_on_wheels.cow.errors.errors.Error static method)
generatePointStr() (luna_streams.crutches_on_wheels.cow.monitoring.influx_adapter.InfluxMonitoringAdapter method)
GEO_POSITION_COLUMN_TYPE (in module configs.config)
getErrorByErrorCode() (luna_streams.crutches_on_wheels.cow.errors.errors.Error static method)
getGeoPosition() (luna_streams.db.context.DBContext method)
getGroups() (luna_streams.db.context.DBContext method)
getPreview() (luna_streams.db.context.DBContext method)
getRoute() (in module luna_streams.crutches_on_wheels.cow.monitoring.points)
getRuntimeChecks() (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)
getTypeFormat() (luna_streams.crutches_on_wheels.cow.monitoring.points.MonitoringPointInfluxFormatBuilder static method)
Group (class in luna_streams.db.streams_db_tools.models.streams_db_models)
GroupStream (class in luna_streams.db.streams_db_tools.models.streams_db_models)
H
Handler (class in luna_streams.db.streams_db_tools.models.streams_db_models)
heartbeat() (luna_streams.db.context.SingleProcessLock method)
heartbeatInterval (luna_streams.app.streams_processes.master.MasterProcess attribute)
I
ImageProcessingError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
InfluxFormatter (class in luna_streams.crutches_on_wheels.cow.monitoring.points)
InfluxMonitoringAdapter (class in luna_streams.crutches_on_wheels.cow.monitoring.influx_adapter)
InfluxSettings (class in luna_streams.crutches_on_wheels.cow.monitoring.influx_adapter)
initialize() (luna_streams.db.context.DBContext method)
initializeProcess() (luna_streams.app.streams_processes.master.MasterProcess method)
initSDO() (luna_streams.db.context.DBContext class method)
L
LegacyError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LicensesError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LIMIndexer (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LIMManager (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LIMMatcher (class in luna_streams.crutches_on_wheels.cow.errors.errors)
link (luna_streams.crutches_on_wheels.cow.errors.errors.ErrorInfo property)
linkStreamsToGroup() (luna_streams.db.context.DBContext method)
LivenessErrors (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LocalStoreError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
Location (class in luna_streams.db.streams_db_tools.models.streams_db_models)
lockContext (luna_streams.app.streams_processes.master.MasterProcess attribute)
lockProcess() (luna_streams.db.context.SingleProcessLock method)
Log (class in luna_streams.db.streams_db_tools.models.streams_db_models)
logger (luna_streams.app.streams_processes.master.MasterProcess attribute)
(luna_streams.db.context.SingleProcessLock attribute)
luna_streams.app.streams_processes.master
module
luna_streams.crutches_on_wheels.cow.errors.errors
module
luna_streams.crutches_on_wheels.cow.monitoring.influx_adapter
module
luna_streams.crutches_on_wheels.cow.monitoring.points
module
luna_streams.db.context
module
luna_streams.db.streams_db_tools.models.streams_db_models
module
LunaAccounts (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaAdmin (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaApiError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaBackport3 (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaBackport4 (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaCachedMatcher (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaEvents (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaFaces (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaHandlers (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaHealthCheckError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaImageStoreError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaLambda (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaPythonMatcher (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaRemoteSDK (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaSender (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaStreams (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaTasks (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaVideoAgent (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaVideoManager (class in luna_streams.crutches_on_wheels.cow.errors.errors)
LunaVLError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
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.crutches_on_wheels.cow.errors.errors
luna_streams.crutches_on_wheels.cow.monitoring.influx_adapter
luna_streams.crutches_on_wheels.cow.monitoring.points
luna_streams.db.context
luna_streams.db.streams_db_tools.models.streams_db_models
MonitoringPointInfluxFormatBuilder (class in luna_streams.crutches_on_wheels.cow.monitoring.points)
monitorTime() (in module luna_streams.crutches_on_wheels.cow.monitoring.points)
N
name (luna_streams.db.context.SingleProcessLock attribute)
O
obsoletingPeriod (luna_streams.app.streams_processes.master.MasterProcess attribute)
P
prepareSearchQueryFilters() (luna_streams.db.context.DBContext static method)
probe() (luna_streams.db.context.DBContext 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)
RequestErrorMonitoringPoint (class in luna_streams.crutches_on_wheels.cow.monitoring.points)
requestId (luna_streams.crutches_on_wheels.cow.monitoring.points.BaseRequestMonitoringPoint attribute)
RequestMonitoringPoint (class in luna_streams.crutches_on_wheels.cow.monitoring.points)
RESTAPIError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
Restart (class in luna_streams.db.streams_db_tools.models.streams_db_models)
route (luna_streams.crutches_on_wheels.cow.monitoring.points.BaseRequestMonitoringPoint attribute)
RPCError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
S
S3StorageError (class in luna_streams.crutches_on_wheels.cow.errors.errors)
saveFeedback() (luna_streams.db.context.DBContext method)
scheduler (luna_streams.app.streams_processes.master.MasterProcess attribute)
series (luna_streams.crutches_on_wheels.cow.monitoring.points.RequestErrorMonitoringPoint attribute)
(luna_streams.crutches_on_wheels.cow.monitoring.points.RequestMonitoringPoint attribute)
service (luna_streams.crutches_on_wheels.cow.monitoring.points.BaseRequestMonitoringPoint attribute)
sessionId (luna_streams.app.streams_processes.master.MasterProcess attribute)
SingleProcessLock (class in luna_streams.db.context)
(class in luna_streams.db.streams_db_tools.models.streams_db_models)
splitList() (luna_streams.db.context.DBContext method)
statusCode (luna_streams.crutches_on_wheels.cow.monitoring.points.BaseRequestMonitoringPoint attribute)
stopMonitoring() (luna_streams.crutches_on_wheels.cow.monitoring.influx_adapter.InfluxMonitoringAdapter method)
Stream (class in luna_streams.db.streams_db_tools.models.streams_db_models)
STREAM_AUTORESTARTER_INTERVAL (in module configs.config)
STREAM_DOWNGRADE_INTERVAL (in module configs.config)
T
tags (luna_streams.crutches_on_wheels.cow.monitoring.points.BaseMonitoringPoint property)
(luna_streams.crutches_on_wheels.cow.monitoring.points.BaseRequestMonitoringPoint property)
(luna_streams.crutches_on_wheels.cow.monitoring.points.RequestErrorMonitoringPoint property)
(luna_streams.crutches_on_wheels.cow.monitoring.points.RequestMonitoringPoint property)
U
unlinkStreamsFromGroup() (luna_streams.db.context.DBContext method)
updateGroup() (luna_streams.db.context.DBContext method)
updateStream() (luna_streams.db.context.DBContext method)
V
view() (in module luna_streams.db.streams_db_tools.models.streams_db_models)
Contents