multiqueue

Documentation

Index

• Variables
• type HandleFunc
• type MultiQueue
  • func New[T any](h HandleFunc[T], maxThreadSize int) MultiQueue[T]

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 any] interface {
	Add(ctx context.Context, threadId string, msg T) (err error)
	CloseThread(threadId string) (err error)
	Close() (err error)
}

func New

func New[T any](h HandleFunc[T], maxThreadSize int) MultiQueue[T]