iscp.FlushPolicy - データのフラッシュ方法

フラッシュ方法を表す抽象クラス

class FlushPolicy

Upstreamのフラッシュの方法について定義します。

abstract IsFlush(size)

内部バッファのサイズからフラッシュするかどうかを判定します。

パラメータ:

size (int) -- 内部バッファサイズ

戻り値:

フラッシュするかどうか。

戻り値の型:

bool

abstract Ticker()

時間間隔によるフラッシュを行うためのTickerを取得します。

Tickerが時間を返す度にフラッシュを行います。Noneの場合は時間間隔によるフラッシュを行いません。

戻り値:

Ticker

戻り値の型:

Optional[Ticker]

フラッシュ方法を実装した具象クラス

class NoFlush

フラッシュを行わないFlushPolicyです。このFlushPolicyを指定した場合は、明示的にフラッシュを行う必要があります。

class Immediately

即時フラッシュを行うFlushPolicyです。

class IntervalOnly(interval=1.0)

インターバルによるフラッシュを行うFlushPolicyです。

interval

フラッシュインターバル（秒）

Type:

float

class BufferSizeOnly(buffer_size=100000)

バッファサイズによるフラッシュを行うFlushPolicyです。

buffer_size

バッファサイズ

Type:

int

class IntervalOrBufferSize(buffer_size=100000, interval=1.0)

インターバル、またはバッファサイズによるフラッシュを行うFlushPolicyです。

buffer_size

バッファサイズ

Type:

int

interval

フラッシュインターバル（秒）

Type:

float