packages

Documentation

Index

• type Architecture
• type MPSCQueue
  • func NewMPSCQueue(parallelism int) *MPSCQueue
  • func (q *MPSCQueue) Consume(msgHandler func(msg ...Package), errHandler func(err error))
  • func (q *MPSCQueue) ConsumerDoneCh() chan bool
  • func (q *MPSCQueue) ErrorCh() chan error
  • func (q *MPSCQueue) MessageCh() chan []Package
  • func (q *MPSCQueue) ProducersWG() *sync.WaitGroup
  • func (q *MPSCQueue) SendError(err error)
  • func (q *MPSCQueue) SendMessage(msg ...Package)
  • func (q *MPSCQueue) SendMessageAndComplete(msg ...Package)
  • func (q *MPSCQueue) SigConsumerCompletion()
  • func (q *MPSCQueue) SigProducerCompletion()
  • func (q *MPSCQueue) WaitAndClose()
• type Mirror
• type Package
• type Repository
• type SearchOptions
  • func NewSearchOptions(packageName string, architectures []Architecture, seedURLs []string, ...) *SearchOptions
  • func (o *SearchOptions) Architectures() []Architecture
  • func (o *SearchOptions) Log() *output.Logger
  • func (o *SearchOptions) PackageFileNames() []string
  • func (o *SearchOptions) PackageName() string
  • func (o *SearchOptions) ProgressMessage() string
  • func (o *SearchOptions) SeedURLs() []string
  • func (o *SearchOptions) Verbosity() output.Verbosity
• type URITemplate

Types

type Architecture

type Architecture string

type MPSCQueue

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

MPSCQueue provides an option set to manage a sync group of multiple producer workers and single consumer, leveraging Go sync.WaitGroup and channels to notify errors, results and completion of consuming the results from the single consumer worker.

func NewMPSCQueue

func NewMPSCQueue(parallelism int) *MPSCQueue

func (*MPSCQueue) Consume

func (q *MPSCQueue) Consume(msgHandler func(msg ...Package), errHandler func(err error))

Consume listens for both messages and errors on queues and do something with them, as specified by msgHandler and errHandler functions.

func (*MPSCQueue) ConsumerDoneCh

func (q *MPSCQueue) ConsumerDoneCh() chan bool

func (*MPSCQueue) ErrorCh

func (q *MPSCQueue) ErrorCh() chan error

func (*MPSCQueue) MessageCh

func (q *MPSCQueue) MessageCh() chan []Package

func (*MPSCQueue) ProducersWG

func (q *MPSCQueue) ProducersWG() *sync.WaitGroup

func (*MPSCQueue) SendError

func (q *MPSCQueue) SendError(err error)

SendError sends an error message of type error to the errors queue.

func (*MPSCQueue) SendMessage

func (q *MPSCQueue) SendMessage(msg ...Package)

SendMessage sends a message as variadic parameter msg of type packages.Package to the messages queue.

func (*MPSCQueue) SendMessageAndComplete

func (q *MPSCQueue) SendMessageAndComplete(msg ...Package)

SendMessageAndComplete sends a message as variadic parameter msg of type archive.Package to the messages queue, and eventually signals the completion of the current producer.

func (*MPSCQueue) SigConsumerCompletion

func (q *MPSCQueue) SigConsumerCompletion()

SigConsumerCompletion signals that the consumer completed its work.

func (*MPSCQueue) SigProducerCompletion

func (q *MPSCQueue) SigProducerCompletion()

SigProducerCompletion signals that a producer completed its work.

func (*MPSCQueue) WaitAndClose

func (q *MPSCQueue) WaitAndClose()

type Mirror

type Mirror struct {
	Name string
	// The base URL of the package mirror
	// (e.g. https://mirrors.kernel.org/<distribution>)
	URL string
}

type Package

type Package interface {
	GetName() string
	GetVersion() string
	GetRelease() string
	GetArch() string
	GetLocation() string
	URL() string
	FileReaders() []io.Reader
}

type Repository

type Repository struct {
	Name string
	URI  URITemplate
}

type SearchOptions

type SearchOptions struct {
	*output.ProgressOptions

	*MPSCQueue
	// contains filtered or unexported fields
}

func NewSearchOptions

func NewSearchOptions(packageName string, architectures []Architecture, seedURLs []string, verbosity output.Verbosity, progressMessage string, packageFileNames ...string) *SearchOptions

func (*SearchOptions) Architectures

func (o *SearchOptions) Architectures() []Architecture

func (*SearchOptions) Log

func (o *SearchOptions) Log() *output.Logger

func (*SearchOptions) PackageFileNames

func (o *SearchOptions) PackageFileNames() []string

func (*SearchOptions) PackageName

func (o *SearchOptions) PackageName() string

func (*SearchOptions) ProgressMessage

func (o *SearchOptions) ProgressMessage() string

func (*SearchOptions) SeedURLs

func (o *SearchOptions) SeedURLs() []string

func (*SearchOptions) Verbosity

func (o *SearchOptions) Verbosity() output.Verbosity

type URITemplate

type URITemplate string