mirrorrepository

Documentation

Index

• type Handler
  • func NewHandler(logger *slog.Logger, repoHandler *repository.RepoHandler) *Handler
  • func (h *Handler) CreateRepository(ctx context.Context, properties *apiv1.RepositoryProperties) (err error)
  • func (h *Handler) DeleteRepository(ctx context.Context, deleteFiles bool) (err error)
  • func (h *Handler) DeleteRepositoryFile(ctx context.Context, file string) (err error)
  • func (h *Handler) GenerateIndexes() error
  • func (h *Handler) GenerateRepository(_ context.Context) (err error)
  • func (h *Handler) GetRepository(ctx context.Context) (properties *apiv1.RepositoryProperties, err error)
  • func (h *Handler) GetRepositoryFile(ctx context.Context, name string) (repositoryFile *apiv1.RepositoryFile, err error)
  • func (h *Handler) GetRepositoryFileByReference(ctx context.Context, reference string) (repositoryFile *apiv1.RepositoryFile, err error)
  • func (h *Handler) GetRepositoryFileByReferenceRaw(ctx context.Context, reference string) (repositoryFile *mirrordb.RepositoryFile, err error)
  • func (h *Handler) GetRepositoryFileCount(ctx context.Context) (count int, err error)
  • func (h *Handler) GetRepositorySyncPlan(_ context.Context) (syncPlan *apiv1.RepositorySyncPlan, err error)
  • func (h *Handler) GetRepositorySyncStatus(context.Context) (syncStatus *apiv1.SyncStatus, err error)
  • func (h *Handler) ListRepositoryFiles(ctx context.Context, _ *apiv1.Page) (repositoryFiles []*apiv1.RepositoryFile, err error)
  • func (h *Handler) ListRepositoryLogs(ctx context.Context, _ *apiv1.Page) (logs []apiv1.RepositoryLog, err error)
  • func (h *Handler) ListRepositorySymlinks(ctx context.Context, _ *apiv1.Page) (repositoryFiles []*apiv1.RepositoryFile, err error)
  • func (h *Handler) QueueEvent(event *eventv1.EventPayload, store bool) error
  • func (h *Handler) Start(ctx context.Context)
  • func (h *Handler) SyncRepository(_ context.Context, wait bool) (err error)
  • func (h *Handler) UpdateRepository(ctx context.Context, properties *apiv1.RepositoryProperties) (err error)
• type PlanSyncer
  • func NewPlanSyncer(h *Handler, config mirrorConfig, configID uint64, parallelism int, ...) *PlanSyncer
  • func (s *PlanSyncer) Sync() error
• type Storage
  • func NewStorage(h *Handler, config mirrorConfig, configID uint64) *Storage
  • func (s *Storage) Close()
  • func (s *Storage) Delete(filePath string, _ rsync.FileMode) error
  • func (s *Storage) List() (rsync.FileList, error)
  • func (s *Storage) Put(filePath string, content io.Reader, fileSize int64, ...) (written int64, err error)

Types

type Handler

type Handler struct {
	*repository.RepoHandler
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(logger *slog.Logger, repoHandler *repository.RepoHandler) *Handler

func (*Handler) CreateRepository

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

func (*Handler) DeleteRepository

func (h *Handler) DeleteRepository(ctx context.Context, deleteFiles bool) (err error)

func (*Handler) DeleteRepositoryFile

func (h *Handler) DeleteRepositoryFile(ctx context.Context, file string) (err error)

func (*Handler) GenerateIndexes

func (h *Handler) GenerateIndexes() error

func (*Handler) GenerateRepository

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

func (*Handler) GetRepository

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

func (*Handler) GetRepositoryFile

func (h *Handler) GetRepositoryFile(ctx context.Context, name string) (repositoryFile *apiv1.RepositoryFile, err error)

func (*Handler) GetRepositoryFileByReference

func (h *Handler) GetRepositoryFileByReference(ctx context.Context, reference string) (repositoryFile *apiv1.RepositoryFile, err error)

func (*Handler) GetRepositoryFileByReferenceRaw

func (h *Handler) GetRepositoryFileByReferenceRaw(ctx context.Context, reference string) (repositoryFile *mirrordb.RepositoryFile, err error)

func (*Handler) GetRepositoryFileCount

func (h *Handler) GetRepositoryFileCount(ctx context.Context) (count int, err error)

func (*Handler) GetRepositorySyncPlan

func (h *Handler) GetRepositorySyncPlan(_ context.Context) (syncPlan *apiv1.RepositorySyncPlan, err error)

func (*Handler) GetRepositorySyncStatus

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

func (*Handler) ListRepositoryFiles

func (h *Handler) ListRepositoryFiles(ctx context.Context, _ *apiv1.Page) (repositoryFiles []*apiv1.RepositoryFile, err error)

func (*Handler) ListRepositoryLogs

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

func (*Handler) ListRepositorySymlinks

func (h *Handler) ListRepositorySymlinks(ctx context.Context, _ *apiv1.Page) (repositoryFiles []*apiv1.RepositoryFile, err error)

func (*Handler) QueueEvent

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

func (*Handler) Start

func (h *Handler) Start(ctx context.Context)

func (*Handler) SyncRepository

func (h *Handler) SyncRepository(_ context.Context, wait bool) (err error)

func (*Handler) UpdateRepository

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

type PlanSyncer

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

func NewPlanSyncer

func NewPlanSyncer(h *Handler, config mirrorConfig, configID uint64, parallelism int, plan *rsync.SyncPlan) *PlanSyncer

func (*PlanSyncer) Sync

func (s *PlanSyncer) Sync() error

type Storage

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

func NewStorage

func NewStorage(h *Handler, config mirrorConfig, configID uint64) *Storage

func (*Storage) Close

func (s *Storage) Close()

func (*Storage) Delete

func (s *Storage) Delete(filePath string, _ rsync.FileMode) error

func (*Storage) List

func (s *Storage) List() (rsync.FileList, error)

func (*Storage) Put

func (s *Storage) Put(filePath string, content io.Reader, fileSize int64, metadata rsync.FileMetadata) (written int64, err error)