exqueue

package

v0.2.1 Latest Latest Go to latest Published: Jan 14, 2021 License: MIT Imports: 4 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type ExQueue struct {
	Threads int
	// contains filtered or unexported fields
}

func New(conf *viper.Viper) (*ExQueue, error)

New creates a new queue

func (l ExQueue) Add(r exRequest) error

Add add request to exList

func (q *ExQueue) AddRequest(r exRequest) error

AddRequest adds a new Request to the queue

func (l ExQueue) Get() exRequest

Get get request from exList

func (q *ExQueue) OnStart(ctx context.Context) (err error)

OnStart TODO

func (q *ExQueue) OnStop(ctx context.Context) (err error)

OnStop TODO

func (l ExQueue) Size() (int, error)

Size get the size of exList