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.

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, error)
  • func (f *Handler) ServeHTTP(ctx context.Context, event cloudevents.Event, resp *cloudevents.EventResponse) error
• type MessageHandler
  • func NewMessageHandler(logger *zap.Logger, config Config) (*MessageHandler, error)
  • func (f *MessageHandler) ServeHTTP(response nethttp.ResponseWriter, request *nethttp.Request)

Types

type Config

type Config struct {
	Subscriptions []eventingduck.SubscriberSpec `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"`
	DispatcherConfig channel.EventDispatcherConfig
}

Config for a fanout.Handler.

type Handler

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

Handler is a 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, error)

NewHandler creates a new fanout.Handler.

func (*Handler) ServeHTTP

func (f *Handler) ServeHTTP(ctx context.Context, event cloudevents.Event, resp *cloudevents.EventResponse) error

type MessageHandler

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

Handler 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, config Config) (*MessageHandler, error)

NewHandler creates a new fanout.Handler.

func (*MessageHandler) ServeHTTP

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