ingress

Documentation

Index

• Variables
• type Handler
  • func (h *Handler) Start(stopCh <-chan struct{}) error

Variables

var (
	// MeasureEventsTotal is a counter which records the number of events received
	// by the ingress. The value of the Result tag indicates whether the event
	// was filtered or dispatched by the ingress.
	MeasureEventsTotal = stats.Int64(
		"knative.dev/eventing/broker/measures/events_total",
		"Total number of events received",
		stats.UnitNone,
	)

	// MeasureDispatchTime records the time spent dispatching an event, in
	// milliseconds.
	MeasureDispatchTime = stats.Int64(
		"knative.dev/eventing/broker/measures/dispatch_time",
		"Time spent dispatching an event",
		stats.UnitMilliseconds,
	)

	// TagResult is a tag key referring to the observed result of an operation.
	TagResult = mustNewTagKey("result")

	// TagBroker is a tag key referring to the Broker name serviced by this
	// ingress process.
	TagBroker = mustNewTagKey("broker")
)

Types

type Handler

type Handler struct {
	Logger     *zap.Logger
	CeClient   cloudevents.Client
	ChannelURI *url.URL
	BrokerName string
}

func (*Handler) Start

func (h *Handler) Start(stopCh <-chan struct{}) error