recorder

Documentation

Index

• type ExecutionRecorder
  • func NewFileLogRecorder(resFilename string, dir string) (ExecutionRecorder, error)
• type FileLogRecorder
  • func (l *FileLogRecorder) AddExecution(ex *pb.JobExecution) error
  • func (l *FileLogRecorder) Close() error
  • func (l *FileLogRecorder) OldRecords(n int) ([]string, error)
  • func (l *FileLogRecorder) StartTailing(ctx context.Context) (Tailer, error)
• type MemRecorder
  • func NewMemrecorder() *MemRecorder
  • func (m *MemRecorder) AddExecution(ex *pb.JobExecution) error
  • func (m *MemRecorder) Close() error
  • func (m *MemRecorder) OldRecords(n int) ([]string, error)
  • func (m *MemRecorder) StartTailing(_ context.Context) (Tailer, error)
• type MemTailer
  • func (t *MemTailer) Lines() <-chan string
  • func (t *MemTailer) Stop() error
• type Tailer

Types

type ExecutionRecorder

type ExecutionRecorder interface {
	OldRecords(n int) ([]string, error)
	StartTailing(context.Context) (Tailer, error)
	AddExecution(ex *pb.JobExecution) error
	Close() error
}

func NewFileLogRecorder

func NewFileLogRecorder(resFilename string, dir string) (ExecutionRecorder, error)

type FileLogRecorder

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

func (*FileLogRecorder) AddExecution

func (l *FileLogRecorder) AddExecution(ex *pb.JobExecution) error

func (*FileLogRecorder) Close

func (l *FileLogRecorder) Close() error

func (*FileLogRecorder) OldRecords

func (l *FileLogRecorder) OldRecords(n int) ([]string, error)

func (*FileLogRecorder) StartTailing

func (l *FileLogRecorder) StartTailing(ctx context.Context) (Tailer, error)

type MemRecorder

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

func NewMemrecorder

func NewMemrecorder() *MemRecorder

func (*MemRecorder) AddExecution

func (m *MemRecorder) AddExecution(ex *pb.JobExecution) error

func (*MemRecorder) Close

func (m *MemRecorder) Close() error

func (*MemRecorder) OldRecords

func (m *MemRecorder) OldRecords(n int) ([]string, error)

func (*MemRecorder) StartTailing

func (m *MemRecorder) StartTailing(_ context.Context) (Tailer, error)

type MemTailer

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

func (*MemTailer) Lines

func (t *MemTailer) Lines() <-chan string

func (*MemTailer) Stop

func (t *MemTailer) Stop() error

type Tailer

type Tailer interface {
	Lines() <-chan string
	Stop() error
}