queueutil

Documentation

Index

• func Tokenise(str string) string
• type QueueManager
  • func NewQueueManager(service *frame.Service) QueueManager
• type WorkPoolManager
  • func NewWorkManager[T any](service *frame.Service) WorkPoolManager[T]

Functions

func Tokenise

func Tokenise(str string) string

Types

type QueueManager

type QueueManager interface {
	RegisterPublisher(ctx context.Context, opts *config.QueueOptions) error
	GetPublisher(ref string) (frame.Publisher, error)
	GetOrCreatePublisher(ctx context.Context, opts *config.QueueOptions) (frame.Publisher, error)
	DiscardPublisher(ctx context.Context, ref string) error

	Publish(ctx context.Context, reference string, payload any, headers ...map[string]string) error

	RegisterSubscriber(ctx context.Context, opts *config.QueueOptions, handler ...frame.SubscribeWorker) error
	GetSubscriber(ref string) (frame.Subscriber, error)
	GetOrCreateSubscriber(ctx context.Context, opts *config.QueueOptions) (frame.Subscriber, error)
	DiscardSubscriber(ctx context.Context, ref string) error
}

func NewQueueManager

func NewQueueManager(service *frame.Service) QueueManager

NewQueueManager ensures a default internal Queue exists

type WorkPoolManager

type WorkPoolManager[T any] interface {
	Submit(ctx context.Context, job frame.Job[T])
}

func NewWorkManager

func NewWorkManager[T any](service *frame.Service) WorkPoolManager[T]

NewWorkManager creates a new internal Queue worker