processing

Documentation

Index

• func Process(in Decoder, out io.Writer, w Worker, m Marshaler, workers uint)
• type Decoder
• type Handler
• type Marshaler
• type Worker

Functions

func Process

func Process(in Decoder, out io.Writer, w Worker, m Marshaler, workers uint)

Types

type Decoder

type Decoder interface {
	DecodeNext() (interface{}, error)
}

type Handler

type Handler func(interface{}) interface{}

type Marshaler

type Marshaler interface {
	Marshal(interface{}) ([]byte, error)
}

type Worker

type Worker interface {
	MakeHandler(uint) Handler
	Success() uint
	Failure() uint
	Total() uint
	Done()
	RunCount() uint
}