mongodb

Mar 31, 2021

Changes in this version

+ func NewCache(conf cache.Config, mgr types.Manager, log log.Modular, stats metrics.Type) (types.Cache, error)

+ func NewOutput(conf output.MongoDBConfig, mgr types.Manager, log log.Modular, ...) (output.Type, error)

+ func NewProcessor(conf processor.Config, mgr types.Manager, log log.Modular, stats metrics.Type) (types.Processor, error)

+ type Cache struct

+ func (m *Cache) Add(key string, value []byte) error

+ func (m *Cache) CloseAsync()

+ func (m *Cache) Delete(key string) error

+ func (m *Cache) Get(key string) ([]byte, error)

+ func (m *Cache) Set(key string, value []byte) error

+ func (m *Cache) SetMulti(items map[string][]byte) error

+ func (m *Cache) WaitForClose(timeout time.Duration) error

+ type Processor struct

+ func (m *Processor) CloseAsync()

+ func (m *Processor) ProcessMessage(msg types.Message) ([]types.Message, types.Response)

+ func (m *Processor) WaitForClose(timeout time.Duration) error

+ type Writer struct

+ func NewWriter(conf output.MongoDBConfig, log log.Modular, stats metrics.Type) (*Writer, error)

+ func (m *Writer) CloseAsync()

+ func (m *Writer) ConnectWithContext(ctx context.Context) error

+ func (m *Writer) WaitForClose(timeout time.Duration) error

+ func (m *Writer) WriteWithContext(ctx context.Context, msg types.Message) error