FlushTask

Flush から返される非同期タスクです。フラッシュが完了するまでブロックするには、Await() を呼び出します。

go

type FlushTask struct {
}

METHODS:

• Await(ctx context.Context) error

  非同期操作が完了するか、コンテキストがキャンセルされるまでブロックします。操作が失敗した場合はエラーが返されます。

• GetFlushStats() segIDs []int64, flushSegIDs []int64, flushTs uint64, channelCheckpoints map[string]*msgpb.MsgPosition

  セグメント ID とフラッシュのタイムスタンプを含むフラッシュ統計を返します。