queue

Documentation

Index

• Variables
• type IntQueue
  • func NewIntQueue(capacity int) *IntQueue
  • func (q *IntQueue) Head() (int64, error)
  • func (q *IntQueue) Pop() (int64, error)
  • func (q *IntQueue) Push(val int64)
  • func (q *IntQueue) Size() int
• type TimeQueue
  • func NewTimeQueue(capacity int) *TimeQueue
  • func (q *TimeQueue) Head() (time.Time, error)
  • func (q *TimeQueue) Pop() (time.Time, error)
  • func (q *TimeQueue) Push(val time.Time)
  • func (q *TimeQueue) Size() int

Variables

var (
	ErrEmptyQueue = errors.New("Queue is empty")
)

var (
	ZeroTime = time.Unix(0, 0)
)

Types

type IntQueue

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

func NewIntQueue

func NewIntQueue(capacity int) *IntQueue

func (*IntQueue) Head

func (q *IntQueue) Head() (int64, error)

func (*IntQueue) Pop

func (q *IntQueue) Pop() (int64, error)

func (*IntQueue) Push

func (q *IntQueue) Push(val int64)

func (*IntQueue) Size

func (q *IntQueue) Size() int

type TimeQueue

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

func NewTimeQueue

func NewTimeQueue(capacity int) *TimeQueue

func (*TimeQueue) Head

func (q *TimeQueue) Head() (time.Time, error)

func (*TimeQueue) Pop

func (q *TimeQueue) Pop() (time.Time, error)

func (*TimeQueue) Push

func (q *TimeQueue) Push(val time.Time)

func (*TimeQueue) Size

func (q *TimeQueue) Size() int