queue

Documentation

Index

• func ChangePartialConvertMultiple(items []interface{}) []data.ChangePartial
• func ChangePartialConvertSingle(item interface{}) data.ChangePartial
• func ChangePartialEnqueueMultiple(queue goqueue.Enqueuer, changePartials []data.ChangePartial) (changePartialsRemaining []data.ChangePartial, overflow bool)
• func ChangePartialFlush(queue goqueue.Dequeuer) (changePartials []data.ChangePartial)
• func ChangePartialPeek(queue goqueue.Peeker) (changePartials []data.ChangePartial)
• func New(queueSize int) interface{ ... }
• type Queue

Functions

func ChangePartialConvertMultiple

func ChangePartialConvertMultiple(items []interface{}) []data.ChangePartial

func ChangePartialConvertSingle

func ChangePartialConvertSingle(item interface{}) data.ChangePartial

func ChangePartialEnqueueMultiple

func ChangePartialEnqueueMultiple(queue goqueue.Enqueuer, changePartials []data.ChangePartial) (changePartialsRemaining []data.ChangePartial, overflow bool)

func ChangePartialFlush

func ChangePartialFlush(queue goqueue.Dequeuer) (changePartials []data.ChangePartial)

func ChangePartialPeek

func ChangePartialPeek(queue goqueue.Peeker) (changePartials []data.ChangePartial)

func New

func New(queueSize int) interface {
	goqueue.Owner
	goqueue.GarbageCollecter
	goqueue.Dequeuer
	goqueue.Enqueuer
	goqueue.EnqueueInFronter
	goqueue.Length
	goqueue.Event
	goqueue.Peeker
}

Types

type Queue

type Queue interface {
	goqueue.Owner
	goqueue.Enqueuer
	goqueue.Dequeuer
	goqueue.Peeker
	goqueue.Length
}