cluster

Documentation

Index

• func NewClusterDispatcher(dispatch dispatch.Dispatcher, options ...Option) (dispatch.Dispatcher, error)
• type Option
  • func Cache(c cache.Cache) Option
  • func ConcurrencyLimit(limit uint16) Option
  • func PrometheusSubsystem(name string) Option

Functions

func NewClusterDispatcher

func NewClusterDispatcher(dispatch dispatch.Dispatcher, 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 Cache

func Cache(c cache.Cache) Option

Cache sets the cache for the remote dispatcher.

func ConcurrencyLimit

func ConcurrencyLimit(limit uint16) Option

ConcurrencyLimit sets the max number of goroutines per operation

func PrometheusSubsystem

func PrometheusSubsystem(name string) Option

PrometheusSubsystem sets the subsystem name for the prometheus metrics