Documentation
¶
Index ¶
- type Queue
- func (h *Queue) AcquireFinalizer(ref string) (<-chan struct{}, func())
- func (h *Queue) Delete(ctx context.Context, ref string) error
- func (h *Queue) Finalize(ctx context.Context, ref string) error
- func (h *Queue) ImportError(ctx context.Context, err error) (_ *spb.Status, _ *controlapi.Descriptor, _ func(), retErr error)
- func (h *Queue) ImportStatus(ctx context.Context, ch chan *client.SolveStatus) (_ *StatusImportResult, _ func(), err error)
- func (h *Queue) Listen(ctx context.Context, req *controlapi.BuildHistoryRequest, ...) error
- func (h *Queue) OpenBlobWriter(ctx context.Context, mt string) (_ *Writer, err error)
- func (h *Queue) Status(ctx context.Context, ref string, st chan<- *client.SolveStatus) error
- func (h *Queue) Update(ctx context.Context, e *controlapi.BuildHistoryEvent) error
- func (h *Queue) UpdateRef(ctx context.Context, ref string, ...) error
- type QueueOpt
- type StatusImportResult
- type Writer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
func (*Queue) AcquireFinalizer ¶
func (*Queue) ImportError ¶
func (h *Queue) ImportError(ctx context.Context, err error) (_ *spb.Status, _ *controlapi.Descriptor, _ func(), retErr error)
func (*Queue) ImportStatus ¶
func (h *Queue) ImportStatus(ctx context.Context, ch chan *client.SolveStatus) (_ *StatusImportResult, _ func(), err error)
func (*Queue) Listen ¶
func (h *Queue) Listen(ctx context.Context, req *controlapi.BuildHistoryRequest, f func(*controlapi.BuildHistoryEvent) error) error
func (*Queue) OpenBlobWriter ¶
func (*Queue) Update ¶
func (h *Queue) Update(ctx context.Context, e *controlapi.BuildHistoryEvent) error
func (*Queue) UpdateRef ¶
func (h *Queue) UpdateRef(ctx context.Context, ref string, upt func(r *controlapi.BuildHistoryRecord) error) error
type QueueOpt ¶
type QueueOpt struct {
DB db.Transactor
LeaseManager *leaseutil.Manager
ContentStore *containerdsnapshot.Store
CleanConfig *config.HistoryConfig
GarbageCollect func(context.Context) error
GracefulStop <-chan struct{}
}
type StatusImportResult ¶
Source Files
Click to show internal directories.
Click to hide internal directories.