combined

Documentation

Overview

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

Index

• func NewDispatcher(nsm namespace.Manager, ds datastore.Datastore, srv *grpc.Server, ...) (dispatch.Dispatcher, error)
• type Option
  • func GrpcDialOpts(opts ...grpc.DialOption) Option
  • func GrpcPresharedKey(key string) Option
  • func UpstreamAddr(addr string) Option
  • func UpstreamCAPath(path string) Option

Functions

func NewDispatcher

func NewDispatcher(nsm namespace.Manager, ds datastore.Datastore, srv *grpc.Server, 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 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 UpstreamAddr

func UpstreamAddr(addr string) Option

UpstreamAddr sets the optional cluster dispatching upstream address.

func UpstreamCAPath

func UpstreamCAPath(path string) Option

UpstreamAddr sets the optional cluster dispatching upstream certificate authority.