Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Notifier ¶
type Notifier struct {
// contains filtered or unexported fields
}
func NewNotifier ¶ added in v1.1.0
func NewNotifier(ctx context.Context, workerCount int, maxRetry int, logger *logrus.Entry) *Notifier
NewNotifier creates a new Notifier with a specified worker count and max retry attempts.
func (*Notifier) AddInNotifyQueue ¶
func (n *Notifier) AddInNotifyQueue(event *plugnmeet.CommonNotifyEvent, apiKey, apiSecret string, urls []string)
func (*Notifier) Kill ¶ added in v1.1.0
func (n *Notifier) Kill()
Kill stops the worker immediately, dropping any unprocessed items in the queue.
func (*Notifier) StopGracefully ¶ added in v1.1.0
func (n *Notifier) StopGracefully()
StopGracefully waits for all queued items to be processed before stopping.
Click to show internal directories.
Click to hide internal directories.