logstore

Documentation

Index

• Variables
• func MigrateTarLog(ls *LogStore, logTar string) error
• func MigrateTarLogsInDir(ls *LogStore, dir string)
• type LogStore
  • func NewLogStore(dir string) (*LogStore, error)
  • func (ls *LogStore) Close() error
  • func (ls *LogStore) Create(id string, parentOpID int64, ttl time.Duration) (io.WriteCloser, error)
  • func (ls *LogStore) Delete(id string) error
  • func (ls *LogStore) DeleteWithParent(parentOpID int64) error
  • func (ls *LogStore) Open(id string) (io.ReadCloser, error)
  • func (ls *LogStore) SelectAll(f func(id string, parentID int64)) error

Variables

var (
	ErrLogNotFound = fmt.Errorf("log not found")
)

Functions

func MigrateTarLog

func MigrateTarLog(ls *LogStore, logTar string) error

func MigrateTarLogsInDir

func MigrateTarLogsInDir(ls *LogStore, dir string)

Types

type LogStore

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

func NewLogStore

func NewLogStore(dir string) (*LogStore, error)

func (*LogStore) Close

func (ls *LogStore) Close() error

func (*LogStore) Create

func (ls *LogStore) Create(id string, parentOpID int64, ttl time.Duration) (io.WriteCloser, error)

func (*LogStore) Delete

func (ls *LogStore) Delete(id string) error

func (*LogStore) DeleteWithParent

func (ls *LogStore) DeleteWithParent(parentOpID int64) error

func (*LogStore) Open

func (ls *LogStore) Open(id string) (io.ReadCloser, error)

func (*LogStore) SelectAll

func (ls *LogStore) SelectAll(f func(id string, parentID int64)) error