diff --git a/worker/inpack.go b/worker/inpack.go index 3a18e46..abb7516 100644 --- a/worker/inpack.go +++ b/worker/inpack.go @@ -24,6 +24,10 @@ func (inpack *inPack) Data() []byte { return inpack.data } +func (inpack *inPack) Fn() string { + return inpack.fn +} + func (inpack *inPack) Handle() string { return inpack.handle } diff --git a/worker/job.go b/worker/job.go index 7ef28de..3d6904f 100644 --- a/worker/job.go +++ b/worker/job.go @@ -3,6 +3,7 @@ package worker type Job interface { Err() error Data() []byte + Fn() string SendWarning(data []byte) SendData(data []byte) UpdateStatus(numerator, denominator int)