Versions in this module Expand all Collapse all v0 v0.1.3 Nov 24, 2021 v0.1.2 Oct 28, 2021 Changes in this version + const RedisKubernetesChart + const RedisKubernetesDeploymentName + var RedisKubernetesChartRepo = repo.Entry + func CacheSmokeTest(t *testing.T, c CacheSystem) + func IntOptional(i int) *int + func RunTestCacheSystem(t *testing.T, c CacheSystem) + type AWSEFSCache struct + func (A *AWSEFSCache) Clear() error + func (A *AWSEFSCache) Delete(path string) error + func (A *AWSEFSCache) Deploy() error + func (A *AWSEFSCache) Flush(fs corfs.FileSystem) error + func (A *AWSEFSCache) FunctionInjector() CacheConfigIncector + func (A *AWSEFSCache) Init() error + func (A *AWSEFSCache) Join(elem ...string) string + func (A *AWSEFSCache) ListFiles(path string) ([]corfs.FileInfo, error) + func (A *AWSEFSCache) OpenReader(path string, startAt int64) (io.ReadCloser, error) + func (A *AWSEFSCache) OpenWriter(path string) (io.WriteCloser, error) + func (A *AWSEFSCache) Split(path string) []string + func (A *AWSEFSCache) Stat(path string) (corfs.FileInfo, error) + func (A *AWSEFSCache) Undeploy() error + type AWSEFSCacheConfigInjector struct + func (a *AWSEFSCacheConfigInjector) CacheSystem() CacheSystem + func (a *AWSEFSCacheConfigInjector) ConfigureLambda(functionConfig *lambda.CreateFunctionInput) error + type CacheConfigIncector interface + CacheSystem func() CacheSystem + type CacheSystem interface + Clear func() error + Deploy func() error + Flush func(system corfs.FileSystem) error + FunctionInjector func() CacheConfigIncector + Undeploy func() error + func NewCacheSystem(fsType CacheSystemType) (CacheSystem, error) + type CacheSystemType int + const EFS + const Local + const NoCache + const Olric + const Redis + func CacheSystemTypes(fs CacheSystem) CacheSystemType + type ClientConfig struct + Addrs []string + DB int + RouteByLatency bool + RouteRandomly bool + User string + type DeploymentStrategy interface + Deploy func() (*ClientConfig, error) + Undeploy func() error + func NewDeploymentStrategy(deploymentType DeploymentType) (DeploymentStrategy, error) + type DeploymentType int + const AWS + const KubernetesDeployment + const LocalDeployment + type KubernetesRedisDeploymentStrategy struct + Namespace string + NodePort *int + StorageClass string + func (k *KubernetesRedisDeploymentStrategy) Deploy() (*ClientConfig, error) + func (k *KubernetesRedisDeploymentStrategy) Undeploy() error + type LocalCache struct + func NewLocalInMemoryProvider(maxSize uint64) *LocalCache + func (l *LocalCache) Clear() error + func (l *LocalCache) Delete(path string) error + func (l *LocalCache) Deploy() error + func (l *LocalCache) Flush(fs corfs.FileSystem) error + func (l *LocalCache) FunctionInjector() CacheConfigIncector + func (l *LocalCache) Init() error + func (l *LocalCache) Join(elem ...string) string + func (l *LocalCache) ListFiles(path string) ([]corfs.FileInfo, error) + func (l *LocalCache) OpenReader(path string, startAt int64) (io.ReadCloser, error) + func (l *LocalCache) OpenWriter(path string) (io.WriteCloser, error) + func (l *LocalCache) Split(path string) []string + func (l *LocalCache) Stat(path string) (corfs.FileInfo, error) + func (l *LocalCache) Undeploy() error + type LocalRedisDeploymentStrategy struct + func (l *LocalRedisDeploymentStrategy) Deploy() (*ClientConfig, error) + func (l *LocalRedisDeploymentStrategy) Undeploy() error + type RedisBackedCache struct + Client redis.UniversalClient + Config *ClientConfig + DeploymentStragey DeploymentStrategy + func NewRedisBackedCache(deploymentType DeploymentType) (*RedisBackedCache, error) + func (r *RedisBackedCache) Clear() error + func (r *RedisBackedCache) Delete(filePath string) error + func (r *RedisBackedCache) Deploy() error + func (r *RedisBackedCache) Flush(fs corfs.FileSystem) error + func (r *RedisBackedCache) FunctionInjector() CacheConfigIncector + func (r *RedisBackedCache) Init() error + func (r *RedisBackedCache) Join(elem ...string) string + func (r *RedisBackedCache) ListFiles(pathGlob string) ([]corfs.FileInfo, error) + func (r *RedisBackedCache) OpenReader(filePath string, startAt int64) (io.ReadCloser, error) + func (r *RedisBackedCache) OpenWriter(filePath string) (io.WriteCloser, error) + func (r *RedisBackedCache) Split(path string) []string + func (r *RedisBackedCache) Stat(filePath string) (corfs.FileInfo, error) + func (r *RedisBackedCache) Undeploy() error + type RedisCacheConfigInjector struct + func (r *RedisCacheConfigInjector) CacheSystem() CacheSystem + func (r *RedisCacheConfigInjector) ConfigureLambda(function *lambda.CreateFunctionInput) error + func (r *RedisCacheConfigInjector) ConfigureWhisk(action *whisk.Action) error + type WriteCloser struct + func (w *WriteCloser) Close() error + func (w *WriteCloser) Write(p []byte) (n int, err error)
Go to main page