webhook

Documentation

Overview

Package webhook posts usage events as JSON to an HTTP endpoint. Delivery is asynchronous so the request path never blocks on the sink.

Index

• type Sink
  • func New(url string, timeout time.Duration) *Sink
  • func (s *Sink) OnUsage(ctx context.Context, ev hooks.UsageEvent)

Types

type Sink

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

Sink POSTs each usage event to URL.

func New

func New(url string, timeout time.Duration) *Sink

New builds a webhook sink. timeout <= 0 uses a 3s default.

func (*Sink) OnUsage

func (s *Sink) OnUsage(ctx context.Context, ev hooks.UsageEvent)

OnUsage queues a non-blocking POST. Failures are logged; they never affect the client response (the usage event was already recorded on the request path).