Documentation
¶
Index ¶
- func LWW_Decode(item []byte, in_ok, readable bool) (value []byte, ok bool)
- func LWW_Delete() (item []byte)
- func LWW_Factory() api.Merger
- func LWW_Put(value []byte) (item []byte)
- func Table_Delete() (item []byte)
- func Table_Factory() api.Merger
- func Table_Put(src Row) (item []byte)
- type LastWriteWins
- type Row
- type TableMerger
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LWW_Delete ¶
func LWW_Delete() (item []byte)
func LWW_Factory ¶
func Table_Delete ¶
func Table_Delete() (item []byte)
func Table_Factory ¶
Types ¶
type LastWriteWins ¶
type LastWriteWins struct {
// contains filtered or unexported fields
}
func (*LastWriteWins) Changed ¶
func (lww *LastWriteWins) Changed() bool
func (*LastWriteWins) Cleanup ¶
func (lww *LastWriteWins) Cleanup()
func (*LastWriteWins) Init ¶
func (lww *LastWriteWins) Init(item []byte)
func (*LastWriteWins) Merge ¶
func (lww *LastWriteWins) Merge(item []byte)
func (*LastWriteWins) Result ¶
func (lww *LastWriteWins) Result() []byte
type TableMerger ¶
type TableMerger struct {
// contains filtered or unexported fields
}
func (*TableMerger) Changed ¶
func (t *TableMerger) Changed() bool
func (*TableMerger) Cleanup ¶
func (t *TableMerger) Cleanup()
func (*TableMerger) Init ¶
func (t *TableMerger) Init(item []byte)
func (*TableMerger) Merge ¶
func (t *TableMerger) Merge(item []byte)
func (*TableMerger) Result ¶
func (t *TableMerger) Result() []byte
Source Files
Click to show internal directories.
Click to hide internal directories.