statemanager.go 7.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279
  1. /*
  2. Copyright © 2025 ESO Maintainer Team
  3. Licensed under the Apache License, Version 2.0 (the "License");
  4. you may not use this file except in compliance with the License.
  5. You may obtain a copy of the License at
  6. https://www.apache.org/licenses/LICENSE-2.0
  7. Unless required by applicable law or agreed to in writing, software
  8. distributed under the License is distributed on an "AS IS" BASIS,
  9. WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  10. See the License for the specific language governing permissions and
  11. limitations under the License.
  12. */
  13. // Package statemanager provides functionality for managing state of generator operations.
  14. package statemanager
  15. import (
  16. "context"
  17. "errors"
  18. "fmt"
  19. "strings"
  20. "time"
  21. "github.com/spf13/pflag"
  22. apiextensions "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
  23. metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  24. "k8s.io/apimachinery/pkg/runtime"
  25. "sigs.k8s.io/controller-runtime/pkg/client"
  26. "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
  27. genapi "github.com/external-secrets/external-secrets/apis/generators/v1alpha1"
  28. "github.com/external-secrets/external-secrets/pkg/esutils"
  29. "github.com/external-secrets/external-secrets/pkg/feature"
  30. )
  31. // Manager takes care of maintaining the state of the generators.
  32. // It provides the ability to commit and rollback the state of the generators,
  33. // which is needed when we have multiple generators that need to be created or
  34. // other operations which can fail.
  35. type Manager struct {
  36. ctx context.Context
  37. scheme *runtime.Scheme
  38. client client.Client
  39. namespace string
  40. resource genapi.StatefulResource
  41. queue []QueueItem
  42. }
  43. // QueueItem represents a single item in the state manager's queue.
  44. type QueueItem struct {
  45. Rollback func() error
  46. Commit func() error
  47. }
  48. var gcGracePeriod time.Duration
  49. func init() {
  50. fs := pflag.NewFlagSet("gc", pflag.ExitOnError)
  51. fs.DurationVar(&gcGracePeriod, "generator-gc-grace-period", time.Minute*2, "Duration after which generated secrets are cleaned up after they have been flagged for gc.")
  52. feature.Register(feature.Feature{
  53. Flags: fs,
  54. })
  55. }
  56. // New creates a new state manager instance with the given configuration.
  57. func New(ctx context.Context, client client.Client, scheme *runtime.Scheme, namespace string,
  58. resource genapi.StatefulResource) *Manager {
  59. return &Manager{
  60. ctx: ctx,
  61. scheme: scheme,
  62. client: client,
  63. namespace: namespace,
  64. resource: resource,
  65. }
  66. }
  67. // Rollback will rollback the enqueued operations.
  68. func (m *Manager) Rollback() error {
  69. var errs []error
  70. for _, item := range m.queue {
  71. if item.Rollback == nil {
  72. continue
  73. }
  74. if err := item.Rollback(); err != nil {
  75. errs = append(errs, err)
  76. }
  77. }
  78. return errors.Join(errs...)
  79. }
  80. // Commit will apply the enqueued changes to the state of the generators.
  81. func (m *Manager) Commit() error {
  82. var errs []error
  83. for _, item := range m.queue {
  84. if item.Commit == nil {
  85. continue
  86. }
  87. if err := item.Commit(); err != nil {
  88. errs = append(errs, err)
  89. }
  90. }
  91. return errors.Join(errs...)
  92. }
  93. // EnqueueFlagLatestStateForGC will flag the latest state for garbage collection after Commit.
  94. // It will be cleaned up later by the garbage collector.
  95. func (m *Manager) EnqueueFlagLatestStateForGC(stateKey string) {
  96. m.queue = append(m.queue, QueueItem{
  97. Commit: func() error {
  98. return m.disposeState(stateKey)
  99. },
  100. })
  101. }
  102. // EnqueueMoveStateToGC will move the generator state to GC if Commit() is called.
  103. func (m *Manager) EnqueueMoveStateToGC(stateKey string) {
  104. m.queue = append(m.queue, QueueItem{
  105. Commit: func() error {
  106. return m.disposeState(stateKey)
  107. },
  108. })
  109. }
  110. // EnqueueSetLatest sets the latest state for the given key.
  111. // It will commit the state on success or move the state to GC on failure.
  112. func (m *Manager) EnqueueSetLatest(ctx context.Context, stateKey, namespace string, resource *apiextensions.JSON, gen genapi.Generator, state genapi.GeneratorProviderState) {
  113. if state == nil {
  114. return
  115. }
  116. m.queue = append(m.queue, QueueItem{
  117. // Stores the state in GeneratorState resource
  118. Commit: func() error {
  119. genState, err := m.createGeneratorState(resource, state, namespace, stateKey)
  120. if err != nil {
  121. return err
  122. }
  123. return m.client.Create(ctx, genState)
  124. },
  125. // Rollback by cleaning up the state.
  126. // In case of failure, create a new GeneratorState, so it will eventually be cleaned up.
  127. // If that also fails we're out of luck :(
  128. Rollback: func() error {
  129. err := gen.Cleanup(ctx, resource, state, m.client, namespace)
  130. if err == nil {
  131. return nil
  132. }
  133. genState, err := m.createGeneratorState(resource, state, namespace, stateKey)
  134. if err != nil {
  135. return err
  136. }
  137. genState.Spec.GarbageCollectionDeadline = &metav1.Time{
  138. Time: time.Now(),
  139. }
  140. return m.client.Create(ctx, genState)
  141. },
  142. })
  143. }
  144. func (m *Manager) createGeneratorState(resource *apiextensions.JSON, state genapi.GeneratorProviderState, namespace, stateKey string) (*genapi.GeneratorState, error) {
  145. genState := &genapi.GeneratorState{
  146. ObjectMeta: metav1.ObjectMeta{
  147. GenerateName: fmt.Sprintf("gen-%s-%s-", strings.ToLower(m.resource.GetObjectKind().GroupVersionKind().Kind), m.resource.GetName()),
  148. Namespace: namespace,
  149. Labels: map[string]string{
  150. genapi.GeneratorStateLabelOwnerKey: ownerKey(
  151. m.resource,
  152. stateKey,
  153. ),
  154. },
  155. },
  156. Spec: genapi.GeneratorStateSpec{
  157. Resource: resource,
  158. State: state,
  159. },
  160. }
  161. if err := controllerutil.SetOwnerReference(m.resource, genState, m.scheme); err != nil {
  162. return nil, err
  163. }
  164. return genState, nil
  165. }
  166. func ownerKey(resource genapi.StatefulResource, key string) string {
  167. return esutils.ObjectHash(fmt.Sprintf("%s-%s-%s-%s",
  168. resource.GetObjectKind().GroupVersionKind().Kind,
  169. resource.GetNamespace(),
  170. resource.GetName(),
  171. key),
  172. )
  173. }
  174. func (m *Manager) disposeState(key string) error {
  175. allStates, err := m.GetAllStates(key)
  176. if err != nil {
  177. return err
  178. }
  179. latest := getLatest(allStates)
  180. if latest == nil {
  181. return nil
  182. }
  183. // flag all states for GC except the latest one
  184. // This is to ensure that all "old" states are eventually cleaned up.
  185. // This is needed due to fast reconciles and working with stale cache.
  186. var errs []error
  187. for _, state := range allStates {
  188. if state.Name == latest.Name {
  189. continue
  190. }
  191. if state.Spec.GarbageCollectionDeadline != nil {
  192. continue
  193. }
  194. state.Spec.GarbageCollectionDeadline = &metav1.Time{
  195. Time: time.Now().Add(gcGracePeriod),
  196. }
  197. if err := m.client.Update(m.ctx, &state); err != nil {
  198. errs = append(errs, err)
  199. }
  200. }
  201. return errors.Join(errs...)
  202. }
  203. // GetAllStates retrieves all the stored states for the given key.
  204. func (m *Manager) GetAllStates(key string) ([]genapi.GeneratorState, error) {
  205. var stateList genapi.GeneratorStateList
  206. if err := m.client.List(m.ctx, &stateList, &client.MatchingLabels{
  207. genapi.GeneratorStateLabelOwnerKey: ownerKey(
  208. m.resource,
  209. key,
  210. ),
  211. }, client.InNamespace(m.namespace)); err != nil {
  212. return nil, err
  213. }
  214. return stateList.Items, nil
  215. }
  216. // GetLatestState returns the latest state for the given key.
  217. func (m *Manager) GetLatestState(key string) (*genapi.GeneratorState, error) {
  218. var stateList genapi.GeneratorStateList
  219. if err := m.client.List(m.ctx, &stateList, &client.MatchingLabels{
  220. genapi.GeneratorStateLabelOwnerKey: ownerKey(
  221. m.resource,
  222. key,
  223. ),
  224. }, client.InNamespace(m.namespace)); err != nil {
  225. return nil, err
  226. }
  227. if latestState := getLatest(stateList.Items); latestState != nil {
  228. return latestState, nil
  229. }
  230. return nil, nil
  231. }
  232. func getLatest(stateList []genapi.GeneratorState) *genapi.GeneratorState {
  233. var latest *genapi.GeneratorState
  234. for _, state := range stateList {
  235. // if the state is already flagged for GC, skip it
  236. // It can happen that the latest based on creation timestamp is already flagged for GC.
  237. // That is the case when a rollback was performed.
  238. if state.Spec.GarbageCollectionDeadline != nil {
  239. continue
  240. }
  241. if latest == nil {
  242. latest = &state
  243. continue
  244. }
  245. if state.CreationTimestamp.After(latest.CreationTimestamp.Time) {
  246. latest = &state
  247. }
  248. }
  249. return latest
  250. }