flusherimpl

Documentation

Index

• func GetExecPool() *conc.Pool[any]
• type WALFlusherImpl
  • func RecoverWALFlusher(param interceptors.InterceptorBuildParam) *WALFlusherImpl
  • func (impl *WALFlusherImpl) Close()
  • func (impl *WALFlusherImpl) Execute() (err error)

Functions

func GetExecPool

func GetExecPool() *conc.Pool[any]

Types

type WALFlusherImpl

type WALFlusherImpl struct {
	// contains filtered or unexported fields
}

func RecoverWALFlusher

func RecoverWALFlusher(param interceptors.InterceptorBuildParam) *WALFlusherImpl

RecoverWALFlusher recovers the wal flusher.

func (*WALFlusherImpl) Close

func (impl *WALFlusherImpl) Close()

Close closes the wal flusher and release all related resources for it.

func (*WALFlusherImpl) Execute

func (impl *WALFlusherImpl) Execute() (err error)

Execute starts the wal flusher.