mirror of
https://github.com/open-policy-agent/opa.git
synced 2026-08-25 01:35:18 -06:00
Anders Eknert
61d3b7b64d
And many smaller performance improvements. The indexer recycling results is one of the most impactful performance improvements as of yet, and alone saves more than 2 million allocations in the Regal lint benchmark. The indexer is also more efficient, as `values` are no longer stored on the struct. Thanks @tsandall for that code! Also included a bunch of small improvements from my perf branches. **Before** ``` 1209043041 ns/op 3255157224 B/op 64026192 allocs/op ``` **After** ``` 1197131792 ns/op 3194124864 B/op 61876276 allocs/op ``` Signed-off-by: Anders Eknert <anders@styra.com>
72 lines
1.9 KiB
Go
72 lines
1.9 KiB
Go
// Copyright 2018 The OPA Authors. All rights reserved.
|
|
// Use of this source code is governed by an Apache2
|
|
// license that can be found in the LICENSE file.
|
|
|
|
// Package runtime contains utilities to return runtime information on the OPA instance.
|
|
package runtime
|
|
|
|
import (
|
|
"os"
|
|
"strings"
|
|
|
|
"github.com/open-policy-agent/opa/v1/ast"
|
|
"github.com/open-policy-agent/opa/v1/util"
|
|
"github.com/open-policy-agent/opa/v1/version"
|
|
)
|
|
|
|
// Params controls the types of runtime information to return.
|
|
type Params struct {
|
|
Config []byte
|
|
IsAuthorizationEnabled bool
|
|
SkipKnownSchemaCheck bool
|
|
}
|
|
|
|
var (
|
|
configKey = ast.StringTerm("config")
|
|
envKey = ast.StringTerm("env")
|
|
versionKey = ast.StringTerm("version")
|
|
commitKey = ast.StringTerm("commit")
|
|
authorizationEnabledKey = ast.StringTerm("authorization_enabled")
|
|
skipKnownSchemaCheckKey = ast.StringTerm("skip_known_schema_check")
|
|
)
|
|
|
|
// Term returns the runtime information as an ast.Term object.
|
|
func Term(params Params) (*ast.Term, error) {
|
|
|
|
obj := ast.NewObject()
|
|
|
|
if params.Config != nil {
|
|
|
|
var x interface{}
|
|
if err := util.Unmarshal(params.Config, &x); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
v, err := ast.InterfaceToValue(x)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
obj.Insert(configKey, ast.NewTerm(v))
|
|
}
|
|
|
|
env := ast.NewObject()
|
|
|
|
for _, s := range os.Environ() {
|
|
parts := strings.SplitN(s, "=", 2)
|
|
if len(parts) == 1 {
|
|
env.Insert(ast.StringTerm(parts[0]), ast.InternedNullTerm)
|
|
} else if len(parts) > 1 {
|
|
env.Insert(ast.StringTerm(parts[0]), ast.StringTerm(parts[1]))
|
|
}
|
|
}
|
|
|
|
obj.Insert(envKey, ast.NewTerm(env))
|
|
obj.Insert(versionKey, ast.StringTerm(version.Version))
|
|
obj.Insert(commitKey, ast.StringTerm(version.Vcs))
|
|
obj.Insert(authorizationEnabledKey, ast.InternedBooleanTerm(params.IsAuthorizationEnabled))
|
|
obj.Insert(skipKnownSchemaCheckKey, ast.InternedBooleanTerm(params.SkipKnownSchemaCheck))
|
|
|
|
return ast.NewTerm(obj), nil
|
|
}
|