registry

type DBInsert struct {
	Table string
	Data  *map[string]interface{}
}

type FileProcessor interface {
	Process(name string, files map[string][]byte) ([]DBInsert, error)
}

type PullClient struct {
	Type  string
	Conn  *r.Session
	Table string
}

type PushClient struct {
	ServerAddr string
	ChunkSize  int
	Conn       pb.RegistryClient
}

type PushClientFile struct {
	Name string
	Type string
}

type PushServer struct {
	Port      int
	ChunkSize int
	Conn      *r.Session // sessions are thread safe?
	Processor FileProcessor
}