sequential

Documentation

Index

• Variables
• func Info(baseDir string) error
• type Sequential
  • func New(baseDir string, logger *zap.Logger) Sequential

Variables

var (
	ErrOversize = fmt.Errorf("payload size exceeds the limit of %d", dataSize)
	ErrClosed   = stderr.New("sequential has closed")
	ErrNotfound = stderr.New("offset not found")
)

Functions

func Info

func Info(baseDir string) error

Info show offset and available capacity of each file(.mox) in this directory

Types

type Sequential

type Sequential interface {
	Close()
	Write(raw []byte) (offset uint64, err error)
	Get(offset uint64) ([]byte, error)
	// contains filtered or unexported methods
}

Sequential write files sequentially

func New

func New(baseDir string, logger *zap.Logger) Sequential

New write files sequentially