diff --git a/worker/inpack.go b/worker/inpack.go index 68d9928..abb7516 100644 --- a/worker/inpack.go +++ b/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) diff --git a/worker/job.go b/worker/job.go index d2d7d6f..3d6904f 100644 --- a/worker/job.go +++ b/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 }