watch_graph

type ArcAttrs struct {
	Controller              bool `json:"c,omitempty"`
	BlockOwnerDeletion      bool `json:"b,omitempty"`
	DestinationDoesNotExist bool `json:"e,omitempty"`
}

type ArcSet[VID, AT comparable] map[ArcToID[VID, AT]]struct{}

type ArcSetWithData[VID, AT comparable, AD any] map[ArcToID[VID, AT]]AD

type ArcToID[VID, AT comparable] struct {
	To      VID
	ArcType AT
}

type ArcType byte // enough bits to represent each arc type as an individual bit.

type ArcTypeSet ArcType

type Error struct {
	Message string
	Code    ErrorCode
}

type ErrorCode byte

type GraphInspector[VID, AT comparable, VD, AD any] interface {
	InboundArcsFor(VID) ArcSet[VID, AT]
	OutboundArcsFor(VID) ArcSetWithData[VID, AT, AD]
	VertexData(VID) (VD, bool)
}

type Namespaces struct {
	Names                    sets.Set[string]
	LabelSelector            string
	FieldSelector            string
	ObjectSelectorExpression cel.Program // can be nil
}

type ObjectGraph[VID, AT comparable, VD, AD any] struct {
	// contains filtered or unexported fields
}

type ObjectGraphObserver[VID, AT comparable, VD, AD any] interface {
	OnSetVertex(context.Context, GraphInspector[VID, AT, VD, AD], VID, VD)
	OnDeleteVertex(context.Context, GraphInspector[VID, AT, VD, AD], VID)
	OnSetArc(ctx context.Context, insp GraphInspector[VID, AT, VD, AD], from VID, to ArcToID[VID, AT], data AD)
	OnDeleteArc(ctx context.Context, insp GraphInspector[VID, AT, VD, AD], from VID, to ArcToID[VID, AT])
}

type ObjectGraphOpts[VID, AT comparable, VD, AD any] struct {
	IsVertexDataEqual func(a, b VD) bool
	IsArcDataEqual    func(a, b AD) bool
	Observer          ObjectGraphObserver[VID, AT, VD, AD]
}

type Opts struct {
	Log              *slog.Logger
	Queries          []any // Elements are QueryInclude or QueryExclude
	Namespaces       Namespaces
	DiscoClient      discovery.AggregatedDiscoveryInterface
	Client           dynamic.Interface
	NewBuilder       func() *resource.Builder
	OnWarning        func(Warning)
	ObjectToEvalVars func(*unstructured.Unstructured, schema.GroupVersionResource) map[string]any
	Graph            *ObjectGraph[VertexID, ArcType, VertexData, ArcAttrs]
}

type QueryExclude struct {
	ResourceSelectorExpression cel.Program // never nil
}

type QueryInclude struct {
	ResourceSelectorExpression cel.Program // never nil

	Object QueryIncludeObject
}

type QueryIncludeObject struct {
	LabelSelector            string
	FieldSelector            string
	ObjectSelectorExpression cel.Program        // can be nil
	JSONPath                 *jsonpath.JSONPath // can be nil
}

type SetVertexResult byte

type VertexData struct {
	Object      map[string]any     // do not mutate the contents of the map as this is the data from informer, not a copy.
	JSONPath    *jsonpath.JSONPath // nil if no JSON Path processing is necessary
	HelmRelease []byte
}

type VertexID struct {
	GVR       unique.Handle[schema.GroupVersionResource]
	Namespace string
	Name      string
}

type Warning struct {
	Type       string
	Message    string
	Attributes WarningAttrs
}

type WarningAttrs struct {
	Group     string `json:"g,omitempty"`
	Version   string `json:"v,omitempty"`
	Resource  string `json:"r,omitempty"`
	Namespace string `json:"ns,omitempty"`
	Name      string `json:"n,omitempty"`
}

type WatchGraph struct {
	// contains filtered or unexported fields
}