diff --git a/docs/client.rst b/docs/client.rst index a147540..f93dec4 100644 --- a/docs/client.rst +++ b/docs/client.rst @@ -40,6 +40,9 @@ // set delay time taskId,err=client.SetTaskCtl(client.RunAfter, 2*time.Second).Send("group1","add",12,33) + // set expire time + taskId,err=client.SetTaskCtl(client.ExpireTime,time.Now().Add(4*time.Second)).Send("group1","add",12,33) + 获取结果 ---------- diff --git a/docs/expire.rst b/docs/expire.rst new file mode 100644 index 0000000..f9420b5 --- /dev/null +++ b/docs/expire.rst @@ -0,0 +1,15 @@ +任务过期时间 +============== + +目前只支持在client端设置过期时间,若任务发生重试且重试开始的时间超过了过期时间,任务会直接终止 + +.. code:: go + + taskId, err :=client.SetTaskCtl(client.ExpireTime,time.Now().Add(4*time.Second)).Send("group1","add",12,33) + + result, _ := client.GetResult(taskId, 2*time.Second, 300*time.Millisecond) + + if result.Status == message.ResultStatus.Expired{ + // do ... + } +