The highest tagged major version is v2.

webhook

package

v1.1.0 Latest Latest Go to latest Published: Dec 19, 2025 License: MIT Imports: 18 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/mynaparrot/plugnmeet-protocol

Links

Open Source Insights

Documentation ¶

Index ¶

func VerifyRequest(body []byte, apiKey, secret, token string) (bool, error)
type Notifier
- func NewNotifier(ctx context.Context, queueSize int, logger *logrus.Logger) *Notifier
type SimpleQueueWorker
- func NewSimpleQueueWorker(ctx context.Context, queueSize int, logger *logrus.Entry) *SimpleQueueWorker

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func VerifyRequest ¶

func VerifyRequest(body []byte, apiKey, secret, token string) (bool, error)

VerifyRequest will verify webhook request both for livekit & plugNmeet in plugNmeet we're following the same token system as livekit is using in this method we'll verify the provided body request

Types ¶

type Notifier ¶

type Notifier struct {
	// contains filtered or unexported fields
}

func NewNotifier ¶ added in v1.1.0

func NewNotifier(ctx context.Context, queueSize int, logger *logrus.Logger) *Notifier

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.

type SimpleQueueWorker ¶ added in v1.1.0

type SimpleQueueWorker struct {
	// contains filtered or unexported fields
}

SimpleQueueWorker provides a basic job queue with a single worker goroutine.

func NewSimpleQueueWorker ¶ added in v1.1.0

func NewSimpleQueueWorker(ctx context.Context, queueSize int, logger *logrus.Entry) *SimpleQueueWorker

NewSimpleQueueWorker creates and starts a new queue worker.

func (*SimpleQueueWorker) Kill ¶ added in v1.1.0

func (qw *SimpleQueueWorker) Kill()

Kill stops the worker immediately, dropping any unprocessed jobs in the queue.

func (*SimpleQueueWorker) StopGracefully ¶ added in v1.1.0

func (qw *SimpleQueueWorker) StopGracefully()

StopGracefully waits for all queued jobs to be processed before stopping the worker.

func (*SimpleQueueWorker) Submit ¶ added in v1.1.0

func (qw *SimpleQueueWorker) Submit(job func())

Submit adds a job to the queue. It will drop the job if the queue is full.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL