Documentation ¶
Index ¶
- type Dispatcher
- func (cd *Dispatcher) Close() error
- func (cd *Dispatcher) DispatchCheck(ctx context.Context, req *v1.DispatchCheckRequest) (*v1.DispatchCheckResponse, error)
- func (cd *Dispatcher) DispatchExpand(ctx context.Context, req *v1.DispatchExpandRequest) (*v1.DispatchExpandResponse, error)
- func (cd *Dispatcher) DispatchLookup(ctx context.Context, req *v1.DispatchLookupRequest) (*v1.DispatchLookupResponse, error)
- func (cd *Dispatcher) DispatchLookupSubjects(req *v1.DispatchLookupSubjectsRequest, stream dispatch.LookupSubjectsStream) error
- func (cd *Dispatcher) DispatchReachableResources(req *v1.DispatchReachableResourcesRequest, ...) error
- func (cd *Dispatcher) IsReady() bool
- func (cd *Dispatcher) SetDelegate(delegate dispatch.Dispatcher)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatcher ¶ added in v1.4.0
type Dispatcher struct {
// contains filtered or unexported fields
}
Dispatcher is a dispatcher with cacheInst-in caching.
func NewCachingDispatcher ¶
func NewCachingDispatcher( cacheConfig *cache.Config, prometheusSubsystem string, keyHandler keys.Handler, ) (*Dispatcher, error)
NewCachingDispatcher creates a new dispatch.Dispatcher which delegates dispatch requests and caches the responses when possible and desirable.
func (*Dispatcher) Close ¶ added in v1.4.0
func (cd *Dispatcher) Close() error
func (*Dispatcher) DispatchCheck ¶ added in v1.4.0
func (cd *Dispatcher) DispatchCheck(ctx context.Context, req *v1.DispatchCheckRequest) (*v1.DispatchCheckResponse, error)
DispatchCheck implements dispatch.Check interface
func (*Dispatcher) DispatchExpand ¶ added in v1.4.0
func (cd *Dispatcher) DispatchExpand(ctx context.Context, req *v1.DispatchExpandRequest) (*v1.DispatchExpandResponse, error)
DispatchExpand implements dispatch.Expand interface and does not do any caching yet.
func (*Dispatcher) DispatchLookup ¶ added in v1.4.0
func (cd *Dispatcher) DispatchLookup(ctx context.Context, req *v1.DispatchLookupRequest) (*v1.DispatchLookupResponse, error)
DispatchLookup implements dispatch.Lookup interface and does not do any caching yet.
func (*Dispatcher) DispatchLookupSubjects ¶ added in v1.12.0
func (cd *Dispatcher) DispatchLookupSubjects(req *v1.DispatchLookupSubjectsRequest, stream dispatch.LookupSubjectsStream) error
DispatchLookupSubjects implements dispatch.LookupSubjects interface and does not do any caching yet.
func (*Dispatcher) DispatchReachableResources ¶ added in v1.8.0
func (cd *Dispatcher) DispatchReachableResources(req *v1.DispatchReachableResourcesRequest, stream dispatch.ReachableResourcesStream) error
DispatchReachableResources implements dispatch.ReachableResources interface and does not do any caching yet.
func (*Dispatcher) IsReady ¶ added in v1.9.0
func (cd *Dispatcher) IsReady() bool
func (*Dispatcher) SetDelegate ¶ added in v1.4.0
func (cd *Dispatcher) SetDelegate(delegate dispatch.Dispatcher)
SetDelegate sets the internal delegate to the specific dispatcher instance.