Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

v0

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