singleflight

func (*Dispatcher) Close ¶

func (d *Dispatcher) Close() error

func (*Dispatcher) DispatchCheck ¶

func (d *Dispatcher) DispatchCheck(ctx context.Context, req *v1.DispatchCheckRequest) (*v1.DispatchCheckResponse, error)

func (*Dispatcher) DispatchExpand ¶

func (d *Dispatcher) DispatchExpand(ctx context.Context, req *v1.DispatchExpandRequest) (*v1.DispatchExpandResponse, error)

func (*Dispatcher) DispatchLookupResources2 ¶ added in v1.35.0

func (d *Dispatcher) DispatchLookupResources2(req *v1.DispatchLookupResources2Request, stream dispatch.LookupResources2Stream) error

func (*Dispatcher) DispatchLookupResources3 ¶ added in v1.45.4

func (d *Dispatcher) DispatchLookupResources3(req *v1.DispatchLookupResources3Request, stream dispatch.LookupResources3Stream) error

func (*Dispatcher) DispatchLookupSubjects ¶

func (d *Dispatcher) DispatchLookupSubjects(req *v1.DispatchLookupSubjectsRequest, stream dispatch.LookupSubjectsStream) error

func (*Dispatcher) DispatchQueryPlan ¶ added in v1.52.0

func (d *Dispatcher) DispatchQueryPlan(req *v1.DispatchQueryPlanRequest, stream dispatch.PlanStream) error

func (*Dispatcher) LookupPlanCheck ¶ added in v1.54.0

func (d *Dispatcher) LookupPlanCheck(ctx context.Context, lookup dispatch.PlanCheckLookup) (*v1.ResultPath, bool, error)

LookupPlanCheck is a passthrough — singleflight provides no cache of its own; it just deduplicates concurrent identical Plan-Check dispatches. The delegate (typically a caching.Dispatcher) is the actual cache holder.

func (*Dispatcher) ReadyState ¶

func (d *Dispatcher) ReadyState() dispatch.ReadyState