message

type Adaptor ¶ added in v0.1.2

type Adaptor interface {
	Name() string
	From(op ops.Op, namespace string, data data.Data) Msg
}

func MustUseAdaptor(name string) Adaptor

func UseAdaptor(name string) (Adaptor, error)

type Base ¶ added in v0.1.2

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

Base represents a standard message format for transporter data if it does not meet your need, you can embed the struct and override whatever methods needed to accurately represent the data structure.

func (m *Base) Data() data.Data

func (m *Base) ID() string

func (m *Base) Namespace() string

func (m *Base) OP() ops.Op

func (m *Base) Timestamp() int64

type Commandable ¶ added in v0.1.2

type Commandable interface {
	Command(Msg) error
}

type Deletable ¶ added in v0.1.2

type Deletable interface {
	Delete(Msg) error
}

type Insertable ¶ added in v0.1.2

type Insertable interface {
	Insert(Msg) error
}

type Msg ¶

type Msg interface {
	ID() string
	OP() ops.Op
	Timestamp() int64
	Data() data.Data
	Namespace() string
}

A Msg serves to wrap the actual document to provide additional metadata about the document being transported.

func Exec(a Adaptor, m Msg) (Msg, error)

func From(op ops.Op, namespace string, d data.Data) Msg

type Updatable ¶ added in v0.1.2

type Updatable interface {
	Update(Msg) error
}