Versions in this module Expand all Collapse all v0 v0.1.3 Feb 9, 2017 v0.1.2 Jan 27, 2017 Changes in this version + type Adaptor struct + func (r Adaptor) Delete(m message.Msg) error + func (r Adaptor) From(op ops.Op, namespace string, d data.Data) message.Msg + func (r Adaptor) Insert(m message.Msg) error + func (r Adaptor) Name() string + func (r Adaptor) Update(m message.Msg) error + func (r Adaptor) UseSession(session *sql.DB) Adaptor + type Message struct + MapData data.Data + NS string + Operation ops.Op + TS int64 + func (r *Message) Data() data.Data + func (r *Message) ID() string + func (r *Message) Namespace() string + func (r *Message) OP() ops.Op + func (r *Message) Timestamp() int64
Go to main page