ingress

Documentation

Index

• func NewServerManager(ctx context.Context, logger *zap.Logger, cmw configmap.Watcher, ...) (*eventingtls.ServerManager, error)
• type Handler
  • func NewHandler(logger *zap.Logger, reporter StatsReporter, defaulter client.EventDefaulter, ...) (*Handler, error)
  • func (h *Handler) ServeHTTP(writer http.ResponseWriter, request *http.Request)
• type ReportArgs
• type StatsReporter
  • func NewStatsReporter(container, uniqueName string) StatsReporter

Functions

func NewServerManager

func NewServerManager(ctx context.Context, logger *zap.Logger, cmw configmap.Watcher, httpPort, httpsPort int, handler *Handler) (*eventingtls.ServerManager, error)

Types

type Handler

type Handler struct {
	// Defaults sets default values to incoming events
	Defaulter client.EventDefaulter
	// Reporter reports stats of status code and dispatch time
	Reporter StatsReporter
	// BrokerLister gets broker objects
	BrokerLister eventinglisters.BrokerLister

	EvenTypeHandler *eventtype.EventTypeAutoHandler

	Logger *zap.Logger
}

func NewHandler

func NewHandler(logger *zap.Logger, reporter StatsReporter, defaulter client.EventDefaulter, brokerInformer v1.BrokerInformer) (*Handler, error)

func (*Handler) ServeHTTP

func (h *Handler) ServeHTTP(writer http.ResponseWriter, request *http.Request)

type ReportArgs

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

type StatsReporter

type StatsReporter interface {
	ReportEventCount(args *ReportArgs, responseCode int) error
	ReportEventDispatchTime(args *ReportArgs, responseCode int, d time.Duration) error
}

StatsReporter defines the interface for sending ingress metrics.

func NewStatsReporter

func NewStatsReporter(container, uniqueName string) StatsReporter

NewStatsReporter creates a reporter that collects and reports ingress metrics.