@@ -24,6 +24,18 @@ func (inpack *inPack) Data() []byte { | |||||
return inpack.data | 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 { | func (inpack *inPack) Err() error { | ||||
if inpack.dataType == dtError { | if inpack.dataType == dtError { | ||||
return getError(inpack.data) | return getError(inpack.data) | ||||
@@ -3,7 +3,10 @@ package worker | |||||
type Job interface { | type Job interface { | ||||
Err() error | Err() error | ||||
Data() []byte | Data() []byte | ||||
Fn() string | |||||
SendWarning(data []byte) | SendWarning(data []byte) | ||||
SendData(data []byte) | SendData(data []byte) | ||||
UpdateStatus(numerator, denominator int) | UpdateStatus(numerator, denominator int) | ||||
Handle() string | |||||
UniqueId() string | |||||
} | } |