mananger

Documentation

Index

• Variables
• type DefaultManager
  • func NewSegmentManager(segmentPath string, writeBufferSize int64, mergeFloor int64, ...) (*DefaultManager, error)
  • func (sm *DefaultManager) Close() error
  • func (sm *DefaultManager) Flush() error
  • func (sm *DefaultManager) Merge() error
  • func (sm *DefaultManager) Read(key string) (domain.KV, error)
  • func (sm *DefaultManager) Refresh() error
  • func (sm *DefaultManager) Write(kv domain.KV) error
• type Manager

Variables

var (
	ErrNull = errors.New("null value")
)

Types

type DefaultManager

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

func NewSegmentManager

func NewSegmentManager(segmentPath string, writeBufferSize int64, mergeFloor int64, codec codec2.Codec) (*DefaultManager, error)

func (*DefaultManager) Close

func (sm *DefaultManager) Close() error

func (*DefaultManager) Flush

func (sm *DefaultManager) Flush() error

func (*DefaultManager) Merge

func (sm *DefaultManager) Merge() error

func (*DefaultManager) Read

func (sm *DefaultManager) Read(key string) (domain.KV, error)

func (*DefaultManager) Refresh

func (sm *DefaultManager) Refresh() error

func (*DefaultManager) Write

func (sm *DefaultManager) Write(kv domain.KV) error

type Manager

type Manager interface {
	Refresh() error
	Close() error
	Write(kv domain.KV) error
	Read(key string) (domain.KV, error)
	Flush() error
	Merge() error
}