Merge branch 'master' into 0.2-dev

worker/inpack.go

@@ -24,6 +24,18 @@ func (inpack *inPack) Data() []byte {
 	return inpack.data
 }
 
+func (inpack *inPack) Fn() string {
+	return inpack.fn
+}
+
+func (inpack *inPack) Handle() string {
+	return inpack.handle
+}
+
+func (inpack *inPack) UniqueId() string {
+	return inpack.uniqueId
+}
+
 func (inpack *inPack) Err() error {
 	if inpack.dataType == dtError {
 		return getError(inpack.data)

worker/job.go

@@ -3,7 +3,10 @@ package worker
 type Job interface {
 	Err() error
 	Data() []byte
+	Fn() string
 	SendWarning(data []byte)
 	SendData(data []byte)
 	UpdateStatus(numerator, denominator int)
+	Handle() string
+	UniqueId() string
 }