class Flux::BufferedWriter

Defined in:

flux/buffered_writer.cr

.new(client : Flux::Client, bucket : String, batch_size : Int32 = 5000, flush_delay : Time::Span = 1.seconds)
Creates a new buffered writer for storing points in bucket via client.

#enqueue(point : Point) : Nil
Enqueue a point for writing.
#flush : Nil
Flush any fully buffered writes, or schedules a task for partials.

def self.new(client : Flux::Client, bucket : String, batch_size : Int32 = 5000, flush_delay : Time::Span = 1.seconds) #

Creates a new buffered writer for storing points in bucket via client.

Writes to the underlying client are deferred until batch_size points are cached or no additional write call is made for flush_delay.

[View source]

def enqueue(point : Point) : Nil #

Enqueue a point for writing.

[View source]

def flush : Nil #

Flush any fully buffered writes, or schedules a task for partials.

[View source]