bmw

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

type Dispatcher struct {
	// A pool of workers channels that are registered with the dispatcher
	WorkerPool chan chan RetryJob
	Config     *DispatcherConfig
	// contains filtered or unexported fields
}

type DispatcherConfig struct {
	MaxWorkers int
	WorkerRate int
}

type GoChannelConfig struct {
}

type Handler interface {
	Handle(job RetryJob) error
}

type HandlerRoute struct {
	Host    string // for api
	Path    string // for api
	Topic   string // for queue (pusher, waiter)
	Handler Handler
}

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

type MultiHandlerRoutes struct {
	Host   string
	Routes []SingleRoute
}

type Parser interface {
	Parse(*http.Request) interface{}
}

type Publisher interface {
	Register() error
	Unregister() error
}

type Pusher interface {
	Push([]byte) error
}

type PusherWaiter interface {
	Pusher
	Waiter
}

type RetryJob struct {
	ID      string `json:"id"`
	Retry   uint8  `json:"retry"`
	Payload []byte `json:"payload"`
}

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

type Serializer interface {
	Serialize(interface{}) []byte
	Unserialize([]byte) interface{}
}

type ServiceInfo struct {
	ServiceName string `json:"serviceName"`
	Host        string `json:"host"`
	Privilege   int    `json:"privilege"`
	Key         string `json:"key"`
}

type SingleRoute struct {
	Path    string // for api
	Topic   string // for queue (pusher, waiter)
	Handler Handler
}

type Waiter interface {
	Wait() []byte
}

type Worker struct {
	ID         string
	WorkerPool chan chan RetryJob
	JobChannel chan RetryJob
	// contains filtered or unexported fields
}