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 StringStreamObject. lagAsJson(String consumer, String stream, List<LogLag> lags)protected StringStreamObject. 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 LogLagLatency. lagMethods in org.nuxeo.lib.stream.log that return LogLag Modifier and Type Method Description default LogLagLogManager. getLag(String name, String group)Deprecated.since 11.1 useLogManager.getLag(Name, Name)insteaddefault LogLagLogManager. getLag(Name name, Name group)Returns the lag between consumergroupand producers for a Log.LogLagLatency. lag()static LogLagLogLag. of(long lag)static LogLagLogLag. of(long lowerOffset, long upperOffset)static LogLagLogLag. 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 consumergroupand 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 LatencyLatency. 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 LogLagLogLag. 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 LogLagChronicleLogManager. 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 LogLagPositionCommand. 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 voidLagCommand. renderLag(Name group, List<LogLag> lags)
-