pipeline

Documentation

Index

• func NewPipeline(ctx context.Context, numEncoders, numPrinters int) (chan string, chan string)
• type Job
• type Worker
  • func (w *Worker) Encode(ctx context.Context)
  • func (w *Worker) Print(ctx context.Context)
  • func (w *Worker) Work(ctx context.Context, j Job)

Functions

func NewPipeline

func NewPipeline(ctx context.Context, numEncoders, numPrinters int) (chan string, chan string)

NewPipeline initializes the workers and connects them, it returns the input of the pipeline and the final output

Types

type Job

type Job string

Job is a job a worker can do

const (
	// Print echo's all input to
	// stdout
	Print Job = "print"
	// Encode base64 encodes input
	Encode Job = "encode"
)

type Worker

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

Worker have one role that is determined when Work is called

func (*Worker) Encode

func (w *Worker) Encode(ctx context.Context)

Encode takes plain text as int and returns "string => <base64 string encoding> as out

func (*Worker) Print

func (w *Worker) Print(ctx context.Context)

Print prints w.in and repalys it on w.out

func (*Worker) Work

func (w *Worker) Work(ctx context.Context, j Job)

Work is how to dispatch a worker, they are assigned a job here