queue

Documentation

Overview

Package queue provides TimeBoundedQueue

the queue items are dequeued non-deterministically, but time bounds are set

Index

• type BasicTBQueue
  • func (this *BasicTBQueue) Enqueue(item_ TimeBoundedQueueItem) error
  • func (this *BasicTBQueue) GetDequeueChan() chan TimeBoundedQueueItem
• type BasicTBQueueItem
  • func NewBasicTBQueueItem(value interface{}, minDuration, maxDuration time.Duration) (*BasicTBQueueItem, error)
  • func (this *BasicTBQueueItem) EnqueuedTime() time.Time
  • func (this *BasicTBQueueItem) MaxDuration() time.Duration
  • func (this *BasicTBQueueItem) MinDuration() time.Duration
  • func (this *BasicTBQueueItem) Value() interface{}
• type TimeBoundedQueue
  • func NewBasicTBQueue() TimeBoundedQueue
• type TimeBoundedQueueItem

Types

type BasicTBQueue

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

implements TimeBoundedQueue

func (*BasicTBQueue) Enqueue

func (this *BasicTBQueue) Enqueue(item_ TimeBoundedQueueItem) error

func (*BasicTBQueue) GetDequeueChan

func (this *BasicTBQueue) GetDequeueChan() chan TimeBoundedQueueItem

type BasicTBQueueItem

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

implements TimeBoundedQueueItem

func NewBasicTBQueueItem

func NewBasicTBQueueItem(value interface{}, minDuration, maxDuration time.Duration) (*BasicTBQueueItem, error)

func (*BasicTBQueueItem) EnqueuedTime

func (this *BasicTBQueueItem) EnqueuedTime() time.Time

func (*BasicTBQueueItem) MaxDuration

func (this *BasicTBQueueItem) MaxDuration() time.Duration

func (*BasicTBQueueItem) MinDuration

func (this *BasicTBQueueItem) MinDuration() time.Duration

func (*BasicTBQueueItem) Value

func (this *BasicTBQueueItem) Value() interface{}

type TimeBoundedQueue

type TimeBoundedQueue interface {
	// enqueue
	Enqueue(TimeBoundedQueueItem) error

	// get channel for dequeue
	GetDequeueChan() chan TimeBoundedQueueItem
}

concurrent-safe, time-bounded queue.

designed for ExplorePolicies.

func NewBasicTBQueue

func NewBasicTBQueue() TimeBoundedQueue

type TimeBoundedQueueItem

type TimeBoundedQueueItem interface {
	// item value
	Value() interface{}

	// enqueued time
	EnqueuedTime() time.Time

	// min duration
	MinDuration() time.Duration

	// max duration (>= MinDuration)
	MaxDuration() time.Duration
}

item for TimeBoundedQueue