Versions in this module Expand all Collapse all v0 v0.2.1 Mar 7, 2017 Changes in this version + const DefaultURI + type Client struct + func NewClient(options ...ClientOptionFunc) (*Client, error) + func (c *Client) Close() + func (c *Client) Connect() (client.Session, error) + type ClientOptionFunc func(*Client) error + func WithURI(uri string) ClientOptionFunc + type Config struct + Debug bool + Namespace string + ReplicationSlot string + Tail bool + URI string + type Postgres struct + func (p *Postgres) Connect() error + func (p *Postgres) Description() string + func (p *Postgres) Listen() (err error) + func (p *Postgres) SampleConfig() string + func (p *Postgres) Start() (err error) + func (p *Postgres) Stop() error + type Reader struct + func (r *Reader) Read(filterFn client.NsFilterFunc) client.MessageChanFunc + type Session struct + 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