multiqueue

Documentation

Index

• Variables
• type HandleFunc
• type MultiQueue
  • func New[T Sizeable](h HandleFunc[T], updater sizeUpdater, msgType int, maxThreadSize int) MultiQueue[T]
• type Queue
  • func NewQueue[T Sizeable](id string, size, msgType int, updater sizeUpdater, h QueueHandler[T]) *Queue[T]
  • func (q *Queue[T]) Close() error
  • func (q *Queue[T]) TryAdd(msg T) error
  • func (q *Queue[T]) WaitOne(ctx context.Context) (T, error)
• type QueueHandler
• type QueueProvider
  • func NewQueueProvider[T Sizeable](size, msgType int, updater sizeUpdater, handler QueueHandler[T]) QueueProvider[T]
• type Sizeable

Variables

var (
	ErrThreadNotExists = errors.New("multiQueue: thread not exists")
	ErrClosed          = errors.New("multiQueue: closed")
)

Types

type HandleFunc

type HandleFunc[T any] func(msg T)

type MultiQueue

type MultiQueue[T Sizeable] interface {
	Add(ctx context.Context, threadId string, msg T) (err error)
	CloseThread(threadId string) (err error)
	ThreadIds() []string
	Close() (err error)
}

func New

func New[T Sizeable](h HandleFunc[T], updater sizeUpdater, msgType int, maxThreadSize int) MultiQueue[T]

type Queue

type Queue[T Sizeable] struct {
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue[T Sizeable](id string, size, msgType int, updater sizeUpdater, h QueueHandler[T]) *Queue[T]

func (*Queue[T]) Close

func (q *Queue[T]) Close() error

func (*Queue[T]) TryAdd

func (q *Queue[T]) TryAdd(msg T) error

func (*Queue[T]) WaitOne

func (q *Queue[T]) WaitOne(ctx context.Context) (T, error)

type QueueHandler

type QueueHandler[T Sizeable] func(id string, msg T, q *mb.MB[T]) error

type QueueProvider

type QueueProvider[T Sizeable] interface {
	GetQueue(id string) *Queue[T]
	RemoveQueue(id string) error
	Close() error
}

func NewQueueProvider

func NewQueueProvider[T Sizeable](size, msgType int, updater sizeUpdater, handler QueueHandler[T]) QueueProvider[T]

type Sizeable

type Sizeable interface {
	MsgSize() uint64
}