queue

Documentation

Overview

Package queue is in charge of creating and handling a queue that receives data and sends it in bulk whenever it is possible, i.e. when the component that will receive it is ready to process it.

Index

• type Queue
  • func New(ctx context.Context, servsHandler services.Handler) Queue

Types

type Queue

type Queue interface {
	// Enqueue intructs the queue that a new data must be sent on next request
	Enqueue(events map[string]*openapi.Event)
}

Queue contains data that will be sent to a handler

func New

func New(ctx context.Context, servsHandler services.Handler) Queue

New returns a Queue that receives data and sends it in bulk whenever possible