rethinkdb

package

v0.1.2 Latest Latest Go to latest Published: Jan 27, 2017 License: BSD-3-Clause Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Adaptor struct {
	// contains filtered or unexported fields
}

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) MustUseSession(conn interface{}) message.Adaptor

func (r Adaptor) Name() string

func (r Adaptor) Update(m message.Msg) error

func (r Adaptor) UseSession(conn interface{}) (message.Adaptor, error)

type Message struct {
	TS        int64
	MapData   data.Data
	NS        string
	Operation ops.Op
}

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