cache

Jun 2, 2022

Changes in this version

+ type ConfigFetcher interface

+ Fetch func(context.Context, *Request) (Response, error)

+ type LinearCache struct

+ func NewLinearCache(typeURL string, opts ...LinearCacheOption) *LinearCache

+ func (cache *LinearCache) CreateWatch(request *Request) (chan Response, func())

+ func (cache *LinearCache) DeleteResource(name string) error

+ func (cache *LinearCache) Fetch(ctx context.Context, request *Request) (Response, error)

+ func (cache *LinearCache) NumWatches(name string) int

+ func (cache *LinearCache) UpdateResource(name string, res types.Resource) error

+ type LinearCacheOption func(*LinearCache)

+ func WithInitialResources(resources map[string]types.Resource) LinearCacheOption

+ func WithVersionPrefix(prefix string) LinearCacheOption

+ type MuxCache struct

+ Caches map[string]Cache

+ Classify func(Request) string

+ func (mux *MuxCache) CreateWatch(request *Request) (chan Response, func())

+ func (mux *MuxCache) Fetch(ctx context.Context, request *Request) (Response, error)

type RawResponse

+ Heartbeat bool

+ type ResourceWithTtl struct

+ Resources []types.Resource

+ Ttl *time.Duration

type Resources

+ func NewResourcesWithTtl(version string, items []types.ResourceWithTtl) Resources

type Snapshot

+ func NewSnapshotWithResources(version string, resources SnapshotResources) Snapshot

+ func NewSnapshotWithTtls(version string, endpoints []types.ResourceWithTtl, ...) Snapshot

+ func (s *Snapshot) GetResourcesAndTtl(typeURL string) map[string]types.ResourceWithTtl

type SnapshotCache

+ func NewSnapshotCacheWithHeartbeating(ctx context.Context, ads bool, hash NodeHash, logger log.Logger, ...) SnapshotCache

+ type SnapshotResources struct

+ Clusters []types.Resource

+ Endpoints []types.Resource

+ ExtensionConfigs []types.Resource

+ Listeners []types.Resource

+ Routes []types.Resource

+ Runtimes []types.Resource

+ Secrets []types.Resource

Oct 14, 2021

Changes in this version

+ func GetResourceName(res types.Resource) string

+ func GetResourceReferences(resources map[string]types.Resource) map[string]bool

+ func GetResponseType(typeURL string) types.ResponseType

+ func IndexResourcesByName(items []types.Resource) map[string]types.Resource

+ func MarshalResource(resource types.Resource) (types.MarshaledResource, error)

+ type Cache interface

+ Fetch func(context.Context, Request) (Response, error)

+ type ConfigWatcher interface

+ CreateWatch func(Request) (value chan Response, cancel func())

+ type IDHash struct

+ func (IDHash) ID(node *core.Node) string

+ type NodeHash interface

+ ID func(node *core.Node) string

+ type PassthroughResponse struct

+ DiscoveryResponse *discovery.DiscoveryResponse

+ Request discovery.DiscoveryRequest

+ func (r PassthroughResponse) GetDiscoveryResponse() (*discovery.DiscoveryResponse, error)

+ func (r PassthroughResponse) GetRequest() *discovery.DiscoveryRequest

+ func (r PassthroughResponse) GetVersion() (string, error)

+ type RawResponse struct

+ Request discovery.DiscoveryRequest

+ Resources []types.Resource

+ Version string

+ func (r RawResponse) GetDiscoveryResponse() (*discovery.DiscoveryResponse, error)

+ func (r RawResponse) GetRequest() *discovery.DiscoveryRequest

+ func (r RawResponse) GetVersion() (string, error)

+ type Request = discovery.DiscoveryRequest

+ type Resources struct

+ Items map[string]types.Resource

+ Version string

+ func NewResources(version string, items []types.Resource) Resources

+ type Response interface

+ GetDiscoveryResponse func() (*discovery.DiscoveryResponse, error)

+ GetRequest func() *discovery.DiscoveryRequest

+ GetVersion func() (string, error)

+ type ResponseWatch struct

+ Request Request

+ Response chan Response

+ type Snapshot struct

+ Resources [types.UnknownType]Resources

+ func NewSnapshot(version string, endpoints []types.Resource, clusters []types.Resource, ...) Snapshot

+ func (s *Snapshot) Consistent() error

+ func (s *Snapshot) GetResources(typeURL string) map[string]types.Resource

+ func (s *Snapshot) GetVersion(typeURL string) string

+ type SnapshotCache interface

+ ClearSnapshot func(node string)

+ GetSnapshot func(node string) (Snapshot, error)

+ GetStatusInfo func(string) StatusInfo

+ GetStatusKeys func() []string

+ SetSnapshot func(node string, snapshot Snapshot) error

+ func NewSnapshotCache(ads bool, hash NodeHash, logger log.Logger) SnapshotCache

+ type StatusInfo interface

+ GetLastWatchRequestTime func() time.Time

+ GetNode func() *core.Node

+ GetNumWatches func() int