overseer

package module

Go to main page

Versions in this module

v0

v0.6.0

Mar 29, 2024

v0.5.0

Jun 16, 2022

Changes in this version

+ const STDERR

+ const STDOUT

+ type LogMsg struct

+ Text string

+ Type uint8

type Options

+ LineBufferSize uint

type OutputStream

+ func (rw *OutputStream) Flush()

type Overseer

+ func (ovr *Overseer) UnWatchLogs(logChan chan *LogMsg)

+ func (ovr *Overseer) UnWatchState(outputChan chan *ProcessJSON)

+ func (ovr *Overseer) WatchLogs(logChan chan *LogMsg)

+ func (ovr *Overseer) WatchState(outputChan chan *ProcessJSON)

v0.4.0

Nov 26, 2019

v0.3.4

Oct 15, 2019

Changes in this version

type Cmd

+ func (c *Cmd) IsRunningState() bool

v0.3.3

Oct 13, 2019

Changes in this version

type Overseer

+ func (ovr *Overseer) IsRunning() bool

+ func (ovr *Overseer) IsStopping() bool

v0.3.2

Jun 26, 2019

v0.3.1

Jun 25, 2019

Changes in this version

+ const IDLE

+ type OvrState uint

+ func (p OvrState) String() string

v0.3.0

Jun 16, 2019

Changes in this version

+ func SetupLogBuilder(b ml.LogBuilderType)

+ type Attrs = ml.Attrs

type Cmd

+ Group string

+ func (c *Cmd) Clone() *Cmd

+ func (c *Cmd) IsInitialState() bool

+ type Logger = ml.Logger

type Options

+ DelayStart uint

+ Dir string

+ Env []string

+ Group string

+ RetryTimes uint

type Overseer

+ func (ovr *Overseer) ListGroup(group string) []string

+ func (ovr *Overseer) UnWatch(outputChan chan *ProcessJSON)

+ func (ovr *Overseer) Watch(outputChan chan *ProcessJSON)

+ type ProcessJSON struct

+ Cmd string

+ DelayStart uint

+ Dir string

+ Error error

+ ExitCode int

+ Group string

+ ID string

+ PID int

+ RetryTimes uint

+ StartTime time.Time

+ State string

v0.1.2

Sep 13, 2018

v0.1.1

Sep 12, 2018

v0.1.0

Sep 12, 2018

Changes in this version

+ const DEFAULT_LINE_BUFFER_SIZE

+ const DEFAULT_STREAM_CHAN_SIZE

+ const FATAL

+ const FINISHED

+ const INITIAL

+ const INTERRUPT

+ const RUNNING

+ const STARTING

+ const STOPPING

+ const UNKNOWN

+ type Backoff struct

+ Factor float64

+ Jitter bool

+ Max time.Duration

+ Min time.Duration

+ func (b *Backoff) Attempt() float64

+ func (b *Backoff) Duration() time.Duration

+ func (b *Backoff) ForAttempt(attempt float64) time.Duration

+ func (b *Backoff) Reset()

+ type Cmd struct

+ Args []string

+ DelayStart uint

+ Dir string

+ Env []string

+ Name string

+ RetryTimes uint

+ State CmdState

+ Stderr chan string

+ Stdout chan string

+ func NewCmd(name string, args ...string) *Cmd

+ func NewCmdOptions(options Options, name string, args ...string) *Cmd

+ func (c *Cmd) CloneCmd() *Cmd

+ func (c *Cmd) Done() <-chan struct{}

+ func (c *Cmd) IsFinalState() bool

+ func (c *Cmd) SetDelayStart(delayStart uint)

+ func (c *Cmd) SetDir(dir string)

+ func (c *Cmd) SetEnv(env []string)

+ func (c *Cmd) SetRetryTimes(retryTimes uint)

+ func (c *Cmd) Signal(sig syscall.Signal) error

+ func (c *Cmd) Start() <-chan Status

+ func (c *Cmd) Status() Status

+ func (c *Cmd) Stop() error

+ func (c *Cmd) ToJSON() JSONProcess

+ type CmdState uint

+ func (p CmdState) String() string

+ type ErrLineBufferOverflow struct

+ BufferFree int

+ BufferSize int

+ Line string

+ func (e ErrLineBufferOverflow) Error() string

+ type JSONProcess struct

+ Cmd string

+ DelayStart uint

+ Dir string

+ Env []string

+ Error error

+ ExitCode int

+ PID int

+ RetryTimes uint

+ RunTime float64

+ StartTime time.Time

+ State string

+ type Options struct

+ Buffered bool

+ Streaming bool

+ type OutputBuffer struct

+ func NewOutputBuffer() *OutputBuffer

+ func (rw *OutputBuffer) Lines() []string

+ func (rw *OutputBuffer) Write(p []byte) (n int, err error)

+ type OutputStream struct

+ func NewOutputStream(streamChan chan string) *OutputStream

+ func (rw *OutputStream) Lines() <-chan string

+ func (rw *OutputStream) SetLineBufferSize(n int)

+ func (rw *OutputStream) Write(p []byte) (n int, err error)

+ type Overseer struct

+ func NewOverseer() *Overseer

+ func (ovr *Overseer) Add(id string, args ...string) *Cmd

+ func (ovr *Overseer) HasProc(id string) bool

+ func (ovr *Overseer) ListAll() []string

+ func (ovr *Overseer) Remove(id string) bool

+ func (ovr *Overseer) Signal(id string, sig syscall.Signal) error

+ func (ovr *Overseer) Status(id string) Status

+ func (ovr *Overseer) Stop(id string) error

+ func (ovr *Overseer) StopAll()

+ func (ovr *Overseer) Supervise(id string)

+ func (ovr *Overseer) SuperviseAll()

+ func (ovr *Overseer) ToJSON(id string) JSONProcess

+ type Status struct

+ Cmd string

+ Error error

+ Exit int

+ PID int

+ Runtime float64

+ StartTs int64

+ Stderr []string

+ Stdout []string

+ StopTs int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL