flush

Documentation

Index

• type Coordinator
  • func NewFlushCoordinator() Coordinator
  • func NewNoopFlushCoordinator() Coordinator
• type Flushable

Types

type Coordinator

type Coordinator interface {
	Flushable
	NotifyFlush()
	RegisterFlushable(f Flushable)
	WaitForFlush()
}

func NewFlushCoordinator

func NewFlushCoordinator() Coordinator

func NewNoopFlushCoordinator

func NewNoopFlushCoordinator() Coordinator

type Flushable

type Flushable interface {
	Flush()
}