singleflight

Documentation

Index

• func New(delegate dispatch.Dispatcher, handler keys.Handler) dispatch.Dispatcher
• type Dispatcher
  • func (d *Dispatcher) Close() error
  • func (d *Dispatcher) DispatchCheck(ctx context.Context, req *v1.DispatchCheckRequest) (*v1.DispatchCheckResponse, error)
  • func (d *Dispatcher) DispatchExpand(ctx context.Context, req *v1.DispatchExpandRequest) (*v1.DispatchExpandResponse, error)
  • func (d *Dispatcher) DispatchLookupResources(req *v1.DispatchLookupResourcesRequest, stream dispatch.LookupResourcesStream) error
  • func (d *Dispatcher) DispatchLookupResources2(req *v1.DispatchLookupResources2Request, ...) error
  • func (d *Dispatcher) DispatchLookupSubjects(req *v1.DispatchLookupSubjectsRequest, stream dispatch.LookupSubjectsStream) error
  • func (d *Dispatcher) DispatchReachableResources(req *v1.DispatchReachableResourcesRequest, ...) error
  • func (d *Dispatcher) ReadyState() dispatch.ReadyState

Functions

func New

func New(delegate dispatch.Dispatcher, handler keys.Handler) dispatch.Dispatcher

Types

type Dispatcher

type Dispatcher struct {
	// contains filtered or unexported fields
}

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) DispatchLookupResources

func (d *Dispatcher) DispatchLookupResources(req *v1.DispatchLookupResourcesRequest, stream dispatch.LookupResourcesStream) error

func (*Dispatcher) DispatchLookupResources2

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

func (*Dispatcher) DispatchLookupSubjects

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

func (*Dispatcher) DispatchReachableResources

func (d *Dispatcher) DispatchReachableResources(req *v1.DispatchReachableResourcesRequest, stream dispatch.ReachableResourcesStream) error

func (*Dispatcher) ReadyState

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