Uses of Class
org.nuxeo.lib.stream.log.LogLag
-
Packages that use LogLag Package Description org.nuxeo.ecm.restapi.server.jaxrs.management org.nuxeo.lib.stream.log The Log interface with Chronicle and Kafka implementation.org.nuxeo.lib.stream.log.chronicle org.nuxeo.lib.stream.log.internals org.nuxeo.lib.stream.log.kafka org.nuxeo.lib.stream.tools.command -
-
Uses of LogLag in org.nuxeo.ecm.restapi.server.jaxrs.management
Method parameters in org.nuxeo.ecm.restapi.server.jaxrs.management with type arguments of type LogLag Modifier and Type Method Description protected String
StreamObject. lagAsJson(String consumer, String stream, List<LogLag> lags)
protected String
StreamObject. positionChangeAsJson(String consumer, String stream, List<LogLag> before, List<LogLag> after)
-
Uses of LogLag in org.nuxeo.lib.stream.log
Fields in org.nuxeo.lib.stream.log declared as LogLag Modifier and Type Field Description protected LogLag
Latency. lag
Methods in org.nuxeo.lib.stream.log that return LogLag Modifier and Type Method Description default LogLag
LogManager. getLag(String name, String group)
Deprecated.since 11.1 useLogManager.getLag(Name, Name)
insteaddefault LogLag
LogManager. getLag(Name name, Name group)
Returns the lag between consumergroup
and producers for a Log.LogLag
Latency. lag()
static LogLag
LogLag. of(long lag)
static LogLag
LogLag. of(long lowerOffset, long upperOffset)
static LogLag
LogLag. of(List<LogLag> lags)
Methods in org.nuxeo.lib.stream.log that return types with arguments of type LogLag Modifier and Type Method Description default List<LogLag>
LogManager. getLagPerPartition(String name, String group)
Deprecated.since 11.1 useLogManager.getLagPerPartition(Name, Name)
insteadList<LogLag>
LogManager. getLagPerPartition(Name name, Name group)
Returns the lag between consumergroup
and the producers for each partition.List<LogLag>
UnifiedLogManager. getLagPerPartition(Name name, Name group)
Methods in org.nuxeo.lib.stream.log with parameters of type LogLag Modifier and Type Method Description static Latency
Latency. noLatency(long upper, LogLag lag)
Method parameters in org.nuxeo.lib.stream.log with type arguments of type LogLag Modifier and Type Method Description static LogLag
LogLag. of(List<LogLag> lags)
Constructors in org.nuxeo.lib.stream.log with parameters of type LogLag Constructor Description Latency(long lower, long upper, LogLag lag, String key)
-
Uses of LogLag in org.nuxeo.lib.stream.log.chronicle
Methods in org.nuxeo.lib.stream.log.chronicle that return LogLag Modifier and Type Method Description protected LogLag
ChronicleLogManager. getLagForPartition(Name name, int partition, Name group)
Methods in org.nuxeo.lib.stream.log.chronicle that return types with arguments of type LogLag Modifier and Type Method Description List<LogLag>
ChronicleLogManager. getLagPerPartition(Name name, Name group)
-
Uses of LogLag in org.nuxeo.lib.stream.log.internals
Methods in org.nuxeo.lib.stream.log.internals that return types with arguments of type LogLag Modifier and Type Method Description abstract List<LogLag>
AbstractLogManager. getLagPerPartition(Name name, Name group)
-
Uses of LogLag in org.nuxeo.lib.stream.log.kafka
Methods in org.nuxeo.lib.stream.log.kafka that return types with arguments of type LogLag Modifier and Type Method Description List<LogLag>
KafkaLogManager. getLagPerPartition(Name name, Name group)
-
Uses of LogLag in org.nuxeo.lib.stream.tools.command
Methods in org.nuxeo.lib.stream.tools.command that return LogLag Modifier and Type Method Description protected LogLag
PositionCommand. getLag(LogManager manager, Name group, Name name, int partition)
Method parameters in org.nuxeo.lib.stream.tools.command with type arguments of type LogLag Modifier and Type Method Description protected void
LagCommand. renderLag(Name group, List<LogLag> lags)
-