mr

type GenerateFunc func(source chan<- interface{})

type IRule interface {
	Output(req interface{}) *RuleOutput
}

type IWorkFlow interface {
	DoSerialGroup() (res []RuleOutput)
	DoPriorityGroup() (res []RuleOutput)
	DoParallelGroup() (res []RuleOutput)
}

type MapFunc func(item interface{}, writer Writer)

type MapperFunc func(item interface{}, writer Writer, cancel func(error))

type Option func(opts *mapReduceOptions)

type PriorityGroup struct {
	Optimal RuleOutput
	// contains filtered or unexported fields
}

type ReducerFunc func(pipe <-chan interface{}, writer Writer, cancel func(error))

type RuleBase struct{}

type RuleOutput struct {
	Status int
	// Priority. build
	Priority uint32
	Result   interface{}
	Error    error
}

type VoidMapFunc func(item interface{})

type VoidReducerFunc func(pipe <-chan interface{}, cancel func(error))

type WGroup struct {
	Type int

	//Rules
	//example:     RuleA{State: Parallel, Priority: 1},
	Rules []interface{}

	//Hub
	//0 if len([]*RuleOutput) not zero  then return
	//1
	Hub int
}

type Writer interface {
	Write(v interface{})
}