Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FileProcessor ¶
files: map of filetype -> file
type PullClient ¶
func InitPullClient ¶
func InitPullClient(cluster []string, db string, table string) *PullClient
func (*PullClient) Pull ¶
func (c *PullClient) Pull(name string) map[string]interface{}
type PushClient ¶
type PushClient struct { ServerAddr string ChunkSize int Conn pb.RegistryClient }
func InitPushClient ¶
func InitPushClient(serveraddr string, chunksize int) *PushClient
func (*PushClient) Push ¶
func (c *PushClient) Push(name string, files ...PushClientFile)
type PushClientFile ¶
type PushServer ¶
type PushServer struct { Port int ChunkSize int Conn *r.Session // sessions are thread safe? Processor FileProcessor }
func InitPushServer ¶
func InitPushServer(cluster []string, db string, proc FileProcessor, port, chunksize int, tables ...string) *PushServer
TODO add authKey argument to creating the session
func (*PushServer) Push ¶
func (s *PushServer) Push(stream pb.Registry_PushServer) error
func (*PushServer) Run ¶
func (s *PushServer) Run()
Click to show internal directories.
Click to hide internal directories.