flusher

Documentation

Index

• Variables
• func NewDriver() *driver
• type Driver
• type DriverFactory
• type NodeDriver

Variables

var (
	ErrDuplicateNodeFlusher = errors.New("duplicate flusher node")
	ErrNotFoundNodeFlusher  = errors.New("not found flusher node")
)

Functions

func NewDriver

func NewDriver() *driver

Types

type Driver

type Driver interface {
	shard.NodeAware
	Start()
	Stop()
	String() string
}

type DriverFactory

type DriverFactory = func(id uint64) NodeDriver

type NodeDriver

type NodeDriver interface {
	GetId() uint64
	FlushNode(id uint64) error
}