fanout

Documentation

Overview

Package fanout provides an http.Handler that takes in one request and fans it out to N other requests, based on a list of Subscriptions. Logically, it represents all the Subscriptions to a single Knative Channel. It will normally be used in conjunction with multichannelfanout.Handler, which contains multiple fanout.Handlers, each corresponding to a single Knative Channel.

Index

• type Config
• type Handler
  • func NewHandler(logger *zap.Logger, config Config) *Handler
  • func (f *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

Types

type Config

type Config struct {
	Subscriptions []eventingduck.ChannelSubscriberSpec `json:"subscriptions"`
}

Configuration for a fanout.Handler.

type Handler

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

http.Handler that takes a single request in and fans it out to N other servers.

func NewHandler

func NewHandler(logger *zap.Logger, config Config) *Handler

NewHandler creates a new fanout.Handler.

func (*Handler) ServeHTTP

func (f *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)