logger

package

v0.0.0-...-c327e57 Latest Latest Go to latest Published: May 4, 2019 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type File struct {
	io.Writer
	// contains filtered or unexported fields
}

func (f *File) Clear() error

func (f *File) Read(ctx context.Context, lines int, follow bool, l chan string) error

func (f *File) Write(msg []byte) (int, error)

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

func New(opts *LoggerOpts) (*Logger, error)

func (l Logger) GetHost() string

func (l Logger) GetPort() uint16

func (l Logger) GetWorkdir() string

func (l *Logger) Handle(msg types.ProxyMessage) error

func (l *Logger) Listen() error

func (l *Logger) Stream(ctx context.Context, kind, selflink string, opts StreamOpts, writer http.ResponseWriter) error

type LoggerOpts struct {
	Workdir string
	Host    string
	Port    uint16
}

type Storage struct {
	Collection map[string]map[string]*File
	// contains filtered or unexported fields
}

func NewStorage(root string) *Storage

func (s Storage) GetStream(kind, selflink string, clear bool) (*File, error)

type StreamOpts struct {
	Follow bool
	Lines  int
}