caching

Documentation

Index

• func DispatchTestCache(t testing.TB) cache.Cache[keys.DispatchCacheKey, any]
• type Dispatcher
  • func NewCachingDispatcher(cacheInst cache.Cache[keys.DispatchCacheKey, any], metricsEnabled bool, ...) (*Dispatcher, error)
  • 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) DispatchLookupResources(req *v1.DispatchLookupResourcesRequest, stream dispatch.LookupResourcesStream) error
  • func (cd *Dispatcher) DispatchLookupResources2(req *v1.DispatchLookupResources2Request, ...) error
  • func (cd *Dispatcher) DispatchLookupSubjects(req *v1.DispatchLookupSubjectsRequest, stream dispatch.LookupSubjectsStream) error
  • func (cd *Dispatcher) DispatchReachableResources(req *v1.DispatchReachableResourcesRequest, ...) error
  • func (cd *Dispatcher) ReadyState() dispatch.ReadyState
  • func (cd *Dispatcher) SetDelegate(delegate dispatch.Dispatcher)

Functions

func DispatchTestCache

func DispatchTestCache(t testing.TB) cache.Cache[keys.DispatchCacheKey, any]

Types

type Dispatcher

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

Dispatcher is a dispatcher with cacheInst-in caching.

func NewCachingDispatcher

func NewCachingDispatcher(cacheInst cache.Cache[keys.DispatchCacheKey, any], metricsEnabled bool, 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

func (cd *Dispatcher) Close() error

func (*Dispatcher) DispatchCheck

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

DispatchCheck implements dispatch.Check interface

func (*Dispatcher) DispatchExpand

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

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

DispatchLookupResources implements dispatch.LookupResources interface.

func (*Dispatcher) DispatchLookupResources2

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

func (*Dispatcher) DispatchLookupSubjects

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

DispatchLookupSubjects implements dispatch.LookupSubjects interface.

func (*Dispatcher) DispatchReachableResources

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

DispatchReachableResources implements dispatch.ReachableResources interface.

func (*Dispatcher) ReadyState

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

func (*Dispatcher) SetDelegate

func (cd *Dispatcher) SetDelegate(delegate dispatch.Dispatcher)

SetDelegate sets the internal delegate to the specific dispatcher instance.