log

Documentation

Index

• Constants
• Variables
• type Driver
  • func GetFileLogDriver(options *FileLogDriverOptions) (driver Driver, err error)
  • func GetLogDriver(logDriverType string, options interface{}) (driver Driver, err error)
• type FileLogDriver
  • func (d *FileLogDriver) Close() (err error)
  • func (d *FileLogDriver) Count(id string, pattern string) (n int, err error)
  • func (d *FileLogDriver) Find(id string, pattern string, skip int, limit int) (lines []string, err error)
  • func (d *FileLogDriver) Flush() (err error)
  • func (d *FileLogDriver) Init() (err error)
  • func (d *FileLogDriver) WriteLine(id string, line string) (err error)
  • func (d *FileLogDriver) WriteLines(id string, lines []string) (err error)
• type FileLogDriverOptions
• type Message
• type Metadata

Constants

const (
	DriverTypeFile  = "file"  // raw file
	DriverTypeFs    = "fs"    // file system (SeaweedFS)
	DriverTypeMongo = "mongo" // mongodb
	DriverTypeEs    = "es"    // elastic search
)

const (
	MetadataName = "metadata.json"
)

Variables

var (
	ErrInvalidType    = errors.New("invalid type")
	ErrNotImplemented = errors.New("not implemented")
)

Types

type Driver

type Driver interface {
	Init() (err error)
	Close() (err error)
	WriteLine(id string, line string) (err error)
	WriteLines(id string, lines []string) (err error)
	Find(id string, pattern string, skip int, limit int) (lines []string, err error)
	Count(id string, pattern string) (n int, err error)
}

func GetFileLogDriver

func GetFileLogDriver(options *FileLogDriverOptions) (driver Driver, err error)

func GetLogDriver

func GetLogDriver(logDriverType string, options interface{}) (driver Driver, err error)

type FileLogDriver

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

func (*FileLogDriver) Close

func (d *FileLogDriver) Close() (err error)

func (*FileLogDriver) Count

func (d *FileLogDriver) Count(id string, pattern string) (n int, err error)

func (*FileLogDriver) Find

func (d *FileLogDriver) Find(id string, pattern string, skip int, limit int) (lines []string, err error)

func (*FileLogDriver) Flush

func (d *FileLogDriver) Flush() (err error)

func (*FileLogDriver) Init

func (d *FileLogDriver) Init() (err error)

func (*FileLogDriver) WriteLine

func (d *FileLogDriver) WriteLine(id string, line string) (err error)

func (*FileLogDriver) WriteLines

func (d *FileLogDriver) WriteLines(id string, lines []string) (err error)

type FileLogDriverOptions

type FileLogDriverOptions struct {
	BaseDir string
	Ttl     time.Duration
}

type Message

type Message struct {
	Id  int64     `json:"id" bson:"id"`
	Msg string    `json:"msg" bson:"msg"`
	Ts  time.Time `json:"ts" bson:"ts"`
}

type Metadata

type Metadata struct {
	Size       int64  `json:"size,omitempty" bson:"size"`
	TotalLines int64  `json:"total_lines,omitempty" bson:"total_lines"`
	TotalBytes int64  `json:"total_bytes,omitempty" bson:"total_bytes"`
	Md5        string `json:"md5,omitempty" bson:"md5"`
}