Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DependencySet = wire.NewSet( NewInProcessExecutorLogger, NewExecutor, wire.Bind(new(Executor), new(*InProcessExecutor)), wire.Struct(new(InProcessQueue), "*"), )
Functions ¶
This section is empty.
Types ¶
type InProcessExecutor ¶
type InProcessExecutor struct { Logger InProcessExecutorLogger // contains filtered or unexported fields }
func NewExecutor ¶
func NewExecutor( logger InProcessExecutorLogger, sendMessageTask *tasks.SendMessagesTask, ) *InProcessExecutor
type InProcessExecutorLogger ¶
func NewInProcessExecutorLogger ¶
func NewInProcessExecutorLogger(lf *log.Factory) InProcessExecutorLogger
type InProcessQueue ¶
type InProcessQueue struct {
Executor Executor
}
func (*InProcessQueue) Enqueue ¶
func (q *InProcessQueue) Enqueue(param task.Param)
Click to show internal directories.
Click to hide internal directories.