aptly

Documentation

Overview

Package aptly provides common infrastructure that doesn't depend directly on Debian or CentOS

Index

• Constants
• type ConsoleResultReporter
  • func (c *ConsoleResultReporter) Added(msg string, a ...interface{})
  • func (c *ConsoleResultReporter) Removed(msg string, a ...interface{})
  • func (c *ConsoleResultReporter) Warning(msg string, a ...interface{})
• type Downloader
• type LocalPublishedStorage
• type PackagePool
• type Progress
• type PublishedStorage
• type PublishedStorageProvider
• type RecordingResultReporter
  • func (r *RecordingResultReporter) Added(msg string, a ...interface{})
  • func (r *RecordingResultReporter) Removed(msg string, a ...interface{})
  • func (r *RecordingResultReporter) Warning(msg string, a ...interface{})
• type ResultReporter

Constants

const EnableDebug = false

Enable debugging features?

const Version = "0.9.1"

Version of aptly

Types

type ConsoleResultReporter

type ConsoleResultReporter struct {
	Progress Progress
}

ConsoleResultReporter is implementation of ResultReporter that prints in colors to console

func (*ConsoleResultReporter) Added

func (c *ConsoleResultReporter) Added(msg string, a ...interface{})

Added is signal that something has been added (green)

func (*ConsoleResultReporter) Removed

func (c *ConsoleResultReporter) Removed(msg string, a ...interface{})

Removed is signal that something has been removed (red)

func (*ConsoleResultReporter) Warning

func (c *ConsoleResultReporter) Warning(msg string, a ...interface{})

Warning is non-fatal error message (yellow)

type Downloader

type Downloader interface {
	// Download starts new download task
	Download(url string, destination string, result chan<- error)
	// DownloadWithChecksum starts new download task with checksum verification
	DownloadWithChecksum(url string, destination string, result chan<- error, expected utils.ChecksumInfo, ignoreMismatch bool)
	// Pause pauses task processing
	Pause()
	// Resume resumes task processing
	Resume()
	// Shutdown stops downloader after current tasks are finished,
	// but doesn't process rest of queue
	Shutdown()
	// Abort stops downloader without waiting for shutdown
	Abort()
	// GetProgress returns Progress object
	GetProgress() Progress
}

Downloader is parallel HTTP fetcher

type LocalPublishedStorage

type LocalPublishedStorage interface {
	// PublicPath returns root of public part
	PublicPath() string
}

LocalPublishedStorage is published storage on local filesystem

type PackagePool

type PackagePool interface {
	// Path returns full path to package file in pool given any name and hash of file contents
	Path(filename string, hashMD5 string) (string, error)
	// RelativePath returns path relative to pool's root for package files given MD5 and original filename
	RelativePath(filename string, hashMD5 string) (string, error)
	// FilepathList returns file paths of all the files in the pool
	FilepathList(progress Progress) ([]string, error)
	// Remove deletes file in package pool returns its size
	Remove(path string) (size int64, err error)
	// Import copies file into package pool
	Import(path string, hashMD5 string) error
}

PackagePool is asbtraction of package pool storage.

PackagePool stores all the package files, deduplicating them.

type Progress

type Progress interface {
	// Writer interface to support progress bar ticking
	io.Writer
	// Start makes progress start its work
	Start()
	// Shutdown shuts down progress display
	Shutdown()
	// Flush returns when all queued messages are sent
	Flush()
	// InitBar starts progressbar for count bytes or count items
	InitBar(count int64, isBytes bool)
	// ShutdownBar stops progress bar and hides it
	ShutdownBar()
	// AddBar increments progress for progress bar
	AddBar(count int)
	// SetBar sets current position for progress bar
	SetBar(count int)
	// Printf does printf but in safe manner: not overwriting progress bar
	Printf(msg string, a ...interface{})
	// ColoredPrintf does printf in colored way + newline
	ColoredPrintf(msg string, a ...interface{})
}

Progress is a progress displaying entity, it allows progress bars & simple prints

type PublishedStorage

type PublishedStorage interface {
	// MkDir creates directory recursively under public path
	MkDir(path string) error
	// PutFile puts file into published storage at specified path
	PutFile(path string, sourceFilename string) error
	// RemoveDirs removes directory structure under public path
	RemoveDirs(path string, progress Progress) error
	// Remove removes single file under public path
	Remove(path string) error
	// LinkFromPool links package file from pool to dist's pool location
	LinkFromPool(publishedDirectory string, sourcePool PackagePool, sourcePath, sourceMD5 string, force bool) error
	// Filelist returns list of files under prefix
	Filelist(prefix string) ([]string, error)
	// RenameFile renames (moves) file
	RenameFile(oldName, newName string) error
}

PublishedStorage is abstraction of filesystem storing all published repositories

type PublishedStorageProvider

type PublishedStorageProvider interface {
	// GetPublishedStorage returns PublishedStorage by name
	GetPublishedStorage(name string) PublishedStorage
}

PublishedStorageProvider is a thing that returns PublishedStorage by name

type RecordingResultReporter

type RecordingResultReporter struct {
	Warnings     []string
	AddedLines   []string `json:"Added"`
	RemovedLines []string `json:"Removed"`
}

RecordingResultReporter is implementation of ResultReporter that collects all messages

func (*RecordingResultReporter) Added

func (r *RecordingResultReporter) Added(msg string, a ...interface{})

Added is signal that something has been added

func (*RecordingResultReporter) Removed

func (r *RecordingResultReporter) Removed(msg string, a ...interface{})

Removed is signal that something has been removed

func (*RecordingResultReporter) Warning

func (r *RecordingResultReporter) Warning(msg string, a ...interface{})

Warning is non-fatal error message

type ResultReporter

type ResultReporter interface {
	// Warning is non-fatal error message
	Warning(msg string, a ...interface{})
	// Removed is signal that something has been removed
	Removed(msg string, a ...interface{})
	// Added is signal that something has been added
	Added(msg string, a ...interface{})
}

ResultReporter is abstraction for result reporting from complex processing functions