deltas

Documentation

Index

• Constants
• Variables
• func New(tableDir string, fsync bool) *deltas
• type MessageCollector

Constants

const DirName = "deltas"

DirName represents directory name for the deltas

Variables

var EmptyBuffer = errors.New("Empty buffer")

EmptyBuffer represents empty message buffer error

Functions

func New

func New(tableDir string, fsync bool) *deltas

New instantiates deltas

Types

type MessageCollector

type MessageCollector interface {
	AddMessage(message.Message)
	Save() (filename string, minLSN, maxLSN dbutils.LSN, err error)
	MessageCnt() uint32
	LastMessageTime() time.Time
	GetMessage() (message.Message, error)
	Load(filename string) error
	Close() error
}

MessageCollector represents interface