Payload Queue

This library helps you queue data/structs for future work based on queue size or age in the queue.

It is designed to be lightweight, efficient and easy to use.

Free feel to make any suggestions for improvements/optimizations.

Simple usage:

A complete producer example is in the examples folder. Below is a sample usage:

import (
	plq "github.com/sam-ish/payloadqueue"
)

func main() {
	q := plq.Queue{
		Tag:       "QueueName",
		Work:      Datahandler, // your handler for the queued data
		MaxSize:   150,
		MaxAge:    3,
	}
	q.Start() // start queuing
  // Create and append the data-struct to the queue
  qb.Append(qb.NewPayload(struct{
				Name string
			}{
				Name: "DataB",
			})

   // Call the close on exit
   q.Close()
}

// Datahandler to act on the queued data
func Datahandler(data []interface{}) int {
	// ..do meaningful work on the data
	return 0 // zero is success
}