Versions in this module Expand all Collapse all v0 v0.2.1 Jan 14, 2021 v0.2.0 Nov 13, 2020 Changes in this version + type ExQueue struct + Threads int + func New(conf *viper.Viper) (*ExQueue, error) + func (l ExQueue) Add(r exRequest) error + func (l ExQueue) Get() exRequest + func (l ExQueue) Size() (int, error) + func (q *ExQueue) AddRequest(r exRequest) error + func (q *ExQueue) OnStart(ctx context.Context) (err error) + func (q *ExQueue) OnStop(ctx context.Context) (err error)
Go to main page