activator

package

v0.48.0 Latest Latest Go to latest Published: Jan 26, 2026 License: Apache-2.0 Imports: 9 Imported by: 31

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/knative/serving

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AutoscalerConnectionOptions(logger *zap.SugaredLogger, mp metric.MeterProvider) []pkgwebsocket.ConnectionOption
func ReportStats(logger *zap.SugaredLogger, sink RawSender, ...)
type RawSender

Constants ¶

View Source

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 ¶

View Source

var PeerAutoscaler = peerAttrKey.With("autoscaler")

PeerAutoscaler is the attribute value for autoscaler connections.

View Source

var RevisionHeaders = []string{
	RevisionHeaderName,
	RevisionHeaderNamespace,
}

RevisionHeaders are the headers the activator uses to identify the revision. They are removed before reaching the user container.

Functions ¶

func AutoscalerConnectionOptions ¶ added in v0.48.0

func AutoscalerConnectionOptions(
	logger *zap.SugaredLogger,
	mp metric.MeterProvider,
) []pkgwebsocket.ConnectionOption

AutoscalerConnectionOptions returns websocket connection options that handle connection status changes via callbacks. This enables real-time metric updates when the connection state changes, without polling.

func ReportStats ¶ added in v0.18.0

func ReportStats(logger *zap.SugaredLogger, sink RawSender, source <-chan []asmetrics.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 ¶ added in v0.18.0

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

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
certificate
config
handler
net Package net contains the Activator components that govern Activator's request throttling, routing, and reflect the cluster network state.	Package net contains the Activator components that govern Activator's request throttling, routing, and reflect the cluster network state.
testing

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL