clientserver

Documentation

Index

• Constants
• func ClientBlockReader(reader *bufio.Reader, routers []chan []byte, termimator *sync.WaitGroup)
• func ServerDataCompressor(client *Client, pipe int, compression int, ...)
• func ServerDataStreaming(client *Client, pipe int, inCh <-chan compressor.CompressedData, ...)
• type Client
  • func (client *Client) DoneMsg()
  • func (client *Client) Init(ldbs int)
  • func (client *Client) ParseHeader(line string)
  • func (client *Client) Terminate()
• type ClientStats
  • func (client *ClientStats) Init(ldbs int)

Constants

const VersionsHeader = "versions"

Functions

func ClientBlockReader

func ClientBlockReader(reader *bufio.Reader, routers []chan []byte, termimator *sync.WaitGroup)

func ServerDataCompressor

func ServerDataCompressor(client *Client, pipe int, compression int,
	inCh <-chan compressor.CompressableData, outCh chan<- compressor.CompressedData)

func ServerDataStreaming

func ServerDataStreaming(client *Client, pipe int, inCh <-chan compressor.CompressedData, outCh chan<- compressor.TheMessage)

Types

type Client

type Client struct {
	// static
	Databases []int
	Versions  []int64
	Conn      net.Conn
	Reader    *bufio.Reader
	Conntype  string
	ID        string

	Info      map[string]string
	Handshake map[string]string

	TerminateChain func()

	TSStart time.Time

	//  static pipeline - no need to keep just for debugging
	//-- remove channels from client's structure after debugging
	//	KVFullScan   []chan []Reader.PKVData
	KVPartSink   []chan reader.VersionData
	MsgSink      []chan compressor.CompressableData
	DataBreakers []chan compressor.CompressedData
	BlockDrains  []chan compressor.TheMessage

	SocketDrain <-chan compressor.TheMessage

	//	watchers
	// Control
	Finished sync.WaitGroup
	Control  chan control.ControlMessage
	Alive    chan int // never being sent just close on quit

	TSSynced       []time.Time
	TSLatestUpdate []time.Time
	//	SyncVolume []int64
	Stats ClientStats
	// contains filtered or unexported fields
}

func (*Client) DoneMsg

func (client *Client) DoneMsg()

func (*Client) Init

func (client *Client) Init(ldbs int)

func (*Client) ParseHeader

func (client *Client) ParseHeader(line string)

func (*Client) Terminate

func (client *Client) Terminate()

type ClientStats

type ClientStats struct {
	Produced   []int64
	Compressed []int64
}

func (*ClientStats) Init

func (client *ClientStats) Init(ldbs int)