genSync

type Connection interface {
	Listen() error
	Connect() error
	Send(data []byte) (int, error)
	Receive() ([]byte, error)
	SendBytesSlice(dataSlice [][]byte) (int, error)
	ReceiveBytesSlice() ([][]byte, error)
	SendSkipSyncBoolWithInfo(skipSync bool, format string, args ...interface{}) error
	ReceiveSkipSyncBoolWithInfo(format string, args ...interface{}) (bool, error)
	SendSyncStatus(syncStatus uint8) error
	ReceiveSyncStatus() (uint8, error)
	Close() error
	GetIp() string
	GetPort() string
	GetSentBytes() int
	GetReceivedBytes() int
	GetTotalBytes() int
}

type GenSync interface {
	SetFreezeLocal(freezeLocal bool)

	AddElement(elem interface{}) error
	DeleteElement(elem interface{}) error

	SyncClient(ip string, port int) error
	SyncServer(ip string, port int) error

	GetLocalSet() *set.Set
	GetSetAdditions() *set.Set // Set the set that is added to the local set.
	GetSentBytes() int
	GetReceivedBytes() int
	GetTotalBytes() int
}