Package net contains the Activator components that govern Activator's request throttling, routing, and reflect the cluster network state.
Index ¶ Constants ¶This section is empty.
Variables ¶This section is empty.
Functions ¶This section is empty.
Types ¶ type Throttler ¶ added in v0.9.0type 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 ¶ added in v0.9.0func NewThrottler(ctx context.Context, ipAddr string) *Throttler
NewThrottler creates a new Throttler
func (*Throttler) Run ¶ added in v0.9.0func (t *Throttler) Run(ctx context.Context)
Run starts the throttler and blocks until the context is done.
func (*Throttler) Try ¶ added in v0.9.0func (t *Throttler) Try(ctx context.Context, function func(string) error) error
Try waits for capacity and then executes function, passing in a l4 dest to send a request
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4