flusherimpl

Documentation

Index

• func GetExecPool() *conc.Pool[any]
• func NewFlusher(chunkManager storage.ChunkManager) flusher.Flusher
• type ChannelLifetime
  • func NewChannelLifetime(f *flusherImpl, vchannel string, wal wal.WAL) ChannelLifetime
• type LifetimeState

Functions

func GetExecPool

func GetExecPool() *conc.Pool[any]

func NewFlusher

func NewFlusher(chunkManager storage.ChunkManager) flusher.Flusher

Types

type ChannelLifetime

type ChannelLifetime interface {
	Run() error
	Cancel()
}

func NewChannelLifetime

func NewChannelLifetime(f *flusherImpl, vchannel string, wal wal.WAL) ChannelLifetime

type LifetimeState

type LifetimeState int

const (
	Pending LifetimeState = iota
	Cancel
	Fail
	Done
)