state

Documentation

Index

• Constants
• func Processor(ctx context.Context, in chan *WorkRequest, out chan *WorkResponse)
• type WorkRequest
• type WorkResponse
  • func Process(wr *WorkRequest) *WorkResponse

Constants

const (
	// Add values
	Add op = "add"
	// Subtract values
	Subtract = "sub"
	// Multiply values
	Multiply = "mult"
	// Divide values
	Divide = "div"
)

Functions

func Processor

func Processor(ctx context.Context, in chan *WorkRequest, out chan *WorkResponse)

Processor routes work to Process

Types

type WorkRequest

type WorkRequest struct {
	Operation op
	Value1    int64
	Value2    int64
}

WorkRequest perform an op on two values

type WorkResponse

type WorkResponse struct {
	Wr     *WorkRequest
	Result int64
	Err    error
}

WorkResponse returns the result and any errors

func Process

func Process(wr *WorkRequest) *WorkResponse

Process switches on operation type Then does work