queue

Documentation

Index

• type Consumer
• type Message
• type Queue
  • func New() *Queue
  • func (q *Queue) Close()
  • func (q *Queue) Peak(consumerId string) (*Message, error)
  • func (q *Queue) Push(data interface{}, expire time.Duration) error
  • func (q *Queue) Register(consumerId string) *Consumer

Types

type Consumer

type Consumer struct {
	ConsumerId string
	// contains filtered or unexported fields
}

type Message

type Message struct {
	Offset int64
	Data   interface{}
	// contains filtered or unexported fields
}

type Queue

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

func New

func New() *Queue

func (*Queue) Close

func (q *Queue) Close()

func (*Queue) Peak

func (q *Queue) Peak(consumerId string) (*Message, error)

func (*Queue) Push

func (q *Queue) Push(data interface{}, expire time.Duration) error

func (*Queue) Register

func (q *Queue) Register(consumerId string) *Consumer