Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrCanceled = errors.New("operation canceled")
Functions ¶
This section is empty.
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) 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 (*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 OutputStream ¶
type OutputStream interface {
Send(*daemonpb.CommandMessage) error
}
Source Files
Click to show internal directories.
Click to hide internal directories.