mirror

Documentation

Index

• type Plugin
  • func New(ctx context.Context, beskarMirrorConfig *config.BeskarMirrorConfig) (*Plugin, error)
  • func (p *Plugin) Config() pluginsrv.Config
  • func (p *Plugin) Context() context.Context
  • func (p *Plugin) CreateRepository(ctx context.Context, repository string, properties *apiv1.RepositoryProperties) (err error)
  • func (p *Plugin) DeleteRepository(ctx context.Context, repository string, deleteFiles bool) (err error)
  • func (p *Plugin) DeleteRepositoryFile(ctx context.Context, repository, file string) (err error)
  • func (p *Plugin) DeleteRepositoryFilesByMode(ctx context.Context, repository string, mode uint32) (err error)
  • func (p *Plugin) GenerateRepository(ctx context.Context, repository string) (err error)
  • func (p *Plugin) GetRepository(ctx context.Context, repository string) (properties *apiv1.RepositoryProperties, err error)
  • func (p *Plugin) GetRepositoryFile(ctx context.Context, repository, file string) (repositoryFile *apiv1.RepositoryFile, err error)
  • func (p *Plugin) GetRepositoryFileCount(ctx context.Context, repository string) (count int, err error)
  • func (p *Plugin) GetRepositorySyncPlan(ctx context.Context, repository string) (syncPlan *apiv1.RepositorySyncPlan, err error)
  • func (p *Plugin) GetRepositorySyncStatus(ctx context.Context, repository string) (syncStatus *apiv1.SyncStatus, err error)
  • func (p *Plugin) ListRepositoryFiles(ctx context.Context, repository string, page *apiv1.Page) (repositoryFiles []*apiv1.RepositoryFile, err error)
  • func (p *Plugin) ListRepositoryLogs(ctx context.Context, repository string, page *apiv1.Page) (logs []apiv1.RepositoryLog, err error)
  • func (p *Plugin) RepositoryManager() *repository.Manager[*mirrorrepository.Handler]
  • func (p *Plugin) Start(transport http.RoundTripper, _ *mtls.CAPEM, beskarMeta *gossip.BeskarMeta) error
  • func (p *Plugin) SyncRepository(ctx context.Context, repository string, wait bool) (err error)
  • func (p *Plugin) SyncRepositoryWithConfig(ctx context.Context, repository string, mirrorConfigs []apiv1.MirrorConfig, ...) (err error)
  • func (p *Plugin) UpdateRepository(ctx context.Context, repository string, properties *apiv1.RepositoryProperties) (err error)
  • func (p *Plugin) WebHandler(w http.ResponseWriter, r *http.Request)

Types

type Plugin

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

func New

func New(ctx context.Context, beskarMirrorConfig *config.BeskarMirrorConfig) (*Plugin, error)

func (*Plugin) Config

func (p *Plugin) Config() pluginsrv.Config

func (*Plugin) Context

func (p *Plugin) Context() context.Context

func (*Plugin) CreateRepository

func (p *Plugin) CreateRepository(ctx context.Context, repository string, properties *apiv1.RepositoryProperties) (err error)

func (*Plugin) DeleteRepository

func (p *Plugin) DeleteRepository(ctx context.Context, repository string, deleteFiles bool) (err error)

func (*Plugin) DeleteRepositoryFile

func (p *Plugin) DeleteRepositoryFile(ctx context.Context, repository, file string) (err error)

func (*Plugin) DeleteRepositoryFilesByMode

func (p *Plugin) DeleteRepositoryFilesByMode(ctx context.Context, repository string, mode uint32) (err error)

func (*Plugin) GenerateRepository

func (p *Plugin) GenerateRepository(ctx context.Context, repository string) (err error)

func (*Plugin) GetRepository

func (p *Plugin) GetRepository(ctx context.Context, repository string) (properties *apiv1.RepositoryProperties, err error)

func (*Plugin) GetRepositoryFile

func (p *Plugin) GetRepositoryFile(ctx context.Context, repository, file string) (repositoryFile *apiv1.RepositoryFile, err error)

func (*Plugin) GetRepositoryFileCount

func (p *Plugin) GetRepositoryFileCount(ctx context.Context, repository string) (count int, err error)

func (*Plugin) GetRepositorySyncPlan

func (p *Plugin) GetRepositorySyncPlan(ctx context.Context, repository string) (syncPlan *apiv1.RepositorySyncPlan, err error)

func (*Plugin) GetRepositorySyncStatus

func (p *Plugin) GetRepositorySyncStatus(ctx context.Context, repository string) (syncStatus *apiv1.SyncStatus, err error)

func (*Plugin) ListRepositoryFiles

func (p *Plugin) ListRepositoryFiles(ctx context.Context, repository string, page *apiv1.Page) (repositoryFiles []*apiv1.RepositoryFile, err error)

func (*Plugin) ListRepositoryLogs

func (p *Plugin) ListRepositoryLogs(ctx context.Context, repository string, page *apiv1.Page) (logs []apiv1.RepositoryLog, err error)

func (*Plugin) RepositoryManager

func (p *Plugin) RepositoryManager() *repository.Manager[*mirrorrepository.Handler]

func (*Plugin) Start

func (p *Plugin) Start(transport http.RoundTripper, _ *mtls.CAPEM, beskarMeta *gossip.BeskarMeta) error

func (*Plugin) SyncRepository

func (p *Plugin) SyncRepository(ctx context.Context, repository string, wait bool) (err error)

func (*Plugin) SyncRepositoryWithConfig

func (p *Plugin) SyncRepositoryWithConfig(ctx context.Context, repository string, mirrorConfigs []apiv1.MirrorConfig, webConfig *apiv1.WebConfig, wait bool) (err error)

func (*Plugin) UpdateRepository

func (p *Plugin) UpdateRepository(ctx context.Context, repository string, properties *apiv1.RepositoryProperties) (err error)

func (*Plugin) WebHandler

func (p *Plugin) WebHandler(w http.ResponseWriter, r *http.Request)