cluster

Documentation

Index

• func NewClusterDispatcher(dispatch dispatch.Dispatcher, options ...Option) (dispatch.Dispatcher, error)
• type Option
  • func Cache(c cache.Cache[keys.DispatchCacheKey, any]) Option
  • func ConcurrencyLimits(limits graph.ConcurrencyLimits) Option
  • func DispatchChunkSize(dispatchChunkSize uint16) Option
  • func MetricsEnabled(enabled bool) Option
  • func PrometheusSubsystem(name string) Option
  • func RemoteDispatchTimeout(remoteDispatchTimeout time.Duration) 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[keys.DispatchCacheKey, any]) Option

Cache sets the cache for the remote dispatcher.

func ConcurrencyLimits

func ConcurrencyLimits(limits graph.ConcurrencyLimits) Option

ConcurrencyLimits sets the max number of goroutines per operation

func DispatchChunkSize

func DispatchChunkSize(dispatchChunkSize uint16) Option

DispatchChunkSize sets the maximum number of items to be dispatched in a single dispatch request

func MetricsEnabled

func MetricsEnabled(enabled bool) Option

MetricsEnabled enables issuing prometheus metrics

func PrometheusSubsystem

func PrometheusSubsystem(name string) Option

PrometheusSubsystem sets the subsystem name for the prometheus metrics

func RemoteDispatchTimeout

func RemoteDispatchTimeout(remoteDispatchTimeout time.Duration) Option

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