activator

Documentation

Index

• Constants
• func ReportStats(logger *zap.SugaredLogger, sink RawSender, source <-chan []metrics.StatMessage)
• type RawSender

Constants

const (
	// Name is the name of the component.
	Name = "activator"
	// RevisionHeaderName is the header key for revision name.
	RevisionHeaderName = "Knative-Serving-Revision"
	// RevisionHeaderNamespace is the header key for revision's namespace.
	RevisionHeaderNamespace = "Knative-Serving-Namespace"
)

Functions

func ReportStats

func ReportStats(logger *zap.SugaredLogger, sink RawSender, source <-chan []metrics.StatMessage)

ReportStats sends any messages received on the source channel to the sink. The messages are sent on a goroutine to avoid blocking, which means that messages may arrive out of order.

Types

type RawSender

type RawSender interface {
	SendRaw(msgType int, msg []byte) error
}

RawSender sends raw byte array messages with a message type (implemented by gorilla/websocket.Socket).