cluster

Documentation

Index

• func NewClusterDispatcher(dispatch dispatch.Dispatcher, nsm namespace.Manager, options ...Option) (dispatch.Dispatcher, error)
• type Option
  • func CacheConfig(config *ristretto.Config) Option
  • func PrometheusSubsystem(name string) Option

Functions

func NewClusterDispatcher

func NewClusterDispatcher(dispatch dispatch.Dispatcher, nsm namespace.Manager, options ...Option) (dispatch.Dispatcher, error)

NewClusterDispatcher takes a dispatcher (such as one created by combined.NewDispatcher) and returns a cluster dispatcher suitable for use as the dispatcher for the dispatch grpc server.

Types

type Option

type Option func(*optionState)

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

func CacheConfig

func CacheConfig(config *ristretto.Config) Option

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

func PrometheusSubsystem

func PrometheusSubsystem(name string) Option

PrometheusSubsystem sets the subsystem name for the prometheus metrics