mirror

Documentation

Index

• type ExtraMetadataFilter
• type PackageFilter
• type Semaphore
  • func NewWeighted(n int64) *Semaphore
  • func (s *Semaphore) Acquire(ctx context.Context, n int64, timeout time.Duration) error
  • func (s *Semaphore) Release(n int64)
• type Syncer
  • func NewSyncer(downloadDir string, mirrorURLs []*url.URL, options ...SyncerOption) *Syncer
  • func (s *Syncer) DownloadMetadata(ctx context.Context, extraMetadataFilterFn ExtraMetadataFilter) <-chan int
  • func (s *Syncer) DownloadPackages(ctx context.Context, packageFilterFn PackageFilter) (<-chan string, int)
  • func (s *Syncer) Err() error
  • func (s *Syncer) FileReader(ctx context.Context, path string) (io.ReadCloser, error)
  • func (s *Syncer) RepomdData(index int) *yummeta.RepoMdData
  • func (s *Syncer) RepomdXML() io.Reader
  • func (s *Syncer) RepomdXMLSignature() io.Reader
• type SyncerOption
  • func WithKeyring(keyring openpgp.KeyRing) SyncerOption
  • func WithProxyURL(proxy *url.URL, httpsProxy bool) SyncerOption
  • func WithTLSConfig(tlsConfig *tls.Config) SyncerOption

Types

type ExtraMetadataFilter

type ExtraMetadataFilter func(dataType string, checksum string) bool

type PackageFilter

type PackageFilter func(id string) bool

type Semaphore

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

func NewWeighted

func NewWeighted(n int64) *Semaphore

func (*Semaphore) Acquire

func (s *Semaphore) Acquire(ctx context.Context, n int64, timeout time.Duration) error

func (*Semaphore) Release

func (s *Semaphore) Release(n int64)

type Syncer

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

func NewSyncer

func NewSyncer(downloadDir string, mirrorURLs []*url.URL, options ...SyncerOption) *Syncer

func (*Syncer) DownloadMetadata

func (s *Syncer) DownloadMetadata(ctx context.Context, extraMetadataFilterFn ExtraMetadataFilter) <-chan int

func (*Syncer) DownloadPackages

func (s *Syncer) DownloadPackages(ctx context.Context, packageFilterFn PackageFilter) (<-chan string, int)

func (*Syncer) Err

func (s *Syncer) Err() error

func (*Syncer) FileReader

func (s *Syncer) FileReader(ctx context.Context, path string) (io.ReadCloser, error)

func (*Syncer) RepomdData

func (s *Syncer) RepomdData(index int) *yummeta.RepoMdData

func (*Syncer) RepomdXML

func (s *Syncer) RepomdXML() io.Reader

func (*Syncer) RepomdXMLSignature

func (s *Syncer) RepomdXMLSignature() io.Reader

type SyncerOption

type SyncerOption func(*Syncer)

func WithKeyring

func WithKeyring(keyring openpgp.KeyRing) SyncerOption

func WithProxyURL

func WithProxyURL(proxy *url.URL, httpsProxy bool) SyncerOption

func WithTLSConfig

func WithTLSConfig(tlsConfig *tls.Config) SyncerOption