swappable

Documentation

Overview

Package swappable provides an http.Handler that delegates all HTTP requests to an underlying multichannelfanout.Handler. When a new configuration is available, a new multichannelfanout.Handler is created and swapped in. All subsequent requests go to the new handler. It is often used in conjunction with something that notices changes to ConfigMaps, such as configmap.watcher or configmap.filesystem.

Index

• type Handler
  • func NewEmptyHandler(logger *zap.Logger) (*Handler, error)
  • func NewHandler(handler *multichannelfanout.Handler, logger *zap.Logger) *Handler
  • func (h *Handler) ServeHTTP(ctx context.Context, event cloudevents.Event, resp *cloudevents.EventResponse) error
  • func (h *Handler) UpdateConfig(config *multichannelfanout.Config) error
• type UpdateConfig

Types

type Handler

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

Handler is an http.Handler that atomically swaps between underlying handlers.

func NewEmptyHandler

func NewEmptyHandler(logger *zap.Logger) (*Handler, error)

NewEmptyHandler creates a new swappable.Handler with an empty configuration.

func NewHandler

func NewHandler(handler *multichannelfanout.Handler, logger *zap.Logger) *Handler

NewHandler creates a new swappable.Handler.

func (*Handler) ServeHTTP

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

ServeHTTP delegates all HTTP requests to the current multichannelfanout.Handler.

func (*Handler) UpdateConfig

func (h *Handler) UpdateConfig(config *multichannelfanout.Config) error

UpdateConfig copies the current inner multichannelfanout.Handler with the new configuration. If the new configuration is valid, then the new inner handler is swapped in and will start serving HTTP traffic.

type UpdateConfig

type UpdateConfig func(config *multichannelfanout.Config) error

UpdateConfig updates the configuration to use the new config, returning an error if it can't.