add ctx store

mjudeikis · mjudeikis · commit c59901f0a262 · 2025-09-12T11:27:15.000+03:00
diff --git a/pkg/konnector/controllers/contextstore/contextstore.go b/pkg/konnector/controllers/contextstore/contextstore.go
@@ -36,7 +36,7 @@ func NewKey(export kubebindv1alpha2.APIServiceExport) Key {
 	return Key(export.Namespace + "/" + export.Name)
 }
 
-type ContextStore interface {
+type Store interface {
 	Get(key Key) (SyncContext, bool)
 	Set(key Key, value SyncContext)
 	Delete(key Key)
@@ -52,7 +52,7 @@ type SyncContext struct {
 	cancel     func()
 }
 
-func New() ContextStore {
+func New() Store {
 	return &contextStore{
 		store: make(map[Key]SyncContext),
 	}
@@ -62,6 +62,10 @@ func (c *SyncContext) Generation() int64 {
 	return c.generation
 }
 
+func (c *SyncContext) Cancel() {
+	c.cancel()
+}
+
 func (c *contextStore) Get(key Key) (SyncContext, bool) {
 	c.lock.Lock()
 	defer c.lock.Unlock()

Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ func NewKey(export kubebindv1alpha2.APIServiceExport) Key {`
`36`	`36`	`return Key(export.Namespace + "/" + export.Name)`
`37`	`37`	`}`
`38`	`38`
`39`		`-type ContextStore interface {`
	`39`	`+type Store interface {`
`40`	`40`	`Get(key Key) (SyncContext, bool)`
`41`	`41`	`Set(key Key, value SyncContext)`
`42`	`42`	`Delete(key Key)`
`@@ -52,7 +52,7 @@ type SyncContext struct {`
`52`	`52`	`cancel func()`
`53`	`53`	`}`
`54`	`54`
`55`		`-func New() ContextStore {`
	`55`	`+func New() Store {`
`56`	`56`	`return &contextStore{`
`57`	`57`	`store: make(map[Key]SyncContext),`
`58`	`58`	`}`
`@@ -62,6 +62,10 @@ func (c *SyncContext) Generation() int64 {`
`62`	`62`	`return c.generation`
`63`	`63`	`}`
`64`	`64`
	`65`	`+func (c *SyncContext) Cancel() {`
	`66`	`+ c.cancel()`
	`67`	`+}`
	`68`	`+`
`65`	`69`	`func (c *contextStore) Get(key Key) (SyncContext, bool) {`
`66`	`70`	`c.lock.Lock()`
`67`	`71`	`defer c.lock.Unlock()`