queueutil

Documentation

Index

• func Tokenise(str string) string
• type QueueManager
  • func NewQueueManager(service *frame.Service) QueueManager
• type WorkPookManager

Functions

func Tokenise

func Tokenise(str string) string

Types

type QueueManager

type QueueManager interface {
	WorkPookManager

	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 WorkPookManager

type WorkPookManager interface {
	Submit(ctx context.Context, job frame.Job)
}