combined

package
v1.28.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 27, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package combined implements a dispatcher that combines caching, redispatching and optional cluster dispatching.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDispatcher

func NewDispatcher(options ...Option) (dispatch.Dispatcher, error)

NewDispatcher initializes a Dispatcher that caches and redispatches optionally to the provided upstream.

Types

type Option

type Option func(*optionState)

Option is a function-style option for configuring a combined Dispatcher.

func Cache added in v1.13.0

func Cache(c cache.Cache) Option

Cache sets the cache for the dispatcher.

func ConcurrencyLimits added in v1.16.0

func ConcurrencyLimits(limits graph.ConcurrencyLimits) Option

ConcurrencyLimits sets the max number of goroutines per operation

func GrpcDialOpts

func GrpcDialOpts(opts ...grpc.DialOption) Option

GrpcDialOpts sets the default DialOptions used for gRPC clients connecting to the optional cluster dispatching.

func GrpcPresharedKey

func GrpcPresharedKey(key string) Option

GrpcPresharedKey sets the preshared key used to authenticate for optional cluster dispatching.

func MetricsEnabled added in v1.17.0

func MetricsEnabled(enabled bool) Option

MetricsEnabled enables issuing prometheus metrics

func PrometheusSubsystem added in v1.5.0

func PrometheusSubsystem(name string) Option

PrometheusSubsystem sets the subsystem name for the prometheus metrics

func RemoteDispatchTimeout added in v1.16.2

func RemoteDispatchTimeout(remoteDispatchTimeout time.Duration) Option

RemoteDispatchTimeout sets the maximum timeout for a remote dispatch. Defaults to 60s (as defined in the remote dispatcher).

func SecondaryUpstreamAddrs added in v1.27.0

func SecondaryUpstreamAddrs(addrs map[string]string) Option

SecondaryUpstreamAddrs sets a named map of upstream addresses for secondary dispatching.

func SecondaryUpstreamExprs added in v1.27.0

func SecondaryUpstreamExprs(addrs map[string]string) Option

SecondaryUpstreamExprs sets a named map from dispatch type to the associated CEL expression to run to determine which secondary dispatch addresses (if any) to use for that incoming request.

func UpstreamAddr

func UpstreamAddr(addr string) Option

UpstreamAddr sets the optional cluster dispatching upstream address.

func UpstreamCAPath

func UpstreamCAPath(path string) Option

UpstreamCAPath sets the optional cluster dispatching upstream certificate authority.

Jump to

Keyboard shortcuts

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