worker

Documentation

Overview

Package worker impelements worker goroutines to generate random values. The value will be used by blackbox agent for file encryption/decryption.

Index

• func GenerateValue(size int) (string, error)
• func ParseRequest(r io.Reader) (string, error)
• type Pair
• type Worker
  • func NewWorker(p chan net.Conn, r chan Pair, c *cache.Cache) *Worker
  • func (w *Worker) Loop()
  • func (w *Worker) Stop() error

Functions

func GenerateValue

func GenerateValue(size int) (string, error)

func ParseRequest

func ParseRequest(r io.Reader) (string, error)

Types

type Pair

type Pair struct {
	Key   string
	Value string
}

type Worker

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

func NewWorker

func NewWorker(p chan net.Conn, r chan Pair, c *cache.Cache) *Worker

Create worker

func (*Worker) Loop

func (w *Worker) Loop()

Worker looping to get pending connection and then doWork. It also receives stopping signal to terminate.

func (*Worker) Stop

func (w *Worker) Stop() error

Stop worker goroutine, it passes an chan error to worker.Stopping to get error back from worker.