common

type Backoff ¶

type Backoff int

func (b *Backoff) RandomSleep(rng *rand.Rand, clock Clock)

func (b *Backoff) Sleep()

type BoxTime ¶

type BoxTime struct{}

func (BoxTime) After(d time.Duration) <-chan time.Time

func (BoxTime) Now() time.Time

func (BoxTime) Sleep(d time.Duration)

type Clock ¶

type Clock interface {
	Now() time.Time
	Sleep(time.Duration)
	After(time.Duration) <-chan time.Time
}

type Environment ¶

type Environment struct {
	stats.Statter
}

func NewEnvironment(initializers ...func(e *Environment)) *Environment

type HeadLinesWriter ¶

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

HeadLinesWriter stores upto the first N lines in a buffer that can be retrieved via Head().

func NewHeadLinesWriter(max int) *HeadLinesWriter

func (h *HeadLinesWriter) Head() []byte

func (h *HeadLinesWriter) Write(p []byte) (n int, err error)

type LineWriter ¶

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

lineWriter will break apart a stream of data into individual lines. Downstream writer will be called for each complete new line. When Flush is called, a newline will be appended if there isn't one at the end. Not thread-safe

func NewLineWriter(w io.Writer) *LineWriter

func (li *LineWriter) Flush() (int, error)

func (li *LineWriter) Write(p []byte) (int, error)

type TailLinesWriter ¶

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

TailLinesWriter stores upto the last N lines in a buffer that can be retrieved via Tail(). The truncation is only performed when more bytes are received after '\n', so the buffer contents for both these writes are identical.

tail writer that captures last 3 lines. 'a\nb\nc\nd\n' -> 'b\nc\nd\n' 'a\nb\nc\nd' -> 'b\nc\nd'

func NewTailLinesWriter(max int) *TailLinesWriter

func (t *TailLinesWriter) Tail() []byte

func (t *TailLinesWriter) Write(p []byte) (n int, err error)

type Temporary ¶

type Temporary interface {
	Temporary() bool
}

type UserVisibleError ¶

type UserVisibleError interface {
	UserVisible() bool
}

Errors that can be directly exposed to task creators/users.