caching

Documentation

Index

• type Dispatcher
  • func NewCachingDispatcher(cacheConfig *ristretto.Config, nsm namespace.Manager, ...) (*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) DispatchLookup(ctx context.Context, req *v1.DispatchLookupRequest) (*v1.DispatchLookupResponse, error)
  • func (cd *Dispatcher) SetDelegate(delegate dispatch.Dispatcher)

Types

type Dispatcher

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

Dispatcher is a dispatcher with built-in caching.

func NewCachingDispatcher

func NewCachingDispatcher(
	cacheConfig *ristretto.Config,
	nsm namespace.Manager,
	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) DispatchLookup

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

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

SetDelegate sets the internal delegate to the specific dispatcher instance.