delay

Documentation

Overview

Package delay for delay queue Created by chenguolin 2019-07-10

Index

• type Queue
  • func NewQueue(capacity int64) *Queue
  • func (q *Queue) Close()
  • func (q *Queue) IsClosed() bool
  • func (q *Queue) Items() <-chan interface{}
  • func (q *Queue) Length() int
  • func (q *Queue) Push(item interface{}, delayTime time.Duration)

Types

type Queue

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

Queue delay queue

func NewQueue

func NewQueue(capacity int64) *Queue

NewQueue new queue

func (*Queue) Close

func (q *Queue) Close()

Close delay queue

func (*Queue) IsClosed

func (q *Queue) IsClosed() bool

IsClosed check queue is close

func (*Queue) Items

func (q *Queue) Items() <-chan interface{}

Items get queue

func (*Queue) Length

func (q *Queue) Length() int

Length return queue item size

func (*Queue) Push

func (q *Queue) Push(item interface{}, delayTime time.Duration)

Push item 2 queue