cache

package

Go to main page

Versions in this module

v0

v0.13.4

Jan 6, 2025

v0.13.3

Jan 2, 2025

v0.13.2

Dec 23, 2024

v0.13.1

Oct 15, 2024

v0.13.0

Aug 9, 2024

v0.12.0

Jan 2, 2024

v0.11.1

May 28, 2023

v0.11.0

Jan 30, 2023

Changes in this version

+ func GetResourceNames(resources []types.Resource) []string

v0.10.3

Jun 28, 2022

v0.10.2

Jun 28, 2022

Changes in this version

type LinearCache

+ func (cache *LinearCache) NumResources() int

+ func (cache *LinearCache) UpdateResources(toUpdate map[string]types.Resource, toDelete []string) error

+ type ResourceSnapshot interface

+ ConstructVersionMap func() error

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

+ GetResourcesAndTTL func(typeURL string) map[string]types.ResourceWithTTL

+ GetVersion func(typeURL string) string

+ GetVersionMap func(typeURL string) map[string]string

v0.10.1

Nov 15, 2021

v0.10.0

Oct 28, 2021

Changes in this version

+ func GetAllResourceReferences(resourceGroups [types.UnknownType]Resources) map[resource.Type]map[string]bool

type DeltaPassthroughResponse

+ func (r *DeltaPassthroughResponse) GetContext() context.Context

type DeltaResponse

+ GetContext func() context.Context

type LinearCache

+ func (cache *LinearCache) GetResources() map[string]types.Resource

+ func (cache *LinearCache) NumDeltaWatches() int

+ func (cache *LinearCache) SetResources(resources map[string]types.Resource)

type LinearCacheOption

+ func WithLogger(log log.Logger) LinearCacheOption

type MuxCache

+ ClassifyDelta func(*DeltaRequest) string

type PassthroughResponse

+ func (r *PassthroughResponse) GetContext() context.Context

type RawDeltaResponse

+ Ctx context.Context

+ func (r *RawDeltaResponse) GetContext() context.Context

type RawResponse

+ Ctx context.Context

+ func (r *RawResponse) GetContext() context.Context

type Resources

+ func NewResourcesWithTTL(version string, items []types.ResourceWithTTL) Resources

type Response

+ GetContext func() context.Context

type Snapshot

+ func NewSnapshotWithTTLs(version string, resources map[resource.Type][]types.ResourceWithTTL) (Snapshot, error)

+ func (s *Snapshot) GetResourcesAndTTL(typeURL resource.Type) map[string]types.ResourceWithTTL

v0.9.9

May 21, 2021

Changes in this version

+ func GetResponseTypeURL(responseType types.ResponseType) (string, error)

+ func HashResource(resource []byte) string

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

type ConfigWatcher

+ CreateDeltaWatch func(*DeltaRequest, *stream.StreamState) (value chan DeltaResponse, cancel func())

+ type DeltaPassthroughResponse struct

+ DeltaDiscoveryResponse *discovery.DeltaDiscoveryResponse

+ DeltaRequest *discovery.DeltaDiscoveryRequest

+ NextVersionMap map[string]string

+ func (r *DeltaPassthroughResponse) GetDeltaDiscoveryResponse() (*discovery.DeltaDiscoveryResponse, error)

+ func (r *DeltaPassthroughResponse) GetDeltaRequest() *discovery.DeltaDiscoveryRequest

+ func (r *DeltaPassthroughResponse) GetNextVersionMap() map[string]string

+ func (r *DeltaPassthroughResponse) GetSystemVersion() (string, error)

+ type DeltaRequest = discovery.DeltaDiscoveryRequest

+ type DeltaResources struct

+ Items resourceItems

+ SystemVersion string

+ type DeltaResponse interface

+ GetDeltaDiscoveryResponse func() (*discovery.DeltaDiscoveryResponse, error)

+ GetDeltaRequest func() *discovery.DeltaDiscoveryRequest

+ GetNextVersionMap func() map[string]string

+ GetSystemVersion func() (string, error)

+ type DeltaResponseWatch struct

+ Request *DeltaRequest

+ Response chan DeltaResponse

+ StreamState *stream.StreamState

type LinearCache

+ func (cache *LinearCache) CreateDeltaWatch(request *DeltaRequest, st *stream.StreamState) (chan DeltaResponse, func())

type MuxCache

+ func (cache *MuxCache) CreateDeltaWatch(request *DeltaRequest, st *stream.StreamState) (chan DeltaResponse, func())

+ type RawDeltaResponse struct

+ DeltaRequest *discovery.DeltaDiscoveryRequest

+ NextVersionMap map[string]string

+ RemovedResources []string

+ Resources []types.Resource

+ SystemVersionInfo string

+ func (r *RawDeltaResponse) GetDeltaDiscoveryResponse() (*discovery.DeltaDiscoveryResponse, error)

+ func (r *RawDeltaResponse) GetDeltaRequest() *discovery.DeltaDiscoveryRequest

+ func (r *RawDeltaResponse) GetNextVersionMap() map[string]string

+ func (r *RawDeltaResponse) GetSystemVersion() (string, 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

+ VersionMap map[string]map[string]string

+ func NewSnapshotWithResources(version string, resources SnapshotResources) Snapshot

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

+ func (s *Snapshot) ConstructVersionMap() error

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

+ func (s *Snapshot) GetVersionMap() map[string]map[string]string

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

type StatusInfo

+ GetLastDeltaWatchRequestTime func() time.Time

+ GetNumDeltaWatches func() int

+ SetDeltaResponseWatch func(int64, DeltaResponseWatch)

+ SetLastDeltaWatchRequestTime func(time.Time)

v0.9.8

Dec 7, 2020

v0.9.7

Oct 1, 2020

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)

v0.9.6

Jul 5, 2020

Changes in this version

+ 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 Response

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

+ GetRequest func() *discovery.DiscoveryRequest

+ GetVersion func() (string, error)

v0.9.5

Apr 1, 2020

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 Request = discovery.DiscoveryRequest

+ type Resources struct

+ Items map[string]types.Resource

+ Version string

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

+ type Response struct

+ MarshaledResources []types.MarshaledResource

+ Request discovery.DiscoveryRequest

+ ResourceMarshaled bool

+ Resources []types.Resource

+ Version string

+ 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL