Documentation ¶
Index ¶
- type Handler
- type HandlerParams
- type Manager
- type RepoHandler
- func (rh *RepoHandler) DequeueEvents() []*eventv1.EventPayload
- func (rh *RepoHandler) DownloadBlob(ref string, destinationPath string) (errFn error)
- func (rh *RepoHandler) EnqueueEvent(event *eventv1.EventPayload)
- func (rh *RepoHandler) EventQueueLength() int
- func (rh *RepoHandler) EventQueueUpdate()
- func (rh *RepoHandler) Started() bool
- func (rh *RepoHandler) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HandlerParams ¶
type HandlerParams struct { Dir string Bucket *blob.Bucket RemoteOptions []remote.Option NameOptions []name.Option // contains filtered or unexported fields }
func (HandlerParams) Remove ¶
func (hp HandlerParams) Remove(repository string)
type Manager ¶
type Manager[H Handler] struct { // contains filtered or unexported fields }
func NewManager ¶
func NewManager[H Handler]( params *HandlerParams, newHandler func(*slog.Logger, *RepoHandler) H, ) *Manager[H]
type RepoHandler ¶
type RepoHandler struct { Repository string Params *HandlerParams Queued chan struct{} Stopped atomic.Bool // contains filtered or unexported fields }
func NewRepoHandler ¶
func NewRepoHandler(repository string, params *HandlerParams, cancel context.CancelFunc) *RepoHandler
func (*RepoHandler) DequeueEvents ¶
func (rh *RepoHandler) DequeueEvents() []*eventv1.EventPayload
func (*RepoHandler) DownloadBlob ¶
func (rh *RepoHandler) DownloadBlob(ref string, destinationPath string) (errFn error)
func (*RepoHandler) EnqueueEvent ¶
func (rh *RepoHandler) EnqueueEvent(event *eventv1.EventPayload)
func (*RepoHandler) EventQueueLength ¶
func (rh *RepoHandler) EventQueueLength() int
func (*RepoHandler) EventQueueUpdate ¶
func (rh *RepoHandler) EventQueueUpdate()
func (*RepoHandler) Started ¶
func (rh *RepoHandler) Started() bool
func (*RepoHandler) Stop ¶
func (rh *RepoHandler) Stop()
Click to show internal directories.
Click to hide internal directories.