repository

Documentation

Index

• Constants
• type Handler
  • func NewHandler(logger *slog.Logger, repository string, params *HandlerParams) *Handler
  • func (h *Handler) CreateRepository(ctx context.Context, properties *apiv1.RepositoryProperties) (err error)
  • func (h *Handler) DeleteRepository(_ context.Context) (err error)
  • func (h *Handler) GetRepository(ctx context.Context) (properties *apiv1.RepositoryProperties, err error)
  • func (h *Handler) GetRepositoryPackage(ctx context.Context, id string) (repositoryPackage *apiv1.RepositoryPackage, err error)
  • func (h *Handler) GetRepositorySyncStatus(context.Context) (syncStatus *apiv1.SyncStatus, err error)
  • func (h *Handler) ListRepositoryLogs(ctx context.Context, _ *apiv1.Page) (logs []apiv1.RepositoryLog, err error)
  • func (h *Handler) ListRepositoryPackages(ctx context.Context, _ *apiv1.Page) (repositoryPackages []*apiv1.RepositoryPackage, err error)
  • func (h *Handler) QueueEvent(event *eventv1.EventPayload, store bool) error
  • func (h *Handler) RemoveRepositoryPackage(_ context.Context, _ string) (err error)
  • func (h *Handler) Started() bool
  • func (h *Handler) Stop()
  • func (h *Handler) SyncRepository(context.Context) (err error)
  • func (h *Handler) UpdateRepository(ctx context.Context, properties *apiv1.RepositoryProperties) (err error)
• type HandlerParams

Constants

const RepomdXMLTag = "repomdxml"

Types

type Handler

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

func NewHandler

func NewHandler(logger *slog.Logger, repository string, params *HandlerParams) *Handler

func (*Handler) CreateRepository

func (h *Handler) CreateRepository(ctx context.Context, properties *apiv1.RepositoryProperties) (err error)

func (*Handler) DeleteRepository

func (h *Handler) DeleteRepository(_ context.Context) (err error)

func (*Handler) GetRepository

func (h *Handler) GetRepository(ctx context.Context) (properties *apiv1.RepositoryProperties, err error)

func (*Handler) GetRepositoryPackage

func (h *Handler) GetRepositoryPackage(ctx context.Context, id string) (repositoryPackage *apiv1.RepositoryPackage, err error)

func (*Handler) GetRepositorySyncStatus

func (h *Handler) GetRepositorySyncStatus(context.Context) (syncStatus *apiv1.SyncStatus, err error)

func (*Handler) ListRepositoryLogs

func (h *Handler) ListRepositoryLogs(ctx context.Context, _ *apiv1.Page) (logs []apiv1.RepositoryLog, err error)

func (*Handler) ListRepositoryPackages

func (h *Handler) ListRepositoryPackages(ctx context.Context, _ *apiv1.Page) (repositoryPackages []*apiv1.RepositoryPackage, err error)

func (*Handler) QueueEvent

func (h *Handler) QueueEvent(event *eventv1.EventPayload, store bool) error

func (*Handler) RemoveRepositoryPackage

func (h *Handler) RemoveRepositoryPackage(_ context.Context, _ string) (err error)

func (*Handler) Started

func (h *Handler) Started() bool

func (*Handler) Stop

func (h *Handler) Stop()

func (*Handler) SyncRepository

func (h *Handler) SyncRepository(context.Context) (err error)

func (*Handler) UpdateRepository

func (h *Handler) UpdateRepository(ctx context.Context, properties *apiv1.RepositoryProperties) (err error)

type HandlerParams

type HandlerParams struct {
	Dir           string
	Bucket        *blob.Bucket
	RemoteOptions []remote.Option
	NameOptions   []name.Option
	Remove        func(string)
}