repository

Documentation

Index

• type Handler
• type HandlerParams
  • func (hp HandlerParams) Remove(repository string)
• type Manager
  • func NewManager[H Handler](params *HandlerParams, newHandler func(*slog.Logger, *RepoHandler) H) *Manager[H]
  • func (m *Manager[H]) Get(ctx context.Context, repository string) H
  • func (m *Manager[H]) GetAll() map[string]H
  • func (m *Manager[H]) Has(repository string) bool
• type RepoHandler
  • func NewRepoHandler(repository string, params *HandlerParams, cancel context.CancelFunc) *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()

Types

type Handler

type Handler interface {
	QueueEvent(event *eventv1.EventPayload, store bool) error
	Started() bool
	Start(context.Context)
	Stop()
}

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]

func (*Manager[H]) Get

func (m *Manager[H]) Get(ctx context.Context, repository string) H

func (*Manager[H]) GetAll

func (m *Manager[H]) GetAll() map[string]H

func (*Manager[H]) Has

func (m *Manager[H]) Has(repository string) bool

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()