ch.algotrader.influxdb.dao

Interface InfluxDBDao<V extends MarketDataEventVO>

All Known Subinterfaces:

AskDao, BarDao, BidAskDao, BidDao, QuoteDao<V>, TickDao, TradeDao

All Known Implementing Classes:

AbstractInfluxDBDao, AskDaoImpl, BarDaoImpl, BidAskQuoteDaoImpl, BidDaoImpl, TickDaoImpl, TradeDaoImpl

public interface InfluxDBDao<V extends MarketDataEventVO>

Generic InfluxDB DAO interface for read / write operations.

Method Summary

Modifier and Type	Method and Description
int	countByAdapterTypeBarSizeSecurityId(java.util.Optional<java.time.ZonedDateTime> minDateTime, java.util.Optional<java.time.ZonedDateTime> maxDateTime, java.util.Optional<AdapterType> adapterType, java.util.Optional<Duration> barSize, java.util.Optional<java.lang.Long> securityId)
void	delete(V valueObject)
void	deleteAll()
void	deleteAll(java.util.Optional<java.time.ZonedDateTime> minDateTime, java.util.Optional<java.time.ZonedDateTime> maxDateTime, java.util.Optional<AdapterType> adapterType, java.util.Optional<Duration> barSize, java.util.Optional<java.lang.Long> securityId)
java.util.List<V>	findByLimitAndOffset(java.util.Optional<java.time.ZonedDateTime> minDateTime, java.util.Optional<java.time.ZonedDateTime> maxDateTime, long limit, long offset, java.util.Optional<AdapterType> adapterType, java.util.Optional<Duration> barSize, java.util.Optional<java.lang.Long> securityId, java.lang.String sortClause)
void	flush()
java.util.Optional<java.time.LocalDateTime>	getMaxDate(java.util.Optional<java.time.ZonedDateTime> minDateTime, java.util.Optional<java.time.ZonedDateTime> maxDateTime, java.util.Optional<AdapterType> adapterType, java.util.Optional<Duration> barSize, java.util.Optional<java.lang.Long> securityId)
java.util.Optional<java.time.LocalDateTime>	getMinDate(java.util.Optional<java.time.ZonedDateTime> minDateTime, java.util.Optional<java.time.ZonedDateTime> maxDateTime, java.util.Optional<AdapterType> adapterType, java.util.Optional<Duration> barSize, java.util.Optional<java.lang.Long> securityId)
void	save(V valueObject)
void	saveAll(java.util.Collection<V> valueObjects)
void	stream(java.lang.String query, int chunkSize, java.util.function.BiConsumer<InfluxDB.Cancellable,java.util.List<V>> consumer, java.lang.Runnable onComplete)
void	stream(java.lang.String query, int chunkSize, java.util.function.BiConsumer<InfluxDB.Cancellable,java.util.List<V>> consumer, java.lang.Runnable onComplete, java.util.function.Consumer<java.lang.Throwable> onFailure)
void	streamByLimitAndOffset(java.util.Optional<java.time.ZonedDateTime> minDateTime, java.util.Optional<java.time.ZonedDateTime> maxDateTime, long limit, long offset, java.util.Optional<AdapterType> adapterType, java.util.Optional<Duration> barSize, java.util.Optional<java.lang.Long> securityId, java.lang.String sortClause, java.util.function.BiConsumer<InfluxDB.Cancellable,java.util.List<V>> consumer, int streamChunkSize, java.lang.Runnable onComplete)

Method Detail

stream

void stream(java.lang.String query,
            int chunkSize,
            java.util.function.BiConsumer<InfluxDB.Cancellable,java.util.List<V>> consumer,
            java.lang.Runnable onComplete)

stream

void stream(java.lang.String query,
            int chunkSize,
            java.util.function.BiConsumer<InfluxDB.Cancellable,java.util.List<V>> consumer,
            java.lang.Runnable onComplete,
            java.util.function.Consumer<java.lang.Throwable> onFailure)

flush

void flush()

save

void save(V valueObject)

delete

void delete(V valueObject)

saveAll

void saveAll(java.util.Collection<V> valueObjects)

deleteAll

void deleteAll()

streamByLimitAndOffset

void streamByLimitAndOffset(java.util.Optional<java.time.ZonedDateTime> minDateTime,
                            java.util.Optional<java.time.ZonedDateTime> maxDateTime,
                            long limit,
                            long offset,
                            java.util.Optional<AdapterType> adapterType,
                            java.util.Optional<Duration> barSize,
                            java.util.Optional<java.lang.Long> securityId,
                            java.lang.String sortClause,
                            java.util.function.BiConsumer<InfluxDB.Cancellable,java.util.List<V>> consumer,
                            int streamChunkSize,
                            java.lang.Runnable onComplete)

deleteAll

void deleteAll(java.util.Optional<java.time.ZonedDateTime> minDateTime,
               java.util.Optional<java.time.ZonedDateTime> maxDateTime,
               java.util.Optional<AdapterType> adapterType,
               java.util.Optional<Duration> barSize,
               java.util.Optional<java.lang.Long> securityId)

findByLimitAndOffset

java.util.List<V> findByLimitAndOffset(java.util.Optional<java.time.ZonedDateTime> minDateTime,
                                       java.util.Optional<java.time.ZonedDateTime> maxDateTime,
                                       long limit,
                                       long offset,
                                       java.util.Optional<AdapterType> adapterType,
                                       java.util.Optional<Duration> barSize,
                                       java.util.Optional<java.lang.Long> securityId,
                                       java.lang.String sortClause)

getMinDate

java.util.Optional<java.time.LocalDateTime> getMinDate(java.util.Optional<java.time.ZonedDateTime> minDateTime,
                                                       java.util.Optional<java.time.ZonedDateTime> maxDateTime,
                                                       java.util.Optional<AdapterType> adapterType,
                                                       java.util.Optional<Duration> barSize,
                                                       java.util.Optional<java.lang.Long> securityId)

getMaxDate

java.util.Optional<java.time.LocalDateTime> getMaxDate(java.util.Optional<java.time.ZonedDateTime> minDateTime,
                                                       java.util.Optional<java.time.ZonedDateTime> maxDateTime,
                                                       java.util.Optional<AdapterType> adapterType,
                                                       java.util.Optional<Duration> barSize,
                                                       java.util.Optional<java.lang.Long> securityId)

countByAdapterTypeBarSizeSecurityId

int countByAdapterTypeBarSizeSecurityId(java.util.Optional<java.time.ZonedDateTime> minDateTime,
                                        java.util.Optional<java.time.ZonedDateTime> maxDateTime,
                                        java.util.Optional<AdapterType> adapterType,
                                        java.util.Optional<Duration> barSize,
                                        java.util.Optional<java.lang.Long> securityId)