sink

Documentation

Overview

Package sink provides an interface for processing HTTP requests.

Index

• type HealthStatusRegistry
• type Sink
  • func NewHTTPClientSink(client *http.Client) Sink
  • func NewHealthCheckSink(sink Sink, registry HealthStatusRegistry, unhealthyAttemptsThreshold int, ...) Sink
  • func NewPooledSink(ctx context.Context, c workerpool.Component, sink Sink, workers int, ...) Sink

Types

type HealthStatusRegistry

type HealthStatusRegistry interface {
	Get(context.Context) (*ttnpb.ApplicationWebhookHealth, error)
	Set(context.Context, func(*ttnpb.ApplicationWebhookHealth) (*ttnpb.ApplicationWebhookHealth, error)) error
}

HealthStatusRegistry is a registry for webhook health status.

type Sink

type Sink interface {
	Process(*http.Request) error
}

Sink processes HTTP requests.

func NewHTTPClientSink

func NewHTTPClientSink(client *http.Client) Sink

NewHTTPClientSink returns a new HTTP client sink.

func NewHealthCheckSink

func NewHealthCheckSink(
	sink Sink, registry HealthStatusRegistry, unhealthyAttemptsThreshold int, unhealthyRetryInterval time.Duration,
) Sink

NewHealthCheckSink creates a Sink that records the health status of the webhooks and stops them from executing if too many fail in a specified interval of time.

func NewPooledSink

func NewPooledSink(ctx context.Context, c workerpool.Component, sink Sink, workers int, queueSize int) Sink

NewPooledSink creates a Sink that queues requests and processes them in parallel workers.