multiqueue

Documentation

Index

• Variables
• type HandleFunc
• type MultiQueue
  • func New[T Sizeable](h HandleFunc[T], updater sizeUpdater, msgType int, maxThreadSize int) MultiQueue[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 Sizeable

type Sizeable interface {
	MsgSize() uint64
}