add forget

rabbull · rabbull · commit 42335d79c696 · 2022-01-26T00:39:01.000+08:00
diff --git a/flight.go b/flight.go
@@ -14,6 +14,7 @@ type Job func() []byte
 
 type Group interface {
 	Do(jobKey string, job Job) (result []byte, shared bool, err error)
+	Forget(jobKey string) (err error)
 }
 
 func New(opt Option) Group {
@@ -141,3 +142,7 @@ func (f *groupImpl) tryFetchResult(dataKey string) ([]byte, bool, error) {
 	}
 	return sharedResult, true, nil
 }
+
+func (f *groupImpl) Forget(jobKey string) error {
+	return f.client.Del(f.makeLockKey(jobKey))
+}

Original file line number	Diff line number	Diff line change
`@@ -14,6 +14,7 @@ type Job func() []byte`
`14`	`14`
`15`	`15`	`type Group interface {`
`16`	`16`	`Do(jobKey string, job Job) (result []byte, shared bool, err error)`
	`17`	`+ Forget(jobKey string) (err error)`
`17`	`18`	`}`
`18`	`19`
`19`	`20`	`func New(opt Option) Group {`
`@@ -141,3 +142,7 @@ func (f *groupImpl) tryFetchResult(dataKey string) ([]byte, bool, error) {`
`141`	`142`	`}`
`142`	`143`	`return sharedResult, true, nil`
`143`	`144`	`}`
	`145`	`+`
	`146`	`+func (f *groupImpl) Forget(jobKey string) error {`
	`147`	`+ return f.client.Del(f.makeLockKey(jobKey))`
	`148`	`+}`