tasks

Documentation

Index

• type Task
  • func (t *Task) Stop()
• type ViewBufferManager
  • func NewViewBufferManager(log *logrus.Entry, writer io.Writer, beforeStart func(), refreshView func(), ...) *ViewBufferManager
  • func (t *ViewBufferManager) Close()
  • func (m *ViewBufferManager) NewCmdTask(r io.Reader, cmd *exec.Cmd, prefix string, linesToRead int, onDone func()) func(chan struct{}) error
  • func (m *ViewBufferManager) NewTask(f func(stop chan struct{}) error) error
  • func (m *ViewBufferManager) ReadLines(n int)

Types

type Task

type Task struct {
	Log *logrus.Entry
	// contains filtered or unexported fields
}

func (*Task) Stop

func (t *Task) Stop()

type ViewBufferManager

type ViewBufferManager struct {
	Log *logrus.Entry
	// contains filtered or unexported fields
}

func NewViewBufferManager

func NewViewBufferManager(log *logrus.Entry, writer io.Writer, beforeStart func(), refreshView func(), flushStaleCells func()) *ViewBufferManager

func (*ViewBufferManager) Close

func (t *ViewBufferManager) Close()

Close closes the task manager, killing whatever task may currently be running

func (*ViewBufferManager) NewCmdTask

func (m *ViewBufferManager) NewCmdTask(r io.Reader, cmd *exec.Cmd, prefix string, linesToRead int, onDone func()) func(chan struct{}) error

func (*ViewBufferManager) NewTask

func (m *ViewBufferManager) NewTask(f func(stop chan struct{}) error) error

func (*ViewBufferManager) ReadLines

func (m *ViewBufferManager) ReadLines(n int)