file

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 {
	URI string
	FH  *os.File
}

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

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) MustUseFile(name string) message.Adaptor

func (r Adaptor) Name() string

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

func (r Adaptor) UseFile(uri string) (message.Adaptor, error)

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

func (f *Message) Data() data.Data

func (f *Message) ID() string

func (f *Message) Namespace() string

func (f *Message) OP() ops.Op

func (f *Message) Timestamp() int64