disk

Documentation

Index

• Constants
• type Conf
  • func GetConf() (*Conf, error)
  • func (conf *Conf) Key() string
• type Store
  • func NewFromIndex(idx index.Index) (*Store, error)
  • func NewFromIndexWithConf(idx index.Index, conf *Conf) *Store
  • func NewStore(ctx context.Context, conf *Conf) (*Store, error)
  • func (s *Store) Close() error
  • func (s *Store) Driver() string
  • func (s *Store) GetCompilationUnits(_ context.Context, ids ...namer.ModuleID) (map[namer.ModuleID]*policy.CompilationUnit, error)
  • func (s *Store) GetDependents(_ context.Context, ids ...namer.ModuleID) (map[namer.ModuleID][]namer.ModuleID, error)
  • func (s *Store) GetFirstMatch(_ context.Context, candidates []namer.ModuleID) (*policy.CompilationUnit, error)
  • func (s *Store) InspectPolicies(ctx context.Context, _ storage.ListPolicyIDsParams) (map[string]*responsev1.InspectPoliciesResponse_Result, error)
  • func (s *Store) ListPolicyIDs(ctx context.Context, _ storage.ListPolicyIDsParams) ([]string, error)
  • func (s *Store) ListSchemaIDs(ctx context.Context) ([]string, error)
  • func (s *Store) LoadPolicy(ctx context.Context, file ...string) ([]*policy.Wrapper, error)
  • func (s *Store) LoadSchema(ctx context.Context, url string) (io.ReadCloser, error)
  • func (s *Store) Reload(ctx context.Context) error
  • func (s *Store) RepoStats(ctx context.Context) storage.RepoStats

Constants

const DriverName = "disk"

Types

type Conf

type Conf struct {
	// Directory is the path on disk where policies are stored.
	Directory string `yaml:"directory" conf:"required,example=pkg/test/testdata/store"`
	// [DEPRECATED] ScratchDir is the directory to use for holding temporary data.
	ScratchDir string `yaml:"scratchDir" conf:",ignore"`
	// WatchForChanges enables watching the directory for changes.
	WatchForChanges bool `yaml:"watchForChanges" conf:"required,example=false"`
}

Conf is required (if driver is set to 'disk') configuration for disk storage driver. +desc=This section is required only if storage.driver is disk.

func GetConf

func GetConf() (*Conf, error)

func (*Conf) Key

func (conf *Conf) Key() string

type Store

type Store struct {
	*storage.SubscriptionManager
	// contains filtered or unexported fields
}

func NewFromIndex

func NewFromIndex(idx index.Index) (*Store, error)

func NewFromIndexWithConf

func NewFromIndexWithConf(idx index.Index, conf *Conf) *Store

func NewStore

func NewStore(ctx context.Context, conf *Conf) (*Store, error)

func (*Store) Close

func (s *Store) Close() error

func (*Store) Driver

func (s *Store) Driver() string

func (*Store) GetCompilationUnits

func (s *Store) GetCompilationUnits(_ context.Context, ids ...namer.ModuleID) (map[namer.ModuleID]*policy.CompilationUnit, error)

func (*Store) GetDependents

func (s *Store) GetDependents(_ context.Context, ids ...namer.ModuleID) (map[namer.ModuleID][]namer.ModuleID, error)

func (*Store) GetFirstMatch

func (s *Store) GetFirstMatch(_ context.Context, candidates []namer.ModuleID) (*policy.CompilationUnit, error)

func (*Store) InspectPolicies

func (s *Store) InspectPolicies(ctx context.Context, _ storage.ListPolicyIDsParams) (map[string]*responsev1.InspectPoliciesResponse_Result, error)

func (*Store) ListPolicyIDs

func (s *Store) ListPolicyIDs(ctx context.Context, _ storage.ListPolicyIDsParams) ([]string, error)

func (*Store) ListSchemaIDs

func (s *Store) ListSchemaIDs(ctx context.Context) ([]string, error)

func (*Store) LoadPolicy

func (s *Store) LoadPolicy(ctx context.Context, file ...string) ([]*policy.Wrapper, error)

func (*Store) LoadSchema

func (s *Store) LoadSchema(ctx context.Context, url string) (io.ReadCloser, error)

func (*Store) Reload

func (s *Store) Reload(ctx context.Context) error

func (*Store) RepoStats

func (s *Store) RepoStats(ctx context.Context) storage.RepoStats