workers

type Execute func(v interface{}, meta map[string]string)

type Option struct {
	MaxWorkerNum      int
	MaxIdleTime       time.Duration
	CommandTimeout    time.Duration
	CommandBufferSize int
	Fn                Execute
}

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

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