worker

Documentation

Overview

Package worker implements the worker side of Mettle.

Index

• func RunForever(...)
• func RunOne(instanceName, name, storage, dir, cacheDir, sandbox string, ...) error
• type Cache
  • func NewCache(root string) *Cache
  • func (c *Cache) MustStoreAll(instanceName string, targets []string, storage string, secureStorage bool)
  • func (c *Cache) Retrieve(key, dest string, mode os.FileMode) bool
  • func (c *Cache) StoreAll(instanceName string, targets []string, storage string, secureStorage bool) error

Functions

func RunForever

func RunForever(instanceName, requestQueue, responseQueue, name, storage, dir, cacheDir, browserURL, sandbox string, clean, secureStorage bool, timeout time.Duration, maxCacheSize int64)

RunForever runs the worker, receiving jobs until terminated.

func RunOne

func RunOne(instanceName, name, storage, dir, cacheDir, sandbox string, clean, secureStorage bool, timeout time.Duration, hash string, size int64) error

RunOne runs one single request, returning any error received.

Types

type Cache

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

A Cache implements a filesystem-based blob cache. Since all the blobs are keyed by hash we don't have to worry about invalidation. In normal use the server never writes it; we prefill a selected artifact list offline.

func NewCache

func NewCache(root string) *Cache

NewCache returns a new cache instance.

func (*Cache) MustStoreAll

func (c *Cache) MustStoreAll(instanceName string, targets []string, storage string, secureStorage bool)

MustStoreAll is like StoreAll but dies on errors.

func (*Cache) Retrieve

func (c *Cache) Retrieve(key, dest string, mode os.FileMode) bool

Retrieve copies a blob from the cache to the given location. It returns true if retrieved.

func (*Cache) StoreAll

func (c *Cache) StoreAll(instanceName string, targets []string, storage string, secureStorage bool) error

StoreAll reads the given file and stores all the blobs it finds into the cache.