transport

Documentation

Index

• func DecodeContext(context string) (map[string]uint64, error)
• func EncodeContext(context map[string]uint64) (string, error)
• type TransportRow
  • func (tr *TransportRow) FromRow(row *Row) error
• type TransportSiblingSet
  • func (tss *TransportSiblingSet) FromSiblingSet(siblingSet *SiblingSet) error
• type TransportUpdateBatch
  • func (tub TransportUpdateBatch) FromUpdateBatch(updateBatch *UpdateBatch) error
  • func (tub TransportUpdateBatch) ToUpdateBatch(updateBatch *UpdateBatch) error
• type TransportUpdateOp

Functions

func DecodeContext

func DecodeContext(context string) (map[string]uint64, error)

func EncodeContext

func EncodeContext(context map[string]uint64) (string, error)

Types

type TransportRow

type TransportRow struct {
	Key          string   `json:"key"`
	LocalVersion uint64   `json:"serial"`
	Context      string   `json:"context"`
	Siblings     []string `json:"siblings"`
}

func (*TransportRow) FromRow

func (tr *TransportRow) FromRow(row *Row) error

type TransportSiblingSet

type TransportSiblingSet struct {
	Siblings []string `json:"siblings"`
	Context  string   `json:"context"`
}

func (*TransportSiblingSet) FromSiblingSet

func (tss *TransportSiblingSet) FromSiblingSet(siblingSet *SiblingSet) error

type TransportUpdateBatch

type TransportUpdateBatch []TransportUpdateOp

func (TransportUpdateBatch) FromUpdateBatch

func (tub TransportUpdateBatch) FromUpdateBatch(updateBatch *UpdateBatch) error

func (TransportUpdateBatch) ToUpdateBatch

func (tub TransportUpdateBatch) ToUpdateBatch(updateBatch *UpdateBatch) error

type TransportUpdateOp

type TransportUpdateOp struct {
	Type    string `json:"type"`
	Key     string `json:"key"`
	Value   string `json:"value"`
	Context string `json:"context"`
}