concept

type Client interface {
	Do(req *http.Request) (resp *http.Response, err error)
}

type Inquirer interface {
	Inquire(candidates []string, tid string) []*Worker
}

type NeoInquirer struct {
	Neo db.Service
	Log *logger.UPPLogger
}

type S3Updater struct {
	Client            Client
	S3WriterBaseURL   string
	S3WriterHealthURL string
}

type State string

type Updater interface {
	Upload(concept []byte, conceptType, tid string) error
}

type Worker struct {
	sync.RWMutex
	ConceptCh    chan db.Concept `json:"-"`
	Errch        chan error      `json:"-"`
	ConceptType  string          `json:"ConceptType,omitempty"`
	Count        int             `json:"Count,omitempty"`
	Progress     int             `json:"Progress,omitempty"`
	Status       State           `json:"Status,omitempty"`
	ErrorMessage string          `json:"ErrorMessage,omitempty"`
}