bundle

Apr 9, 2024

Changes in this version

type Bundle

+ func (b *Bundle) InspectPolicies(ctx context.Context, listParams storage.ListPolicyIDsParams) (map[string]*responsev1.InspectPoliciesResponse_Result, error)

type HybridStore

+ func (hs *HybridStore) InspectPolicies(ctx context.Context, params storage.ListPolicyIDsParams) (map[string]*responsev1.InspectPoliciesResponse_Result, error)

type LocalSource

+ func (ls *LocalSource) InspectPolicies(ctx context.Context, params storage.ListPolicyIDsParams) (map[string]*responsev1.InspectPoliciesResponse_Result, error)

type RemoteSource

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

Oct 31, 2023

Changes in this version

type CredentialsConf

+ PDPID string

+ WorkspaceSecret string

Sep 13, 2023

Changes in this version

type Bundle

+ func (b *Bundle) Close() error

type Conf

+ CacheSize uint

type HybridStore

+ func (hs *HybridStore) Close() (outErr error)

type LocalParams

+ CacheSize uint

type OpenOpts

+ CacheSize uint

+ Source string

type RemoteSource

+ func (s *RemoteSource) Close() error

Jul 18, 2023

Changes in this version

type Bundle

+ func (b *Bundle) GetFirstMatch(_ context.Context, candidates []namer.ModuleID) (*runtimev1.RunnablePolicySet, error)

type HybridStore

+ func (hs *HybridStore) GetFirstMatch(ctx context.Context, candidates []namer.ModuleID) (*runtimev1.RunnablePolicySet, error)

type LocalSource

+ func (ls *LocalSource) GetFirstMatch(ctx context.Context, candidates []namer.ModuleID) (ps *runtimev1.RunnablePolicySet, err error)

type RemoteSource

+ func (s *RemoteSource) GetFirstMatch(ctx context.Context, candidates []namer.ModuleID) (*runtimev1.RunnablePolicySet, error)

Jun 7, 2023

Changes in this version

type HybridStore

+ func (hs *HybridStore) SourceKind() string

type LocalSource

+ func (ls *LocalSource) SourceKind() string

type RemoteSource

+ func (s *RemoteSource) SourceKind() string

+ type Source interface

+ SourceKind func() string

Apr 17, 2023

Changes in this version

+ const DriverName

+ var ErrBundleNotLoaded = errors.New("bundle not loaded yet")

+ var ErrNoSource = errors.New("at least one of local or remote sources must be defined")

+ func NewStore(ctx context.Context, conf *Conf) (storage.BinaryStore, error)

+ type Bundle struct

+ func Open(opts OpenOpts) (*Bundle, error)

+ func (b *Bundle) GetPolicySet(_ context.Context, id namer.ModuleID) (*runtimev1.RunnablePolicySet, error)

+ func (b *Bundle) ListPolicyIDs(_ context.Context, _ bool) ([]string, error)

+ func (b *Bundle) ListSchemaIDs(_ context.Context) ([]string, error)

+ func (b *Bundle) LoadSchema(_ context.Context, path string) (io.ReadCloser, error)

+ func (b *Bundle) Release() error

+ type CloudAPIClient interface

+ BootstrapBundle func(context.Context, string) (string, error)

+ GetBundle func(context.Context, string) (string, error)

+ GetCachedBundle func(string) (string, error)

+ WatchBundle func(context.Context, string) (cloudapi.WatchHandle, error)

+ type Conf struct

+ Credentials CredentialsConf

+ Local *LocalSourceConf

+ Remote *RemoteSourceConf

+ func GetConf() (*Conf, error)

+ func (conf *Conf) Key() string

+ func (conf *Conf) SetDefaults()

+ func (conf *Conf) Validate() (outErr error)

+ type ConnectionConf struct

+ APIEndpoint string

+ BootstrapEndpoint string

+ HeartbeatInterval time.Duration

+ MaxRetryWait time.Duration

+ MinRetryWait time.Duration

+ NumRetries uint

+ TLS TLSConf

+ type CredentialsConf struct

+ ClientID string

+ ClientSecret string

+ InstanceID string

+ SecretKey string

+ func (cc CredentialsConf) ToCredentials() (*credentials.Credentials, error)

+ type HybridStore struct

+ func (*HybridStore) Driver() string

+ func (hs *HybridStore) GetPolicySet(ctx context.Context, id namer.ModuleID) (*runtimev1.RunnablePolicySet, error)

+ func (hs *HybridStore) ListPolicyIDs(ctx context.Context, includeDisabled bool) ([]string, error)

+ func (hs *HybridStore) ListSchemaIDs(ctx context.Context) ([]string, error)

+ func (hs *HybridStore) LoadSchema(ctx context.Context, id string) (io.ReadCloser, error)

+ type LocalParams struct

+ BundlePath string

+ SecretKey string

+ TempDir string

+ type LocalSource struct

+ func NewLocalSource(params LocalParams) (*LocalSource, error)

+ func NewLocalSourceFromConf(_ context.Context, conf *Conf) (*LocalSource, error)

+ func (ls *LocalSource) Close() error

+ func (ls *LocalSource) Driver() string

+ func (ls *LocalSource) GetPolicySet(ctx context.Context, id namer.ModuleID) (ps *runtimev1.RunnablePolicySet, err error)

+ func (ls *LocalSource) ListPolicyIDs(ctx context.Context, includeDisabled bool) (ids []string, err error)

+ func (ls *LocalSource) ListSchemaIDs(ctx context.Context) (ids []string, err error)

+ func (ls *LocalSource) LoadSchema(ctx context.Context, id string) (schema io.ReadCloser, err error)

+ func (ls *LocalSource) Reload(_ context.Context) error

+ type LocalSourceConf struct

+ BundlePath string

+ TempDir string

+ type OpenOpts struct

+ BundlePath string

+ Credentials *credentials.Credentials

+ ScratchFS afero.Fs

+ type RemoteSource struct

+ func NewRemoteSource(conf *Conf) (*RemoteSource, error)

+ func (s *RemoteSource) Driver() string

+ func (s *RemoteSource) GetPolicySet(ctx context.Context, id namer.ModuleID) (*runtimev1.RunnablePolicySet, error)

+ func (s *RemoteSource) Init(ctx context.Context) error

+ func (s *RemoteSource) InitWithClient(ctx context.Context, client CloudAPIClient) error

+ func (s *RemoteSource) IsHealthy() bool

+ func (s *RemoteSource) ListPolicyIDs(ctx context.Context, includeDisabled bool) ([]string, error)

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

+ func (s *RemoteSource) LoadSchema(ctx context.Context, id string) (io.ReadCloser, error)

+ func (s *RemoteSource) Reload(ctx context.Context) error

+ type RemoteSourceConf struct

+ BundleLabel string

+ CacheDir string

+ Connection ConnectionConf

+ DisableAutoUpdate bool

+ TempDir string

+ type TLSConf struct

+ Authority string

+ CACert string