index

Documentation

Index

• Variables
• type BuildError
  • func (ibe *BuildError) Error() string
• type BuildOpt
  • func WithBuildFailureLogLevel(level zapcore.Level) BuildOpt
  • func WithRootDir(rootDir string) BuildOpt
  • func WithSourceAttributes(attrs ...policy.SourceAttribute) BuildOpt
• type Entry
• type Index
  • func Build(ctx context.Context, fsys fs.FS, opts ...BuildOpt) (Index, error)
• type ModuleIDSet
• type SchemaLoader
  • func NewSchemaLoader(fsys fs.FS, rootDir string) *SchemaLoader
  • func (sl *SchemaLoader) ListIDs(_ context.Context) ([]string, error)
  • func (sl *SchemaLoader) Load(_ context.Context, id string) (io.ReadCloser, error)

Variables

var (
	// ErrDuplicatePolicy signals that there are duplicate policy definitions.
	ErrDuplicatePolicy = errors.New("duplicate policy definitions")
	// ErrInvalidEntry signals that the index entry is invalid.
	ErrInvalidEntry = errors.New("invalid index entry")
	// ErrPolicyNotFound signals that the policy does not exist.
	ErrPolicyNotFound = errors.New("policy not found")
)

Types

type BuildError

type BuildError struct {
	*runtimev1.IndexBuildErrors
	// contains filtered or unexported fields
}

BuildError is an error type that contains details about the failures encountered during the index build.

func (*BuildError) Error

func (ibe *BuildError) Error() string

type BuildOpt

type BuildOpt func(*buildOptions)

func WithBuildFailureLogLevel

func WithBuildFailureLogLevel(level zapcore.Level) BuildOpt

func WithRootDir

func WithRootDir(rootDir string) BuildOpt

func WithSourceAttributes

func WithSourceAttributes(attrs ...policy.SourceAttribute) BuildOpt

type Entry

type Entry struct {
	File   string
	Policy policy.Wrapper
}

type Index

type Index interface {
	io.Closer
	storage.Instrumented
	GetFirstMatch([]namer.ModuleID) (*policy.CompilationUnit, error)
	GetCompilationUnits(...namer.ModuleID) (map[namer.ModuleID]*policy.CompilationUnit, error)
	GetDependents(...namer.ModuleID) (map[namer.ModuleID][]namer.ModuleID, error)
	AddOrUpdate(Entry) (storage.Event, error)
	Delete(Entry) (storage.Event, error)
	GetFiles() []string
	GetAllCompilationUnits(context.Context) <-chan *policy.CompilationUnit
	Clear() error
	InspectPolicies(context.Context) (map[string]*responsev1.InspectPoliciesResponse_Result, error)
	ListPolicyIDs(context.Context) ([]string, error)
	ListSchemaIDs(context.Context) ([]string, error)
	LoadSchema(context.Context, string) (io.ReadCloser, error)
	LoadPolicy(context.Context, ...string) ([]*policy.Wrapper, error)
	Reload(ctx context.Context) ([]storage.Event, error)
}

func Build

func Build(ctx context.Context, fsys fs.FS, opts ...BuildOpt) (Index, error)

Build builds an index from the policy files stored in a directory.

type ModuleIDSet

type ModuleIDSet map[namer.ModuleID]struct{}

type SchemaLoader

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

func NewSchemaLoader

func NewSchemaLoader(fsys fs.FS, rootDir string) *SchemaLoader

func (*SchemaLoader) ListIDs

func (sl *SchemaLoader) ListIDs(_ context.Context) ([]string, error)

func (*SchemaLoader) Load

func (sl *SchemaLoader) Load(_ context.Context, id string) (io.ReadCloser, error)