test
This commit is contained in:
parent
7358ca67e8
commit
a857268e29
3
job.go
3
job.go
@ -19,7 +19,8 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
func createJob(jobTypeID64 int64, priority int32, userID64 int64, trigger int64, schedule time.Time, payload []byte) (int64, error) {
|
func createJob(jobTypeID64 int64, priority int32, userID64 int64, trigger int64, schedule time.Time, payload []byte) (int64, error) {
|
||||||
zb := new(bytes.Buffer)
|
var zb bytes.Buffer
|
||||||
|
|
||||||
zw := zlib.NewWriter(&zb)
|
zw := zlib.NewWriter(&zb)
|
||||||
zw.Write(payload)
|
zw.Write(payload)
|
||||||
zw.Close()
|
zw.Close()
|
||||||
|
Loading…
Reference in New Issue
Block a user