Versions in this module Expand all Collapse all v1 v1.0.0 Jul 3, 2025 Changes in this version + const EventEgressEnded + const EventEgressStarted + const EventEgressUpdated + const EventIngressEnded + const EventIngressStarted + const EventParticipantJoined + const EventParticipantLeft + const EventRoomFinished + const EventRoomStarted + const EventTrackPublished + const EventTrackUnpublished + var DefaultResourceURLNotifierConfig = ResourceURLNotifierConfig + var DefaultURLNotifierConfig = URLNotifierConfig + var DefaultWebHookConfig = WebHookConfig + var ErrInvalidChecksum = errors.New("could not verify authenticity of message") + var ErrNoAuthHeader = errors.New("authorization header could not be found") + var ErrSecretNotFound = errors.New("API secret could not be found") + func IncDispatchDrop(reason string) + func IncDispatchFailure() + func IncDispatchSuccess() + func InitWebhookStats(constLabels prometheus.Labels) + func Receive(r *http.Request, provider auth.KeyProvider) ([]byte, error) + func ReceiveWebhookEvent(r *http.Request, provider auth.KeyProvider) (*livekit.WebhookEvent, error) + func RecordQueueLength(queueLength int) + type DefaultNotifier struct + func (n *DefaultNotifier) QueueNotify(ctx context.Context, event *livekit.WebhookEvent, opts ...NotifyOption) error + func (n *DefaultNotifier) RegisterProcessedHook(hook func(ctx context.Context, whi *livekit.WebhookInfo)) + func (n *DefaultNotifier) SetFilter(params FilterParams) + func (n *DefaultNotifier) SetKeys(apiKey, apiSecret string) + func (n *DefaultNotifier) Stop(force bool) + type FilterParams struct + ExcludeEvents []string + IncludeEvents []string + type HTTPClientParams struct + ClientTimeout time.Duration + MaxRetries int + RetryWaitMax time.Duration + RetryWaitMin time.Duration + type NotifyOption func(*NotifyParams) + func WithExtraWebhooks(wh []*livekit.WebhookConfig) NotifyOption + func WithSecret(secret string) NotifyOption + type NotifyParams struct + ExtraWebhooks []*livekit.WebhookConfig + Secret string + type QueuedNotifier interface + QueueNotify func(ctx context.Context, event *livekit.WebhookEvent, opts ...NotifyOption) error + RegisterProcessedHook func(f func(ctx context.Context, whi *livekit.WebhookInfo)) + SetFilter func(params FilterParams) + SetKeys func(apiKey, apiSecret string) + Stop func(force bool) + func NewDefaultNotifier(config WebHookConfig, kp auth.KeyProvider) (QueuedNotifier, error) + type ResourceURLNotifier struct + func NewResourceURLNotifier(params ResourceURLNotifierParams) *ResourceURLNotifier + func (r *ResourceURLNotifier) Process(ctx context.Context, queuedAt time.Time, event *livekit.WebhookEvent, ...) + func (r *ResourceURLNotifier) QueueNotify(ctx context.Context, event *livekit.WebhookEvent, opts ...NotifyOption) error + func (r *ResourceURLNotifier) RegisterProcessedHook(hook func(ctx context.Context, whi *livekit.WebhookInfo)) + func (r *ResourceURLNotifier) SetFilter(params FilterParams) + func (r *ResourceURLNotifier) SetKeys(apiKey, apiSecret string) + func (r *ResourceURLNotifier) Stop(force bool) + type ResourceURLNotifierConfig struct + MaxAge time.Duration + MaxDepth int + type ResourceURLNotifierParams struct + APIKey string + APISecret string + Config ResourceURLNotifierConfig + FieldsHook func(whi *livekit.WebhookInfo) + Logger logger.Logger + Timeout time.Duration + URL string + type URLNotifier struct + func NewURLNotifier(params URLNotifierParams) *URLNotifier + func (n *URLNotifier) QueueNotify(ctx context.Context, event *livekit.WebhookEvent, opts ...NotifyOption) error + func (n *URLNotifier) RegisterProcessedHook(hook func(ctx context.Context, whi *livekit.WebhookInfo)) + func (n *URLNotifier) SetFilter(params FilterParams) + func (n *URLNotifier) SetKeys(apiKey, apiSecret string) + func (n *URLNotifier) Stop(force bool) + type URLNotifierConfig struct + NumWorkers int + QueueSize int + type URLNotifierParams struct + APIKey string + APISecret string + Config URLNotifierConfig + FieldsHook func(whi *livekit.WebhookInfo) + Logger logger.Logger + URL string + type WebHookConfig struct + APIKey string + ResourceURLNotifier ResourceURLNotifierConfig + URLNotifier URLNotifierConfig + URLs []string
Go to main page