activator

Documentation

Index

• Constants
• Variables
• 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"
)

Variables

var (
	// RevisionHeaders are the headers the activator uses to identify the
	// revision. They are removed before reaching the user container.
	RevisionHeaders = []string{
		RevisionHeaderName,
		RevisionHeaderNamespace,
	}
)

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).