executor

type Client struct {
	Dynamic      dynamic.Interface
	Discovery    discovery.DiscoveryInterface
	FieldManager string
}

type Factory func(api.ServiceAccountReference, types.UID) (Interface, error)

type Interface interface {
	List(context.Context, policy.Target, string) ([]unstructured.Unstructured, error)
	Get(context.Context, Participant, string) (*unstructured.Unstructured, error)
	Prepare(context.Context, Participant, *api.ActionStep, map[string]any) (*Prepared, error)
	Apply(context.Context, Participant, *Prepared, string) (bool, error)
}

type Participant struct {
	Resource   schema.GroupVersionResource `json:"resource"`
	APIVersion string                      `json:"apiVersion"`
	Kind       string                      `json:"kind"`
	Namespace  string                      `json:"namespace"`
	Name       string                      `json:"name"`
	UID        types.UID                   `json:"uid"`
	Action     string                      `json:"action"`
	Captured   map[string]json.RawMessage  `json:"captured,omitempty"`
	Start      *Prepared                   `json:"start,omitempty"`
	End        *Prepared                   `json:"end,omitempty"`
	// Attempted is persisted before applying; a lost response still requires restore.
	Attempted bool `json:"attempted,omitempty"`
	Started   bool `json:"started,omitempty"`
	Finished  bool `json:"finished,omitempty"`
}

type Prepared struct {
	Subresource string         `json:"subresource,omitempty"`
	Force       bool           `json:"force,omitempty"`
	Object      map[string]any `json:"object"`
}