scheduler

Mar 9, 2022

Changes in this version

type Pool

+ PKCS11Timeout time.Duration

type Worker

+ PKCS11Timeout time.Duration

Nov 9, 2021

Changes in this version

+ func CollectRequest(ctx context.Context, requestChan <-chan Request, p *Pool)

+ type Counter uint32

+ func (c *Counter) Get() uint32

+ func (c *Counter) Inc() uint32

+ func (c *Counter) Reset() uint32

+ type DoWorker interface

+ DoWork func(ctx context.Context, worker *Worker)

+ type Pool struct

+ FeatureEnabled bool

+ Name string

+ PoolSize int

+ type Request struct

+ Priority proto.Priority

+ type Worker struct

+ ID int

+ Priority proto.Priority

+ Quit chan struct{}

+ TotalProcessed Counter

+ TotalTimeout Counter

+ func (w *Worker) String() string