postgres

Mar 21, 2017

Changes in this version

type Postgres

+ Debug bool

+ ReplicationSlot string

+ Tail bool

+ func (p *Postgres) Client() (client.Client, error)

+ func (p *Postgres) Reader() (client.Reader, error)

+ func (p *Postgres) Writer(done chan struct{}, wg *sync.WaitGroup) (client.Writer, error)

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