Documentation
¶
Index ¶
- func NewClusterDispatcher(dispatch dispatch.Dispatcher, options ...Option) (dispatch.Dispatcher, error)
- type Option
- func Cache(c cache.Cache[keys.DispatchCacheKey, any]) Option
- func CaveatTypeSet(caveatTypeSet *caveattypes.TypeSet) Option
- func ConcurrencyLimits(limits graph.ConcurrencyLimits) Option
- func DispatchChunkSize(dispatchChunkSize uint16) Option
- func Metrics(reg dispatch.MetricsOptions) Option
- func QueryPlanMetadata(m *query.QueryPlanMetadata) Option
- func RelationshipChunkCache(cache cache.Cache[cache.StringKey, any]) Option
- func RelationshipChunkCacheConfig(config *cache.Config) Option
- func RemoteDispatchTimeout(remoteDispatchTimeout time.Duration) Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 CaveatTypeSet ¶ added in v1.43.0
func CaveatTypeSet(caveatTypeSet *caveattypes.TypeSet) Option
CaveatTypeSet sets the type set to use for caveats. If not specified, the default type set is used.
func ConcurrencyLimits ¶ added in v1.16.0
func ConcurrencyLimits(limits graph.ConcurrencyLimits) Option
ConcurrencyLimits sets the max number of goroutines per operation
func DispatchChunkSize ¶ added in v1.35.0
DispatchChunkSize sets the maximum number of items to be dispatched in a single dispatch request
func Metrics ¶ added in v1.54.0
func Metrics(reg dispatch.MetricsOptions) Option
Metrics sets the prometheus metrics
func QueryPlanMetadata ¶ added in v1.53.0
func QueryPlanMetadata(m *query.QueryPlanMetadata) Option
QueryPlanMetadata sets the shared count-stats store for the receiver-side query plan dispatcher built by NewClusterDispatcher.
func RelationshipChunkCache ¶ added in v1.46.0
RelationshipChunkCache sets the cache for LR3 relationship chunks.
func RelationshipChunkCacheConfig ¶ added in v1.46.0
RelationshipChunkCacheConfig sets the cache config for LR3 relationship chunks.
func RemoteDispatchTimeout ¶ added in v1.16.2
RemoteDispatchTimeout sets the maximum timeout for a remote dispatch. Defaults to 60s (as defined in the remote dispatcher).
Source Files