Documentation
¶
Index ¶
- type 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) DeleteRepositoryFilesByMode(ctx context.Context, mode uint32) (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) GetRepositoryFileRaw(ctx context.Context, name string) (repositoryFile *mirrordb.RepositoryFile, 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) SyncRepositoryWithConfig(_ context.Context, mirrorConfigs []apiv1.MirrorConfig, ...) (err error)
- func (h *Handler) UpdateRepository(ctx context.Context, properties *apiv1.RepositoryProperties) (err error)
- type MirrorSyncer
- type MirrorSyncerPlan
- type PlanSyncer
- type Storage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*Handler) DeleteRepository ¶
func (*Handler) DeleteRepositoryFile ¶ added in v0.0.32
func (*Handler) DeleteRepositoryFilesByMode ¶ added in v0.0.35
func (*Handler) GenerateIndexes ¶
func (*Handler) GenerateRepository ¶ added in v0.0.32
func (*Handler) GetRepository ¶
func (*Handler) GetRepositoryFile ¶
func (*Handler) GetRepositoryFileByReference ¶ added in v0.0.32
func (*Handler) GetRepositoryFileByReferenceRaw ¶ added in v0.0.32
func (*Handler) GetRepositoryFileCount ¶ added in v0.0.32
func (*Handler) GetRepositoryFileRaw ¶ added in v0.0.36
func (*Handler) GetRepositorySyncPlan ¶ added in v0.0.32
func (*Handler) GetRepositorySyncStatus ¶
func (*Handler) ListRepositoryFiles ¶
func (*Handler) ListRepositoryLogs ¶
func (*Handler) ListRepositorySymlinks ¶
func (*Handler) QueueEvent ¶
func (h *Handler) QueueEvent(event *eventv1.EventPayload, store bool) error
func (*Handler) SyncRepository ¶
func (*Handler) SyncRepositoryWithConfig ¶ added in v0.0.34
func (*Handler) UpdateRepository ¶
type MirrorSyncer ¶ added in v0.0.34
type MirrorSyncer struct {
// contains filtered or unexported fields
}
func NewMirrorSyncer ¶ added in v0.0.34
func NewMirrorSyncer(h *Handler, config mirrorConfig, configID uint64, parallelism int) (*MirrorSyncer, error)
func (*MirrorSyncer) ListRepositoryFiles ¶ added in v0.0.34
func (s *MirrorSyncer) ListRepositoryFiles() ([]*apiv1.RepositoryFile, error)
Custom list method since generated client doesn't supply user credentials in the URL.
func (*MirrorSyncer) Plan ¶ added in v0.0.34
func (s *MirrorSyncer) Plan() (*MirrorSyncerPlan, error)
func (*MirrorSyncer) Sync ¶ added in v0.0.34
func (s *MirrorSyncer) Sync() error
type MirrorSyncerPlan ¶ added in v0.0.34
type MirrorSyncerPlan struct {
AddRemoteFiles []*mirrordb.RepositoryFile
DeleteLocalFiles []*mirrordb.RepositoryFile
}
type PlanSyncer ¶ added in v0.0.32
type PlanSyncer struct {
// contains filtered or unexported fields
}
func NewPlanSyncer ¶ added in v0.0.32
func (*PlanSyncer) Sync ¶ added in v0.0.32
func (s *PlanSyncer) Sync() error
Source Files
Click to show internal directories.
Click to hide internal directories.