storage

type BinaryStore interface {
	Store
	Subscribable
	// GetFirstMatch searches for the given module IDs in order and returns the first one found.
	GetFirstMatch(context.Context, []namer.ModuleID) (*runtimev1.RunnablePolicySet, error)
	// GetAll returns all modules that exist within the policy store
	GetAll(context.Context) ([]*runtimev1.RunnablePolicySet, error)
	// GetAllMatching returns all modules that exist for the provided module IDs
	GetAllMatching(context.Context, []namer.ModuleID) ([]*runtimev1.RunnablePolicySet, error)
}

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

type Constructor func(context.Context, *config.Wrapper) (Store, error)

type Event struct {
	OldPolicyID *namer.ModuleID
	SchemaFile  string
	Dependents  []namer.ModuleID
	Kind        EventKind
	PolicyID    namer.ModuleID
}

type EventKind int

type Instrumented interface {
	RepoStats(context.Context) RepoStats
}

type InvalidPolicyError struct {
	Err     error
	Message string
}

type InvalidSchemaError struct {
	Err     error
	Message string
}

type ListPolicyIDsParams struct {
	NameRegexp      string
	ScopeRegexp     string
	VersionRegexp   string
	IDs             []string
	IncludeDisabled bool
}

type MutableStore interface {
	Store
	AddOrUpdate(context.Context, ...policy.Wrapper) error
	AddOrUpdateSchema(context.Context, ...*schemav1.Schema) error
	Disable(context.Context, ...string) (uint32, error)
	Enable(context.Context, ...string) (uint32, error)
	DeleteSchema(context.Context, ...string) (uint32, error)
	Delete(context.Context, ...namer.ModuleID) error
}

type Reloadable interface {
	Reload(context.Context) error
}

type RepoStats struct {
	PolicyCount       map[policy.Kind]int
	AvgRuleCount      map[policy.Kind]float64
	AvgConditionCount map[policy.Kind]float64
	SchemaCount       int
}

type RuleTableStore interface {
	GetRuleTable() (*runtimev1.RuleTable, error)
}

type SourceStore interface {
	Store
	// GetFirstMatch searches for the given module IDs in order and returns the first one found.
	GetFirstMatch(context.Context, []namer.ModuleID) (*policy.CompilationUnit, error)
	// GetAll returns all modules that exist within the policy store
	GetAll(context.Context) ([]*policy.CompilationUnit, error)
	// GetAllMatching returns all modules that exist for the provided module IDs
	GetAllMatching(context.Context, []namer.ModuleID) ([]*policy.CompilationUnit, error)
	// GetCompilationUnits gets the compilation units for the given module IDs.
	GetCompilationUnits(context.Context, ...namer.ModuleID) (map[namer.ModuleID]*policy.CompilationUnit, error)
	// GetDependents returns the dependents of the given modules.
	GetDependents(context.Context, ...namer.ModuleID) (map[namer.ModuleID][]namer.ModuleID, error)
	// LoadPolicy loads the given policy from the store
	LoadPolicy(context.Context, ...string) ([]*policy.Wrapper, error)
}

type Store interface {
	// Driver is the name of the storage backend implementation.
	Driver() string
	// InspectPolicies returns inspection results for the policies in the store.
	InspectPolicies(context.Context, ListPolicyIDsParams) (map[string]*responsev1.InspectPoliciesResponse_Result, error)
	// ListPolicyIDs returns the policy IDs in the store.
	ListPolicyIDs(context.Context, ListPolicyIDsParams) ([]string, error)
	// ListSchemaIDs returns the schema ids in the store.
	ListSchemaIDs(context.Context) ([]string, error)
	// LoadSchema loads the given schema from the store.
	LoadSchema(context.Context, string) (io.ReadCloser, error)
	// Source returns metadata for inclusion in audit logs.
	Source() *auditv1.PolicySource
}

type Subscribable interface {
	// Subscribe adds a subscriber to listen for storage notifications.
	Subscribe(Subscriber)
	// Unsubscribe removes a subscriber.
	Unsubscribe(Subscriber)
}

type Subscriber interface {
	SubscriberID() string
	OnStorageEvent(...Event)
}

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

type Verifiable interface {
	CheckSchema(ctx context.Context) error
}