combined

Documentation

Overview

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

Index

• func NewDispatcher(options ...Option) (dispatch.Dispatcher, error)
• type Option
  • func CacheConfig(config *cache.Config) Option
  • func ConcurrencyLimit(limit uint16) Option
  • func GrpcDialOpts(opts ...grpc.DialOption) Option
  • func GrpcPresharedKey(key string) Option
  • func PrometheusSubsystem(name string) Option
  • func UpstreamAddr(addr string) Option
  • func UpstreamCAPath(path string) Option

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 CacheConfig

func CacheConfig(config *cache.Config) Option

CacheConfig sets the configuration for the local dispatcher's cache.

func ConcurrencyLimit

func ConcurrencyLimit(limit uint16) Option

ConcurrencyLimit 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 PrometheusSubsystem

func PrometheusSubsystem(name string) Option

PrometheusSubsystem sets the subsystem name for the prometheus metrics

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.