sqlite

package
v1.17.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 4, 2021 License: Apache-2.0 Imports: 27 Imported by: 14

Documentation

Index

Constants

View Source 
const (
	ConfigMapCRDName     = "customResourceDefinitions"
	ConfigMapCSVName     = "clusterServiceVersions"
	ConfigMapPackageName = "packages"
)
View Source 
const (
	DefaultMigrationsTable = "schema_migrations"
	NilVersion             = -1
)
View Source 
const ClusterServiceVersionKind = "ClusterServiceVersion"

Variables

This section is empty.

Functions

func EnableForeignKeys 

func EnableForeignKeys(fileName string) string

EnableForeignKeys appends the option to enable foreign keys on connections note that without this option, PRAGMAs about foreign keys will lie.

func EnableImmutable 

func EnableImmutable(fileName string) string

Immutable appends the option to mark the db immutable on connections

func Open 

func Open(fileName string) (*sql.DB, error)

Open opens a connection to a sqlite db. It should be used everywhere instead of sql.Open so that foreign keys are ensured.

func OpenReadOnly 

func OpenReadOnly(fileName string) (*sql.DB, error)

Open opens a connection to a sqlite db. It is

func ToModel 

func ToModel(ctx context.Context, q *SQLQuerier) (model.Model, error)

Types

type BundleDeprecator 

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

BundleDeprecator removes bundles from the database

func NewSQLDeprecatorForBundles 

func NewSQLDeprecatorForBundles(store registry.Load, bundles []string) *BundleDeprecator

func (*BundleDeprecator) Deprecate 

func (d *BundleDeprecator) Deprecate() error

type ConfigMapLoader 

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

ConfigMapLoader loads a configmap of resources into the database entries under "customResourceDefinitions" will be parsed as CRDs entries under "clusterServiceVersions" will be parsed as CSVs entries under "packages" will be parsed as Packages

func NewSQLLoaderForConfigMap 

func NewSQLLoaderForConfigMap(store registry.Load, configMap v1.ConfigMap) *ConfigMapLoader

func NewSQLLoaderForConfigMapData 

func NewSQLLoaderForConfigMapData(logger *logrus.Entry, store registry.Load, configMapData map[string]string) *ConfigMapLoader

NewSQLLoaderForConfigMapData is useful when the operator manifest(s) originate from a different source than a configMap. For example, operator manifest(s) can be downloaded from a remote registry like quay.io.

func (*ConfigMapLoader) Populate 

func (c *ConfigMapLoader) Populate() error

type DbOption 

type DbOption func(*DbOptions)

func WithEnableAlpha 

func WithEnableAlpha(enableAlpha bool) DbOption

func WithMigratorBuilder 

func WithMigratorBuilder(m func(loader *sql.DB) (Migrator, error)) DbOption

type DbOptions 

type DbOptions struct {
	// MigratorBuilder is a function that returns a migrator instance
	MigratorBuilder func(*sql.DB) (Migrator, error)
	EnableAlpha     bool
}

type DirectoryLoader 

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

DirectoryLoader loads a directory of resources into the database

func NewSQLLoaderForDirectory 

func NewSQLLoaderForDirectory(store registry.Load, directory string) *DirectoryLoader

func (*DirectoryLoader) LoadBundleWalkFunc 

func (d *DirectoryLoader) LoadBundleWalkFunc(path string, f os.FileInfo, err error) error

LoadBundleWalkFunc walks the directory. When it sees a `.clusterserviceversion.yaml` file, it attempts to load the surrounding files in the same directory as a bundle, and stores them in the db for querying

func (*DirectoryLoader) LoadPackagesWalkFunc 

func (d *DirectoryLoader) LoadPackagesWalkFunc(path string, f os.FileInfo, err error) error

LoadPackagesWalkFunc attempts to unmarshal the file at the given path into a PackageManifest resource. If unmarshaling is successful, the PackageManifest is added to the loader's store.

func (*DirectoryLoader) Populate 

func (d *DirectoryLoader) Populate() error

type MigratableLoader 

type MigratableLoader interface {
	registry.Load
	Migrate(context.Context) error
}

func NewSQLLiteLoader 

func NewSQLLiteLoader(db *sql.DB, opts ...DbOption) (MigratableLoader, error)

type Migrator 

type Migrator interface {
	Migrate(ctx context.Context) error
	Up(ctx context.Context, migrations migrations.Migrations) error
	Down(ctx context.Context, migrations migrations.Migrations) error
}

func NewSQLLiteMigrator 

func NewSQLLiteMigrator(db *sql.DB) (Migrator, error)

NewSQLLiteMigrator returns a SQLLiteMigrator.

type PackageRemover 

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

PackageRemover removes a package from the database

func NewSQLRemoverForPackages 

func NewSQLRemoverForPackages(store registry.Load, packages string) *PackageRemover

func (*PackageRemover) Remove 

func (d *PackageRemover) Remove() error

type Querier 

type Querier interface {
	QueryContext(ctx context.Context, query string, args ...interface{}) (RowScanner, error)
}

type RowScanner 

type RowScanner interface {
	Next() bool
	Close() error
	Scan(dest ...interface{}) error
}

type SQLDeprecator 

type SQLDeprecator interface {
	Deprecate() error
}

type SQLGraphLoader 

type SQLGraphLoader struct {
	Querier registry.Query
}

func NewSQLGraphLoader 

func NewSQLGraphLoader(dbFilename string) (*SQLGraphLoader, error)

func NewSQLGraphLoaderFromDB 

func NewSQLGraphLoaderFromDB(db *sql.DB) (*SQLGraphLoader, error)

func (*SQLGraphLoader) Generate 

func (g *SQLGraphLoader) Generate(packageName string) (*registry.Package, error)

type SQLLiteMigrator 

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

func (*SQLLiteMigrator) Down 

func (m *SQLLiteMigrator) Down(ctx context.Context, migrations migrations.Migrations) error

func (*SQLLiteMigrator) Migrate 

func (m *SQLLiteMigrator) Migrate(ctx context.Context) error

Migrate gets the current version from the database, the latest version from the migrations, and migrates up the the latest

func (*SQLLiteMigrator) Up 

func (m *SQLLiteMigrator) Up(ctx context.Context, migrations migrations.Migrations) error

Up runs a specific set of migrations.

type SQLPopulator 

type SQLPopulator interface {
	Populate() error
}

type SQLQuerier 

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

func NewSQLLiteQuerier 

func NewSQLLiteQuerier(dbFilename string, opts ...SQLiteQuerierOption) (*SQLQuerier, error)

func NewSQLLiteQuerierFromDBQuerier 

func NewSQLLiteQuerierFromDBQuerier(q Querier, opts ...SQLiteQuerierOption) *SQLQuerier

func NewSQLLiteQuerierFromDb 

func NewSQLLiteQuerierFromDb(db *sql.DB, opts ...SQLiteQuerierOption) *SQLQuerier

func (*SQLQuerier) GetApisForEntry 

func (s *SQLQuerier) GetApisForEntry(ctx context.Context, entryID int64) (provided []*api.GroupVersionKind, required []*api.GroupVersionKind, err error)

func (*SQLQuerier) GetBundle 

func (s *SQLQuerier) GetBundle(ctx context.Context, pkgName, channelName, csvName string) (*api.Bundle, error)

func (*SQLQuerier) GetBundleForChannel 

func (s *SQLQuerier) GetBundleForChannel(ctx context.Context, pkgName string, channelName string) (*api.Bundle, error)

func (*SQLQuerier) GetBundlePathIfExists 

func (s *SQLQuerier) GetBundlePathIfExists(ctx context.Context, bundleName string) (bundlePath string, err error)

func (*SQLQuerier) GetBundlePathsForPackage 

func (s *SQLQuerier) GetBundlePathsForPackage(ctx context.Context, pkgName string) ([]string, error)

func (*SQLQuerier) GetBundleThatProvides 

func (s *SQLQuerier) GetBundleThatProvides(ctx context.Context, group, apiVersion, kind string) (*api.Bundle, error)

Get the the latest bundle that provides the API in a default channel, error unless there is ONLY one

func (*SQLQuerier) GetBundleThatReplaces 

func (s *SQLQuerier) GetBundleThatReplaces(ctx context.Context, name, pkgName, channelName string) (*api.Bundle, error)

func (*SQLQuerier) GetBundleVersion 

func (s *SQLQuerier) GetBundleVersion(ctx context.Context, image string) (string, error)

func (*SQLQuerier) GetBundlesForPackage 

func (s *SQLQuerier) GetBundlesForPackage(ctx context.Context, pkgName string) (map[registry.BundleKey]struct{}, error)

func (*SQLQuerier) GetChannelEntriesFromPackage 

func (s *SQLQuerier) GetChannelEntriesFromPackage(ctx context.Context, packageName string) ([]registry.ChannelEntryAnnotated, error)

func (*SQLQuerier) GetChannelEntriesThatProvide 

func (s *SQLQuerier) GetChannelEntriesThatProvide(ctx context.Context, group, version, kind string) (entries []*registry.ChannelEntry, err error)

func (*SQLQuerier) GetChannelEntriesThatReplace 

func (s *SQLQuerier) GetChannelEntriesThatReplace(ctx context.Context, name string) (entries []*registry.ChannelEntry, err error)

func (*SQLQuerier) GetCurrentCSVNameForChannel 

func (s *SQLQuerier) GetCurrentCSVNameForChannel(ctx context.Context, pkgName, channel string) (string, error)

func (*SQLQuerier) GetDefaultChannelForPackage 

func (s *SQLQuerier) GetDefaultChannelForPackage(ctx context.Context, pkgName string) (string, error)

func (*SQLQuerier) GetDefaultPackage 

func (s *SQLQuerier) GetDefaultPackage(ctx context.Context, name string) (string, error)

func (*SQLQuerier) GetDependenciesForBundle 

func (s *SQLQuerier) GetDependenciesForBundle(ctx context.Context, name, version, path string) (dependencies []*api.Dependency, err error)

func (*SQLQuerier) GetImagesForBundle 

func (s *SQLQuerier) GetImagesForBundle(ctx context.Context, csvName string) ([]string, error)

func (*SQLQuerier) GetLatestChannelEntriesThatProvide 

func (s *SQLQuerier) GetLatestChannelEntriesThatProvide(ctx context.Context, group, version, kind string) (entries []*registry.ChannelEntry, err error)

Get latest channel entries that provide an api

func (*SQLQuerier) GetPackage 

func (s *SQLQuerier) GetPackage(ctx context.Context, name string) (*registry.PackageManifest, error)

func (*SQLQuerier) GetPropertiesForBundle 

func (s *SQLQuerier) GetPropertiesForBundle(ctx context.Context, name, version, path string) (properties []*api.Property, err error)

func (*SQLQuerier) ListBundles 

func (s *SQLQuerier) ListBundles(ctx context.Context) ([]*api.Bundle, error)

func (*SQLQuerier) ListChannels 

func (s *SQLQuerier) ListChannels(ctx context.Context, pkgName string) ([]string, error)

func (*SQLQuerier) ListImages 

func (s *SQLQuerier) ListImages(ctx context.Context) ([]string, error)

func (*SQLQuerier) ListPackages 

func (s *SQLQuerier) ListPackages(ctx context.Context) ([]string, error)

ListPackages returns a list of package names as strings

func (*SQLQuerier) ListRegistryBundles 

func (s *SQLQuerier) ListRegistryBundles(ctx context.Context) ([]*registry.Bundle, error)

ListRegistryBundles returns a set of registry bundles. The set can be filtered by package by setting the given context's 'package' key to a desired package name. e.g. ctx := ContextWithPackage(context.TODO(), "etcd") bundles, err := querier.ListRegistryBundles(ctx) // ...

func (*SQLQuerier) ListTables 

func (s *SQLQuerier) ListTables(ctx context.Context) ([]string, error)

func (*SQLQuerier) SendBundles 

func (s *SQLQuerier) SendBundles(ctx context.Context, stream registry.BundleSender) error

type SQLRemover 

type SQLRemover interface {
	Remove() error
}

type SQLStrandedBundleRemover 

type SQLStrandedBundleRemover interface {
	Remove() error
}

type SQLiteQuerierOption 

type SQLiteQuerierOption func(*querierConfig)

func OmitManifests 

func OmitManifests(b bool) SQLiteQuerierOption

If true, ListBundles will omit inline manifests (the object and csvJson fields) from response elements that contain a bundle image reference.

type StrandedBundleRemover 

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

StrandedBundleRemover removes stranded bundles from the database

func NewSQLStrandedBundleRemover 

func NewSQLStrandedBundleRemover(store registry.Load) *StrandedBundleRemover

func (*StrandedBundleRemover) Remove 

func (d *StrandedBundleRemover) Remove() error

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳