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.MessageHandler, which contains multiple fanout.MessageHandler, each corresponding to a single Knative Channel.

Index

• type Config
• type MessageHandler
  • func NewMessageHandler(logger *zap.Logger, messageDispatcher channel.MessageDispatcher, config Config) (*MessageHandler, error)
  • func (f *MessageHandler) ServeHTTP(response nethttp.ResponseWriter, request *nethttp.Request)
• type Subscription
  • func SubscriberSpecToFanoutConfig(sub eventingduckv1.SubscriberSpec) (*Subscription, error)

Types

type Config

type Config struct {
	Subscriptions []Subscription `json:"subscriptions"`
	// AsyncHandler controls whether the Subscriptions are called synchronous or asynchronously.
	// It is expected to be false when used as a sidecar.
	AsyncHandler bool `json:"asyncHandler,omitempty"`
}

Config for a fanout.MessageHandler.

type MessageHandler

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

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

func NewMessageHandler

func NewMessageHandler(logger *zap.Logger, messageDispatcher channel.MessageDispatcher, config Config) (*MessageHandler, error)

NewMessageHandler creates a new fanout.MessageHandler.

func (*MessageHandler) ServeHTTP

func (f *MessageHandler) ServeHTTP(response nethttp.ResponseWriter, request *nethttp.Request)

type Subscription

type Subscription struct {
	Subscriber  *url.URL
	Reply       *url.URL
	DeadLetter  *url.URL
	RetryConfig *kncloudevents.RetryConfig
}

func SubscriberSpecToFanoutConfig

func SubscriberSpecToFanoutConfig(sub eventingduckv1.SubscriberSpec) (*Subscription, error)