ringbuffer

Documentation

Index

• type Consumer
  • func NewConsumer(size int) *Consumer
  • func (s *Consumer) Queue(task core.QueuedMessage) error
  • func (s *Consumer) Request() (core.QueuedMessage, error)
  • func (s *Consumer) Run(ctx context.Context, task core.QueuedMessage) error
  • func (s *Consumer) Shutdown() error

Types

type Consumer

type Consumer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Consumer for simple queue using buffer channel

func NewConsumer

func NewConsumer(size int) *Consumer

NewConsumer for create new Consumer instance

func (*Consumer) Queue

func (s *Consumer) Queue(task core.QueuedMessage) error

Queue send task to the buffer channel

func (*Consumer) Request

func (s *Consumer) Request() (core.QueuedMessage, error)

Request a new task from channel

func (*Consumer) Run

func (s *Consumer) Run(ctx context.Context, task core.QueuedMessage) error

Run to execute new task

func (*Consumer) Shutdown

func (s *Consumer) Shutdown() error

Shutdown the worker