queue

Documentation

Index

• type Queue
  • func NewQueue(max int) *Queue
  • func (queue *Queue) AckPeeked(ctx context.Context) error
  • func (queue *Queue) CloseWithContext(ctx context.Context) error
  • func (queue *Queue) LastPeeked() interface{}
  • func (queue *Queue) Peek(ctx context.Context) (interface{}, error)
  • func (queue *Queue) Push(ctx context.Context, data interface{}) error
  • func (queue *Queue) ResetPeeked()
  • func (queue *Queue) WaitOk(ctx context.Context) error

Types

type Queue

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

func NewQueue

func NewQueue(max int) *Queue

func (*Queue) AckPeeked

func (queue *Queue) AckPeeked(ctx context.Context) error

func (*Queue) CloseWithContext

func (queue *Queue) CloseWithContext(ctx context.Context) error

func (*Queue) LastPeeked

func (queue *Queue) LastPeeked() interface{}

func (*Queue) Peek

func (queue *Queue) Peek(ctx context.Context) (interface{}, error)

func (*Queue) Push

func (queue *Queue) Push(ctx context.Context, data interface{}) error

func (*Queue) ResetPeeked

func (queue *Queue) ResetPeeked()

func (*Queue) WaitOk

func (queue *Queue) WaitOk(ctx context.Context) error