memorize

type Descriptor struct {
	Resource     string    `json:"resource"`
	Kind         string    `json:"kind"`
	Source       string    `json:"source"`
	Destination  string    `json:"destination"`
	Metas        ListMetas `json:"metas"`
	GroupVersion string    `json:"groupVersion,omitempty"` // if empty, use default
}

type FuncReaderWriter struct {
	WriteFunc func(runtime.Object) error
	WrapFunc  func(parent runtime.Object, parentGvk schema.GroupVersionKind, obj runtime.Object) (runtime.Object, error)
	ListFunc  func(runtime.Object, ListMetas) ([]runtime.Object, error)
	Name      string
}

type ListMetas struct {
	Selectors map[string]string `json:"selectors,omitempty"`
	Config    map[string]string `json:"config,omitempty"`
}

type Node struct {
	Reader Reader
	Writer Writer
	Gvk    schema.GroupVersionKind
	Metas  ListMetas
}

type NodeProcessor struct {
	Node
	// contains filtered or unexported fields
}

type NopReaderWriter struct {
}

type ProcessOptions struct {
	Dry        bool
	NumWorkers int
}

type Reader interface {
	List(parent runtime.Object, metas ListMetas) ([]runtime.Object, error)
}

type ReaderWriter interface {
	Writer
	Reader
}

type ReaderWriterCreator func(gvr schema.GroupVersionResource) ReaderWriterPair

type ReaderWriterPair struct {
	KubeReaderWriter ReaderWriter
	MemReaderWriter  ReaderWriter
}

type SelectorProvider interface {
	Selector(ListMetas, runtime.Object) (string, error)
}

type Writer interface {
	Write(runtime.Object) error
	Wrap(parent runtime.Object, parentGvk schema.GroupVersionKind, obj runtime.Object) (runtime.Object, error)
}