Documentation ¶
Index ¶
- func DoJob(pool WorkerPool, job Job) error
- func DoJobUpdated(pool WorkerPool, job Job) error
- type Job
- type Layer1Config
- type Layer1Object
- type Layer2Config
- type Layer2Object
- type Loader
- type Logger
- type PeopleFilterConfig
- type Person
- type PersonLoader
- type PersonLoaderConfig
- type Worker
- type WorkerPool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DoJob ¶
func DoJob(pool WorkerPool, job Job) error
func DoJobUpdated ¶
func DoJobUpdated(pool WorkerPool, job Job) error
Types ¶
type Layer1Config ¶
type Layer1Config interface {
Logger() Logger
}
Configuration for the Layer 1 Object
type Layer1Object ¶
type Layer1Object struct { MyConfig Layer1Config MyDependency *Layer2Object }
Layer 1 Object
func NewLayer1Object ¶
func NewLayer1Object(config Layer1Config) *Layer1Object
type Layer2Config ¶
type Layer2Config interface {
Logger() Logger
}
Configuration for the Layer 2 Object
type Layer2Object ¶
type Layer2Object struct {
MyConfig Layer2Config
}
Layer 2 Object
func NewLayer2Object ¶
func NewLayer2Object(config Layer2Config) *Layer2Object
type PeopleFilterConfig ¶
type PeopleFilterConfig interface {
DSN() string
}
type Person ¶
type Person struct {
Name string
}
Some data
func PeopleFilter ¶
func PeopleFilter(cfg PeopleFilterConfig, filter string) ([]Person, error)
type PersonLoader ¶
type PersonLoader struct{}
func (*PersonLoader) LoadAll ¶
func (p *PersonLoader) LoadAll(cfg PersonLoaderConfig) ([]Person, error)
type PersonLoaderConfig ¶
type PersonLoaderConfig interface {
DSN() string
}
type WorkerPool ¶
type WorkerPool interface { GetWorker() Worker IsReady() chan struct{} }
Pool of workers
Click to show internal directories.
Click to hide internal directories.