(payload interface{})
| 65 | } |
| 66 | |
| 67 | func WithPayload(payload interface{}) ManagerOption { |
| 68 | return func(o *managerOptions) error { |
| 69 | var b bytes.Buffer |
| 70 | if err := json.NewEncoder(&b).Encode(payload); err != nil { |
| 71 | return errors.WithStack(err) |
| 72 | } |
| 73 | o.payload = b.Bytes() |
| 74 | o.payloadRaw = payload |
| 75 | return nil |
| 76 | } |
| 77 | } |
| 78 | |
| 79 | func WithExpireInsteadOfDelete(duration time.Duration) ManagerOption { |
| 80 | return func(o *managerOptions) error { |