@@ -70,6 +70,7 @@ func (d *Client) Update(ctx context.Context, args Task) error {
7070 d .mu .Lock ()
7171 defer d .mu .Unlock ()
7272 deleteConfigs := d .ConfigManager .Update (args .Key , args .Configs )
73+ d .ConfigManager .Delete (args .Key )
7374
7475 for _ , config := range deleteConfigs {
7576 if err := d .Store .Delete (config .Name , args .ResourceTypes , args .Labels ); err != nil {
@@ -109,7 +110,6 @@ func (d *Client) UpdateConfig(ctx context.Context, args Task) error {
109110 d .mu .Lock ()
110111 defer d .mu .Unlock ()
111112 deleteConfigs := d .ConfigManager .Update (args .Key , args .Configs )
112- d .ConfigManager .Delete (args .Key )
113113
114114 for _ , config := range deleteConfigs {
115115 if err := d .Store .Delete (config .Name , args .ResourceTypes , args .Labels ); err != nil {
@@ -138,6 +138,7 @@ func (d *Client) Delete(ctx context.Context, args Task) error {
138138 defer d .mu .Unlock ()
139139
140140 configs := d .ConfigManager .Get (args .Key )
141+ d .ConfigManager .Delete (args .Key )
141142
142143 for _ , config := range configs {
143144 if err := d .Store .Delete (config .Name , args .ResourceTypes , args .Labels ); err != nil {
@@ -160,7 +161,10 @@ func (d *Client) DeleteConfig(ctx context.Context, args Task) error {
160161 d .mu .Lock ()
161162 defer d .mu .Unlock ()
162163
163- for _ , config := range args .Configs {
164+ configs := d .ConfigManager .Get (args .Key )
165+ d .ConfigManager .Delete (args .Key )
166+
167+ for _ , config := range configs {
164168 if err := d .Store .Delete (config .Name , args .ResourceTypes , args .Labels ); err != nil {
165169 log .Errorw ("failed to delete resources from store" ,
166170 zap .String ("name" , config .Name ),
0 commit comments