Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

cache

package

Go to main page

Versions in this module

v1

v1.18.1

May 23, 2024

v1.18.1-alpha.0

Apr 16, 2024

v1.18.0

Mar 4, 2024

Changes in this version

+ type CacheHook interface

+ OnCreateDeltaWatch func(request *cachev3.DeltaRequest, state stream.StreamState, ...)

+ OnCreateWatch func(request *cachev3.Request, streamState stream.StreamState, ...)

+ OnFetch func(ctx context.Context, request *cachev3.Request)

+ type Callbacks struct

+ func NewCallback(cacheMgr *ResourceCache, nodeMgr *resource.XDSNodeManager) *Callbacks

+ func (cb *Callbacks) OnDeltaStreamClosed(id int64, node *corev3.Node)

+ func (cb *Callbacks) OnDeltaStreamOpen(_ context.Context, id int64, typ string) error

+ func (cb *Callbacks) OnFetchRequest(_ context.Context, req *discovery.DiscoveryRequest) error

+ func (cb *Callbacks) OnFetchResponse(req *discovery.DiscoveryRequest, resp *discovery.DiscoveryResponse)

+ func (cb *Callbacks) OnStreamClosed(id int64, node *corev3.Node)

+ func (cb *Callbacks) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error

+ func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, ...)

+ func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error

+ func (cb *Callbacks) OnStreamRequest(id int64, req *discovery.DiscoveryRequest) error

+ func (cb *Callbacks) OnStreamResponse(_ context.Context, id int64, req *discovery.DiscoveryRequest, ...)

+ type NamespaceResourcesContainer struct

+ type NamespaceStatusInfo struct

+ type NamespaceUpdateResourcesRequest struct

+ DemandResources map[resource.XDSType]*TypeResources

+ NormalResources map[resource.XDSType]*TypeResources

+ TlsResources map[resource.TLSMode]map[resource.XDSType]*TypeResources

+ func NewNamespaceUpdateResourcesRequest() *NamespaceUpdateResourcesRequest

+ func (r *NamespaceUpdateResourcesRequest) AddNormals(xdsType resource.XDSType, res []types.Resource)

+ func (r *NamespaceUpdateResourcesRequest) AddTls(tlsMode resource.TLSMode, xdsType resource.XDSType, res []types.Resource)

+ func (r *NamespaceUpdateResourcesRequest) RemoveNormal(xdsType resource.XDSType, res []types.Resource)

+ func (r *NamespaceUpdateResourcesRequest) RemoveTls(tlsMode resource.TLSMode, xdsType resource.XDSType, res []types.Resource)

+ type NoReadyXdsResponse struct

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

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

+ type ResourceCache struct

+ func NewResourceCache(hook CacheHook) *ResourceCache

+ func (sc *ResourceCache) CleanEnvoyNodeCache(node *corev3.Node) error

+ func (sc *ResourceCache) CreateDeltaWatch(request *cachev3.DeltaRequest, state stream.StreamState, ...) func()

+ func (sc *ResourceCache) CreateWatch(request *cachev3.Request, streamState stream.StreamState, ...) func()

+ func (sc *ResourceCache) Fetch(ctx context.Context, request *cachev3.Request) (cachev3.Response, error)

+ func (sc *ResourceCache) GetResources(typeUrl resource.XDSType, ns, nodeId string) map[string]types.Resource

+ func (sc *ResourceCache) GetStatusKeys() []string

+ func (sc *ResourceCache) UpdateResources(ctx context.Context, req *UpdateResourcesRequest) error

+ type ResourcesContainer struct

+ GlobalVersion string

+ Resources map[string]types.Resource

+ VersionMap map[string]string

+ func (s *ResourcesContainer) ConstructVersionMap(modified []string) error

+ type TypeResources struct

+ RemoveResources map[string]struct{}

+ UpsertResources map[string]types.Resource

+ func NewTypeResources() *TypeResources

+ func (r *TypeResources) AppendRemoves(resources map[string]types.Resource)

+ func (r *TypeResources) AppendUpserts(resources map[string]types.Resource)

+ type UpdateResourcesRequest struct

+ Lds map[string]map[string]types.Resource

+ NamespaceResources map[string]*NamespaceUpdateResourcesRequest

+ func NewUpdateResourcesRequest() *UpdateResourcesRequest

+ func (r *UpdateResourcesRequest) AddNormalNamespaces(namespace string, xdsType resource.XDSType, res []types.Resource)

+ func (r *UpdateResourcesRequest) AddTlsNamespaces(namespace string, tls resource.TLSMode, xdsType resource.XDSType, ...)

+ func (r *UpdateResourcesRequest) RemoveNormalNamespaces(namespace string, tls resource.TLSMode, xdsType resource.XDSType, ...)

+ func (r *UpdateResourcesRequest) RemoveTlsNamespaces(namespace string, tls resource.TLSMode, xdsType resource.XDSType, ...)

v1.18.0-beta.2

Feb 3, 2024

v1.18.0-beta.1

Jan 11, 2024

v1.18.0-beta

Jan 8, 2024

v1.18.0-alpha.1

Jan 2, 2024

v1.18.0-alpha

Dec 21, 2023