optracker

Documentation

Index

• Variables
• type AsyncBuildJobs
  • func NewAsyncBuildJobs(ctx context.Context, appID string, tracker *OpTracker) *AsyncBuildJobs
  • func (a *AsyncBuildJobs) Go(description string, track bool, minDuration time.Duration, ...)
  • func (a *AsyncBuildJobs) Tracker() *OpTracker
  • func (a *AsyncBuildJobs) Wait() error
• type OpTracker
  • func New(w io.Writer, stream OutputStream) *OpTracker
  • func (t *OpTracker) Add(msg string, minStart time.Time) OperationID
  • func (t *OpTracker) AllDone()
  • func (t *OpTracker) Cancel(id OperationID)
  • func (t *OpTracker) Done(id OperationID, minDuration time.Duration)
  • func (t *OpTracker) Fail(id OperationID, err error)
• type OperationID
• type OutputStream

Variables

var ErrCanceled = errors.New("operation canceled")

Types

type AsyncBuildJobs

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

func NewAsyncBuildJobs

func NewAsyncBuildJobs(ctx context.Context, appID string, tracker *OpTracker) *AsyncBuildJobs

func (*AsyncBuildJobs) Go

func (a *AsyncBuildJobs) Go(description string, track bool, minDuration time.Duration, f func(ctx context.Context) error)

func (*AsyncBuildJobs) Tracker

func (a *AsyncBuildJobs) Tracker() *OpTracker

func (*AsyncBuildJobs) Wait

func (a *AsyncBuildJobs) Wait() error

type OpTracker

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

func New

func New(w io.Writer, stream OutputStream) *OpTracker

func (*OpTracker) Add

func (t *OpTracker) Add(msg string, minStart time.Time) OperationID

Add creates a new item on the operations tracker returning the ID for that op. minStart is the time at which the tracker will start to show the task as in progress.

This function is safe to call on a Nil OpTracker and will no-op in that case

func (*OpTracker) AllDone

func (t *OpTracker) AllDone()

AllDone marks all ops as done. This function is safe to call on a Nil OpTracker.

func (*OpTracker) Cancel

func (t *OpTracker) Cancel(id OperationID)

Cancel marks the operation as canceled. It is equivalent to t.Fail(id, ErrCanceled).

func (*OpTracker) Done

func (t *OpTracker) Done(id OperationID, minDuration time.Duration)

Done marks the given operation as done

This function is safe to call on a Nil OpTracker and will no-op in that case

func (*OpTracker) Fail

func (t *OpTracker) Fail(id OperationID, err error)

Fail marks the operation as failed with the given error

This function is safe to call on a Nil OpTracker and will no-op in that case

type OperationID

type OperationID int

const NoOperationID OperationID = -1

type OutputStream

type OutputStream interface {
	Send(*daemonpb.CommandMessage) error
}