try {
        // Send the patch to the cluster
        await K8s(PeprStore, { namespace, name: this.#name }).Patch(payload);
      } catch (err) {
        Log.error(err, "Pepr store update failure");

        // On failure to update, re-add the operations to the cache to be retried
        for (const idx of indexes) {
          sendCache[idx] = payload[Number(idx)];
        }
      }

import { Capability, Log, a } from "pepr";

export const HelloPepr = new Capability({
  name: "hello-pepr",
  description: "A simple example capability to show how things work.",
});

const { When, Store } = HelloPepr;

When(a.Pod)
  .IsCreatedOrUpdated()
  .WithLabel("removeItem")
  .Watch(() => {
    Log.info("Pod with timeout label");
    for (let i = 0; i < 20; i++) {
      Store.removeItem(`element-${i}`);
    }
  });


  When(a.Pod)
  .IsCreatedOrUpdated()
  .WithLabel("a")
  .Watch(() => {
    Log.info("Pod with timeout label");
    Store.setItem("a","a")
  });