requestqueue

Documentation

Overview

Package requestqueue is implemented based on eapache's infinite channel template: https://github.com/eapache/channels/blob/master/infinite_channel.go As explained by the author in documentation: https://godoc.org/github.com/eapache/channels due to Go's type system limitations direct import of his library is impractical. This reimplementation allows more type safety due to having more strict channel type than an empty interface. On top of better, even though slightly slower, queue as now it is thread-safe which is crucial as the queue can be read by multiple workers.

Index

• type RequestQueue
  • func New() *RequestQueue
  • func (ic *RequestQueue) Close()
  • func (ic *RequestQueue) In() chan<- *commands.CommandRequest
  • func (ic *RequestQueue) Len() int64
  • func (ic *RequestQueue) Out() <-chan *commands.CommandRequest

Types

type RequestQueue

type RequestQueue struct {
	// contains filtered or unexported fields
}

RequestQueue represents a seemingly 'infinite' (depending on available memory) FIFO queue working on CommandRequest items.

func New

func New() *RequestQueue

New creates a new instance of a RequestQueue.

func (*RequestQueue) Close

func (ic *RequestQueue) Close()

Close closes the input channel, however, output and hence the goroutine will be open until the queue is exhausted.

func (*RequestQueue) In

func (ic *RequestQueue) In() chan<- *commands.CommandRequest

In returns input channel for writing CommandRequests.

func (*RequestQueue) Len

func (ic *RequestQueue) Len() int64

Len returns number of elements in the queue.

func (*RequestQueue) Out

func (ic *RequestQueue) Out() <-chan *commands.CommandRequest

Out returns output channel for reading CommandRequests.