cache

Documentation

Index

• Variables
• func AddCacheFlagsToCmd(cmd *cobra.Command) func() (*Cache, error)
• type Cache
  • func NewCache(cacheClient CacheClient) *Cache
  • func (c *Cache) GetAppDetails(commitSHA string, appSrc *appv1.ApplicationSource, res interface{}) error
  • func (c *Cache) GetAppManagedResources(appName string, res *[]*appv1.ResourceDiff) error
  • func (c *Cache) GetAppResourcesTree(appName string, res *appv1.ApplicationTree) error
  • func (c *Cache) GetClusterConnectionState(server string) (appv1.ConnectionState, error)
  • func (c *Cache) GetManifests(commitSHA string, appSrc *appv1.ApplicationSource, namespace string, ...) error
  • func (c *Cache) GetOIDCState(key string) (*OIDCState, error)
  • func (c *Cache) GetRepoConnectionState(repo string) (appv1.ConnectionState, error)
  • func (c *Cache) GetRevisionMetadata(repoURL, revision string) (*appv1.RevisionMetadata, error)
  • func (c *Cache) ListApps(repoUrl, revision string) (map[string]string, error)
  • func (c *Cache) SetAppDetails(commitSHA string, appSrc *appv1.ApplicationSource, res interface{}) error
  • func (c *Cache) SetAppManagedResources(appName string, managedResources []*appv1.ResourceDiff) error
  • func (c *Cache) SetAppResourcesTree(appName string, resourcesTree *appv1.ApplicationTree) error
  • func (c *Cache) SetApps(repoUrl, revision string, apps map[string]string) error
  • func (c *Cache) SetClusterConnectionState(server string, state *appv1.ConnectionState) error
  • func (c *Cache) SetManifests(commitSHA string, appSrc *appv1.ApplicationSource, namespace string, ...) error
  • func (c *Cache) SetOIDCState(key string, state *OIDCState) error
  • func (c *Cache) SetRepoConnectionState(repo string, state *appv1.ConnectionState) error
  • func (c *Cache) SetRevisionMetadata(repoURL, revision string, item *appv1.RevisionMetadata) error
• type CacheClient
  • func NewRedisCache(client *redis.Client, expiration time.Duration) CacheClient
• type InMemoryCache
  • func NewInMemoryCache(expiration time.Duration) *InMemoryCache
  • func (i *InMemoryCache) Delete(key string) error
  • func (i *InMemoryCache) Flush()
  • func (i *InMemoryCache) Get(key string, obj interface{}) error
  • func (i *InMemoryCache) Set(item *Item) error
• type Item
• type OIDCState

Variables

var ErrCacheMiss = errors.New("cache: key is missing")

Functions

func AddCacheFlagsToCmd

func AddCacheFlagsToCmd(cmd *cobra.Command) func() (*Cache, error)

AddCacheFlagsToCmd adds flags which control caching to the specified command

Types

type Cache

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

Cache provides strongly types methods to store and retrieve values from shared cache

func NewCache

func NewCache(cacheClient CacheClient) *Cache

NewCache creates new instance of Cache

func (*Cache) GetAppDetails

func (c *Cache) GetAppDetails(commitSHA string, appSrc *appv1.ApplicationSource, res interface{}) error

func (*Cache) GetAppManagedResources

func (c *Cache) GetAppManagedResources(appName string, res *[]*appv1.ResourceDiff) error

func (*Cache) GetAppResourcesTree

func (c *Cache) GetAppResourcesTree(appName string, res *appv1.ApplicationTree) error

func (*Cache) GetClusterConnectionState

func (c *Cache) GetClusterConnectionState(server string) (appv1.ConnectionState, error)

func (*Cache) GetManifests

func (c *Cache) GetManifests(commitSHA string, appSrc *appv1.ApplicationSource, namespace string, appLabelKey string, appLabelValue string, res interface{}) error

func (*Cache) GetOIDCState

func (c *Cache) GetOIDCState(key string) (*OIDCState, error)

func (*Cache) GetRepoConnectionState

func (c *Cache) GetRepoConnectionState(repo string) (appv1.ConnectionState, error)

func (*Cache) GetRevisionMetadata

func (c *Cache) GetRevisionMetadata(repoURL, revision string) (*appv1.RevisionMetadata, error)

func (*Cache) ListApps

func (c *Cache) ListApps(repoUrl, revision string) (map[string]string, error)

func (*Cache) SetAppDetails

func (c *Cache) SetAppDetails(commitSHA string, appSrc *appv1.ApplicationSource, res interface{}) error

func (*Cache) SetAppManagedResources

func (c *Cache) SetAppManagedResources(appName string, managedResources []*appv1.ResourceDiff) error

func (*Cache) SetAppResourcesTree

func (c *Cache) SetAppResourcesTree(appName string, resourcesTree *appv1.ApplicationTree) error

func (*Cache) SetApps

func (c *Cache) SetApps(repoUrl, revision string, apps map[string]string) error

func (*Cache) SetClusterConnectionState

func (c *Cache) SetClusterConnectionState(server string, state *appv1.ConnectionState) error

func (*Cache) SetManifests

func (c *Cache) SetManifests(commitSHA string, appSrc *appv1.ApplicationSource, namespace string, appLabelKey string, appLabelValue string, res interface{}) error

func (*Cache) SetOIDCState

func (c *Cache) SetOIDCState(key string, state *OIDCState) error

func (*Cache) SetRepoConnectionState

func (c *Cache) SetRepoConnectionState(repo string, state *appv1.ConnectionState) error

func (*Cache) SetRevisionMetadata

func (c *Cache) SetRevisionMetadata(repoURL, revision string, item *appv1.RevisionMetadata) error

type CacheClient

type CacheClient interface {
	Set(item *Item) error
	Get(key string, obj interface{}) error
	Delete(key string) error
}

func NewRedisCache

func NewRedisCache(client *redis.Client, expiration time.Duration) CacheClient

type InMemoryCache

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

func NewInMemoryCache

func NewInMemoryCache(expiration time.Duration) *InMemoryCache

func (*InMemoryCache) Delete

func (i *InMemoryCache) Delete(key string) error

func (*InMemoryCache) Flush

func (i *InMemoryCache) Flush()

func (*InMemoryCache) Get

func (i *InMemoryCache) Get(key string, obj interface{}) error

func (*InMemoryCache) Set

func (i *InMemoryCache) Set(item *Item) error

type Item

type Item struct {
	Key    string
	Object interface{}
	// Expiration is the cache expiration time.
	Expiration time.Duration
}

type OIDCState

type OIDCState struct {
	// ReturnURL is the URL in which to redirect a user back to after completing an OAuth2 login
	ReturnURL string `json:"returnURL"`
}