Versions in this module Expand all Collapse all v3 v3.15.4 May 30, 2020 v3.15.2 May 30, 2020 v3.15.1 May 30, 2020 Changes in this version + const TypeDynamoDB + const TypeFile + const TypeMemcached + const TypeMemory + const TypeMultilevel + const TypeRedis + const TypeS3 + var Constructors = map[string]TypeSpec + func Descriptions() string + func DocumentPlugin(typeString, description string, configSanitiser PluginConfigSanitiser) + func New(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (types.Cache, error) + func NewDynamoDB(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (types.Cache, error) + func NewFile(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (types.Cache, error) + func NewMemcached(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (types.Cache, error) + func NewMemory(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (types.Cache, error) + func NewMultilevel(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (types.Cache, error) + func NewRedis(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (types.Cache, error) + func NewS3(conf Config, mgr types.Manager, log log.Modular, stats metrics.Type) (types.Cache, error) + func PluginCount() int + func PluginDescriptions() string + func RegisterPlugin(typeString string, configConstructor PluginConfigConstructor, ...) + func SanitiseConfig(conf Config) (interface{}, error) + type Config struct + DynamoDB DynamoDBConfig + File FileConfig + Memcached MemcachedConfig + Memory MemoryConfig + Multilevel MultilevelConfig + Plugin interface{} + Redis RedisConfig + S3 S3Config + Type string + func NewConfig() Config + func (c *Config) UnmarshalYAML(value *yaml.Node) error + type DynamoDB struct + func (d *DynamoDB) Add(key string, value []byte) error + func (d *DynamoDB) CloseAsync() + func (d *DynamoDB) Delete(key string) error + func (d *DynamoDB) Get(key string) ([]byte, error) + func (d *DynamoDB) Set(key string, value []byte) error + func (d *DynamoDB) SetMulti(items map[string][]byte) error + func (d *DynamoDB) WaitForClose(timeout time.Duration) error + type DynamoDBConfig struct + ConsistentRead bool + DataKey string + HashKey string + TTL string + TTLKey string + Table string + func NewDynamoDBConfig() DynamoDBConfig + type File struct + func (f *File) Add(key string, value []byte) error + func (f *File) CloseAsync() + func (f *File) Delete(key string) error + func (f *File) Get(key string) ([]byte, error) + func (f *File) Set(key string, value []byte) error + func (f *File) SetMulti(items map[string][]byte) error + func (f *File) WaitForClose(timeout time.Duration) error + type FileConfig struct + Directory string + func NewFileConfig() FileConfig + type Memcached struct + func (m *Memcached) Add(key string, value []byte) error + func (m *Memcached) CloseAsync() + func (m *Memcached) Delete(key string) error + func (m *Memcached) Get(key string) ([]byte, error) + func (m *Memcached) Set(key string, value []byte) error + func (m *Memcached) SetMulti(items map[string][]byte) error + func (m *Memcached) WaitForClose(timeout time.Duration) error + type MemcachedConfig struct + Addresses []string + Prefix string + Retries int + RetryPeriod string + TTL int32 + func NewMemcachedConfig() MemcachedConfig + type Memory struct + func (m *Memory) Add(key string, value []byte) error + func (m *Memory) CloseAsync() + func (m *Memory) Delete(key string) error + func (m *Memory) Get(key string) ([]byte, error) + func (m *Memory) Set(key string, value []byte) error + func (m *Memory) SetMulti(items map[string][]byte) error + func (m *Memory) WaitForClose(timeout time.Duration) error + type MemoryConfig struct + CompactionInterval string + InitValues map[string]string + TTL int + func NewMemoryConfig() MemoryConfig + type Multilevel struct + func (l *Multilevel) Add(key string, value []byte) error + func (l *Multilevel) CloseAsync() + func (l *Multilevel) Delete(key string) error + func (l *Multilevel) Get(key string) ([]byte, error) + func (l *Multilevel) Set(key string, value []byte) error + func (l *Multilevel) SetMulti(items map[string][]byte) error + func (l *Multilevel) WaitForClose(timeout time.Duration) error + type MultilevelConfig []string + func NewMultilevelConfig() MultilevelConfig + type PluginConfigConstructor func() interface + type PluginConfigSanitiser func(conf interface{}) interface + type PluginConstructor func(config interface{}, manager types.Manager, logger log.Modular, ...) (types.Cache, error) + type Redis struct + func (r *Redis) Add(key string, value []byte) error + func (r *Redis) CloseAsync() + func (r *Redis) Delete(key string) error + func (r *Redis) Get(key string) ([]byte, error) + func (r *Redis) Set(key string, value []byte) error + func (r *Redis) SetMulti(items map[string][]byte) error + func (r *Redis) WaitForClose(timeout time.Duration) error + type RedisConfig struct + Expiration string + Prefix string + Retries int + RetryPeriod string + URL string + func NewRedisConfig() RedisConfig + type S3 struct + func (s *S3) Add(key string, value []byte) error + func (s *S3) CloseAsync() + func (s *S3) Delete(key string) error + func (s *S3) Get(key string) ([]byte, error) + func (s *S3) Set(key string, value []byte) error + func (s *S3) SetMulti(items map[string][]byte) error + func (s *S3) WaitForClose(timeout time.Duration) error + type S3Config struct + Bucket string + ContentType string + ForcePathStyleURLs bool + Retries int + Timeout string + func NewS3Config() S3Config + type TypeSpec struct + Description string + FieldSpecs docs.FieldSpecs + Footnotes string + Summary string Other modules containing this package github.com/windhooked/benthos
Go to main page