queue

Documentation

Index

• type Queue
  • func New(capacity uint) *Queue
  • func (q *Queue) Build() (*Queue, error)
  • func (q *Queue) Close() error
  • func (q *Queue) Get() (event.Event, error)
  • func (q *Queue) Publish(e event.Event) error
  • func (q *Queue) WithNumOfWorker(n uint) *Queue
  • func (q *Queue) WithSubscriber(s qport.Subscriber) *Queue

Types

type Queue

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

func New

func New(capacity uint) *Queue

func (*Queue) Build

func (q *Queue) Build() (*Queue, error)

func (*Queue) Close

func (q *Queue) Close() error

func (*Queue) Get

func (q *Queue) Get() (event.Event, error)

func (*Queue) Publish

func (q *Queue) Publish(e event.Event) error

func (*Queue) WithNumOfWorker

func (q *Queue) WithNumOfWorker(n uint) *Queue

func (*Queue) WithSubscriber

func (q *Queue) WithSubscriber(s qport.Subscriber) *Queue