Method NewWebhooks

pkg/applicationserver/config.go:255–282

NewWebhooks returns a new web.Webhooks based on the configuration. If Target is empty, this method returns nil.

(ctx context.Context, server io.Server)

// NewWebhooks returns a new web.Webhooks based on the configuration.
// If Target is empty, this method returns nil.
func (c WebhooksConfig) NewWebhooks(ctx context.Context, server io.Server) (web.Webhooks, error) {
	var target sink.Sink
	switch c.Target {
	case "":
		return nil, nil
	case "direct":
		client, err := server.HTTPClient(ctx)
		if err != nil {
			return nil, err
		}
		client.Timeout = c.Timeout
		target = sink.NewHTTPClientSink(client)
	default:
		return nil, errWebhooksTarget.WithAttributes("target", c.Target)
	}
	if c.Registry == nil {
		return nil, errWebhooksRegistry.New()
	}
	if c.UnhealthyAttemptsThreshold > 0 || c.UnhealthyRetryInterval > 0 {
		registry := web.NewHealthStatusRegistry(c.Registry)
		registry = web.NewCachedHealthStatusRegistry(registry)
		target = sink.NewHealthCheckSink(target, registry, c.UnhealthyAttemptsThreshold, c.UnhealthyRetryInterval)
	}
	if c.QueueSize > 0 || c.Workers > 0 {
		target = sink.NewPooledSink(ctx, server, target, c.Workers, c.QueueSize)
	}
	return web.NewWebhooks(ctx, server, c.Registry, target, c.Downlinks)
}

// NewPubSub returns a new pubsub.PubSub based on the configuration.
// If the registry is nil, it returns nil.