logwriter

Documentation

Index

• Variables
• type LiveLog
  • func NewLiveLogger(dir string) (*LiveLog, error)
  • func (t *LiveLog) IsAlive(id string) bool
  • func (t *LiveLog) ListIDs() []string
  • func (t *LiveLog) NewWriter(id string) (*LiveLogWriter, error)
  • func (t *LiveLog) Remove(id string) error
  • func (t *LiveLog) Subscribe(id string) (chan []byte, error)
  • func (t *LiveLog) Unsubscribe(id string, ch chan []byte)
• type LiveLogWriter
  • func (t *LiveLogWriter) Close() error
  • func (t *LiveLogWriter) Write(data []byte) (int, error)
• type LogManager
  • func NewLogManager(dir string, maxLogFiles int) (*LogManager, error)
  • func (lm *LogManager) Finalize(id string) (frozenID string, err error)
  • func (lm *LogManager) LiveLogIDs() []string
  • func (lm *LogManager) NewLiveWriter(idbase string) (string, io.WriteCloser, error)
  • func (lm *LogManager) Subscribe(id string) (chan []byte, error)
  • func (lm *LogManager) Unsubscribe(id string, ch chan []byte)
• type RotatingLog
  • func NewRotatingLog(dir string, maxLogFiles int) *RotatingLog
  • func (r *RotatingLog) Read(name string) ([]byte, error)
  • func (r *RotatingLog) Write(data []byte) (string, error)

Variables

var ErrAlreadyExists = errors.New("already exists")

var ErrBadName = errors.New("bad name")

var ErrFileNotFound = errors.New("file not found")

var ErrNotFound = errors.New("entry not found")

Types

type LiveLog

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

func NewLiveLogger

func NewLiveLogger(dir string) (*LiveLog, error)

func (*LiveLog) IsAlive

func (t *LiveLog) IsAlive(id string) bool

func (*LiveLog) ListIDs

func (t *LiveLog) ListIDs() []string

func (*LiveLog) NewWriter

func (t *LiveLog) NewWriter(id string) (*LiveLogWriter, error)

func (*LiveLog) Remove

func (t *LiveLog) Remove(id string) error

func (*LiveLog) Subscribe

func (t *LiveLog) Subscribe(id string) (chan []byte, error)

func (*LiveLog) Unsubscribe

func (t *LiveLog) Unsubscribe(id string, ch chan []byte)

type LiveLogWriter

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

func (*LiveLogWriter) Close

func (t *LiveLogWriter) Close() error

func (*LiveLogWriter) Write

func (t *LiveLogWriter) Write(data []byte) (int, error)

type LogManager

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

func NewLogManager

func NewLogManager(dir string, maxLogFiles int) (*LogManager, error)

func (*LogManager) Finalize

func (lm *LogManager) Finalize(id string) (frozenID string, err error)

func (*LogManager) LiveLogIDs

func (lm *LogManager) LiveLogIDs() []string

LiveLogIDs returns the list of IDs of live logs e.g. with writes in progress.

func (*LogManager) NewLiveWriter

func (lm *LogManager) NewLiveWriter(idbase string) (string, io.WriteCloser, error)

NewLiveWriter creates a new live log writer. The ID is the base name of the log file, a transformed ID is returned.

func (*LogManager) Subscribe

func (lm *LogManager) Subscribe(id string) (chan []byte, error)

func (*LogManager) Unsubscribe

func (lm *LogManager) Unsubscribe(id string, ch chan []byte)

type RotatingLog

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

func NewRotatingLog

func NewRotatingLog(dir string, maxLogFiles int) *RotatingLog

func (*RotatingLog) Read

func (r *RotatingLog) Read(name string) ([]byte, error)

func (*RotatingLog) Write

func (r *RotatingLog) Write(data []byte) (string, error)