oplog

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

type InAppReplicator struct {
	Buffer chan *OpLog
}

type OpLog struct {
	ID           string        // Operation ID, sortable
	KID          string        // The actual ID that is written Buffer the DB on ADD
	Key          string        // The key used in the interface
	Op           Opn           // The operation (Add, remove etc.
	Value        *crdt.TSValue // What Buffer store
	IsFromRemote bool
}

type Opn string

type PeeringReplicator struct {
	Queue *memberlist.TransmitLimitedQueue
}

type Replicator interface {
	Send(op *OpLog) error
}