internals

Documentation

Index

• Constants
• func CreateBundle(manifestPath string, srcDir string) (string, error)
• func EstimateWorkers() uint
• func GetResult(r io.Reader) (bool, error)
• func RunTests(tests []TestUnit, workers uint, addr string) *TestReport
• func SendData(serverURL string, dataChan <-chan TestUnit, report *TestReport) error
• type OpaServer
  • func NewOpaContainer(ctx context.Context, bundlePath string) (*OpaServer, error)
  • func (s *OpaServer) GetEndpoint(endpoint string) (*http.Response, error)

Constants

const (
	// OpaImage is the Docker image to be used for tests.
	// TODO: make the OPA version a configuration value
	OpaImage     = "openpolicyagent/opa:0.47.4"
	OpaPort      = "8181"
	OpaBundleDir = "/etc/opa/bundles"
)

const (
	UrlSep = "/"
)

Functions

func CreateBundle

func CreateBundle(manifestPath string, srcDir string) (string, error)

CreateBundle takes a JSON Manifest and the path to a directory containing OPA Policies ( Rego files) and then generates an archive (`.tar.gz`) file according to OPA Bundle rules. It returns the full path to the temporary file.

func EstimateWorkers

func EstimateWorkers() uint

func GetResult

func GetResult(r io.Reader) (bool, error)

func RunTests

func RunTests(tests []TestUnit, workers uint, addr string) *TestReport

func SendData

func SendData(serverURL string, dataChan <-chan TestUnit, report *TestReport) error

Types

type OpaServer

type OpaServer struct {
	Address        string
	BundleFilepath string
	Container      testcontainers.Container
}

OpaServer represents the running server.

func NewOpaContainer

func NewOpaContainer(ctx context.Context, bundlePath string) (*OpaServer, error)

func (*OpaServer) GetEndpoint

func (s *OpaServer) GetEndpoint(endpoint string) (*http.Response, error)