net

Documentation

Overview

Package net contains the Activator components that govern Activator's request throttling, routing, and reflect the cluster network state.

Index

• Variables
• type Throttler
  • func NewThrottler(ctx context.Context, breakerParams queue.BreakerParams, ipAddr string) *Throttler
  • func (t *Throttler) Run(ctx context.Context)
  • func (t *Throttler) Try(ctx context.Context, revID types.NamespacedName, function func(string) error) error

Variables

var ErrActivatorOverload = errors.New("activator overload")

Types

type Throttler

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

Throttler load balances requests to revisions based on capacity. When `Run` is called it listens for updates to revision backends and decides when and when and where to forward a request.

func NewThrottler

func NewThrottler(ctx context.Context,
	breakerParams queue.BreakerParams,
	ipAddr string) *Throttler

NewThrottler creates a new Throttler

func (*Throttler) Run

func (t *Throttler) Run(ctx context.Context)

Run starts the throttler and blocks until the context is done.

func (*Throttler) Try

func (t *Throttler) Try(ctx context.Context, revID types.NamespacedName, function func(string) error) error

Try waits for capacity and then executes function, passing in a l4 dest to send a request