Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChannelQueue ¶
type ChannelQueue struct {
// contains filtered or unexported fields
}
func NewChannelQueue ¶
func NewChannelQueue(buffer int) *ChannelQueue
func (*ChannelQueue) Channel ¶
func (q *ChannelQueue) Channel() chan Task
func (*ChannelQueue) Close ¶
func (q *ChannelQueue) Close() error
func (*ChannelQueue) Submit ¶
func (q *ChannelQueue) Submit(task Task) error
type Task ¶
type Task interface { Enqueue() error Start(worker string) error Stop() error Kill(force bool) error Killed() bool Close() error Write(input io.Reader) (int64, error) Execute() error Error(err error) error Wait() }
Task ...
Click to show internal directories.
Click to hide internal directories.