watch_graph

type ArcData []byte

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

type ArcType byte

type Error struct {
	Message string
	Code    ErrorCode
}

type ErrorCode byte

type Namespaces struct {
	Names                    []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 ObjectGraphOpts[VID, AT comparable, VD, AD any] struct {
	IsVertexDataEqual func(a, b VD) bool
	IsArcDataEqual    func(a, b AD) bool

	OnSetVertex    func(VID, VD)
	OnDeleteVertex func(VID)
	OnSetArc       func(from VID, to ArcToID[VID, AT], data AD)
	OnDeleteArc    func(from VID, to ArcToID[VID, AT])
}

type Opts struct {
	Log         *slog.Logger
	Queries     []any // Elements are QueryInclude or QueryExclude
	Namespaces  Namespaces
	Roots       *rpc.Roots // can be nil
	RPCAPI      modshared.RPCAPI
	DiscoClient discovery.AggregatedDiscoveryInterface
	Client      dynamic.Interface
	OnWarning   func(Warning)
	Graph       *ObjectGraph[VertexID, ArcType, VertexData, ArcData]
}

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 VertexData struct {
	Object   []byte
	JSONPath []byte
}

type VertexID struct {
	GVR       schema.GroupVersionResource
	Namespace string
	Name      string
}

type Warning struct {
	Type       string
	Message    string
	Attributes map[string]any
}

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