queue

Documentation

Index

• func NewQueue(config *Config) chan Job
• type Config
• type Job

Functions

func NewQueue

func NewQueue(config *Config) chan Job

Types

type Config

type Config struct {
	Concurrency int
	QueueSize   int
}

type Job

type Job struct {
	JobId string
}