Versions in this module Expand all Collapse all v0 v0.4.0-rc.1 May 20, 2017 v0.3.1 Mar 24, 2017 v0.3.0 Mar 21, 2017 Changes in this version + var DefaultCollectionFilter = map[string]CollectionFilter + var ErrCollectionFilter = errors.New("malformed collection_filters") + type CollectionFilter map[string]interface type MongoDB + Bulk bool + CACerts []string + CollectionFilters string + FSync bool + SSL bool + Tail bool + Wc int + func (m *MongoDB) Client() (client.Client, error) + func (m *MongoDB) Reader() (client.Reader, error) + func (m *MongoDB) Writer(done chan struct{}, wg *sync.WaitGroup) (client.Writer, error) v0.2.2 Mar 20, 2017 v0.2.1 Mar 7, 2017 Changes in this version + const DefaultSessionTimeout + const DefaultURI + var DefaultSafety = mgo.Safe + type Bulk struct + func (b *Bulk) Write(msg message.Msg) func(client.Session) error + type Client struct + func NewClient(options ...ClientOptionFunc) (*Client, error) + func (c *Client) Connect() (client.Session, error) + func (c Client) Close() + type ClientOptionFunc func(*Client) error + func WithCACerts(certs []string) ClientOptionFunc + func WithFsync(fsync bool) ClientOptionFunc + func WithSSL(ssl bool) ClientOptionFunc + func WithTail(tail bool) ClientOptionFunc + func WithTimeout(timeout string) ClientOptionFunc + func WithURI(uri string) ClientOptionFunc + func WithWriteConcern(wc int) ClientOptionFunc + type Config struct + Bulk bool + CACerts []string + FSync bool + Namespace string + SSL bool + Tail bool + Timeout string + URI string + Wc int + type MongoDB struct + func (m *MongoDB) Connect() error + func (m *MongoDB) Description() string + func (m *MongoDB) Listen() (err error) + func (m *MongoDB) SampleConfig() string + func (m *MongoDB) Start() (err error) + func (m *MongoDB) Stop() error + type OplogAccessError struct + func (e OplogAccessError) Error() string + type Reader struct + func (r *Reader) Read(filterFn client.NsFilterFunc) client.MessageChanFunc + type Session struct + func (s *Session) Close() + type Tailer struct + func (t *Tailer) Read(filterFn client.NsFilterFunc) client.MessageChanFunc + type Writer struct + func (w *Writer) Write(msg message.Msg) func(client.Session) error
Go to main page