Versions in this module Expand all Collapse all v4 v4.22.0 Oct 23, 2023 Changes in this version + var ErrContentRequired = errors.New("content required") + var ErrInvalidOperation = errors.New("invalid operation") + var ErrInvalidTranscoder = errors.New("invalid transcoder") + func CacheConfig() *service.ConfigSpec + func ProcessorConfig() *service.ConfigSpec + type Cache struct + func NewCache(conf *service.ParsedConfig, mgr *service.Resources) (*Cache, error) + func (c *Cache) Add(ctx context.Context, key string, value []byte, ttl *time.Duration) error + func (c *Cache) Delete(ctx context.Context, key string) error + func (c *Cache) Get(ctx context.Context, key string) (data []byte, err error) + func (c *Cache) Set(ctx context.Context, key string, value []byte, ttl *time.Duration) error + func (p Cache) Close(ctx context.Context) error + type Processor struct + func NewProcessor(conf *service.ParsedConfig, mgr *service.Resources) (*Processor, error) + func (p *Processor) ProcessBatch(ctx context.Context, inBatch service.MessageBatch) ([]service.MessageBatch, error) + func (p Processor) Close(ctx context.Context) error
Go to main page