Files
shop/order/processor.go
2016-03-08 11:14:19 +01:00

23 lines
383 B
Go

package order
import (
"gopkg.in/mgo.v2/bson"
)
type Processor interface {
OrderCustomProvider() OrderCustomProvider
GetQuery() *bson.M
SetQuery(*bson.M)
Process(*Order) error
Concurrency() int
}
type BulkProcessor interface {
OrderCustomProvider() OrderCustomProvider
ProcessBulk([]*Order) []error
GetQuery() *bson.M
SetQuery(*bson.M)
Limit() int
Concurrency() int
}