Function newAnnotationsResolver

runtime/resolvers/annotations.go:30–74

(ctx context.Context, opts *runtime.ResolverOptions)

}

func newAnnotationsResolver(ctx context.Context, opts *runtime.ResolverOptions) (runtime.Resolver, error) {
	qry := &metricsview.AnnotationsQuery{}
	if err := mapstructureutil.WeakDecode(opts.Properties, qry); err != nil {
		return nil, err
	}

	ctrl, err := opts.Runtime.Controller(ctx, opts.InstanceID)
	if err != nil {
		return nil, err
	}

	res, err := ctrl.Get(ctx, &runtimev1.ResourceName{Kind: runtime.ResourceKindMetricsView, Name: qry.MetricsView}, false)
	if err != nil {
		return nil, err
	}

	mv := res.GetMetricsView().State.ValidSpec
	if mv == nil {
		return nil, fmt.Errorf("metrics view %q is invalid", res.Meta.Name.Name)
	}

	security, err := opts.Runtime.ResolveSecurity(ctx, opts.InstanceID, opts.Claims, res)
	if err != nil {
		return nil, err
	}

	var userAttrs map[string]any
	if opts.Claims != nil {
		userAttrs = opts.Claims.UserAttributes
	}

	ex, err := executor.New(ctx, opts.Runtime, opts.InstanceID, mv, false, security, qry.Priority, userAttrs)
	if err != nil {
		return nil, err
	}

	return &metricsAnnotationsResolver{
		instanceID: opts.InstanceID,
		query:      qry,
		mv:         mv,
		executor:   ex,
		runtime:    opts.Runtime,
		claims:     opts.Claims,
	}, nil
}

func (r *metricsAnnotationsResolver) Close() error {
	r.executor.Close()