db_local

package
v0.9.1 Latest Latest
Warning

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

 Go to latest Published: Nov 11, 2021 License: AGPL-3.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

View Source 
const CertIssuer = "steampipe.io"
View Source 
const ServiceExecutableRelativeLocation = "/db/12.1.0/postgres/bin/postgres"

Variables

View Source 
var (
	CertExpiryTolerance      = 180 * (24 * time.Hour)     // 180 days
	RootCertValidityPeriod   = 5 * 365 * (24 * time.Hour) // 5 years
	ServerCertValidityPeriod = 365 * (24 * time.Hour)     // 1 year
)

Functions

func CertificatesExist 

func CertificatesExist() bool

CertificatesExist checks if the root and server certificate and key files exist

func EnsureDBInstalled 

func EnsureDBInstalled() (err error)

EnsureDBInstalled makes sure that the embedded pg database is installed and running

func EnsureDbAndStartService 

func EnsureDbAndStartService(invoker constants.Invoker) error

EnsureDbAndStartService ensures database is installed and starts service if necessary

func FindAllSteampipePostgresInstances 

func FindAllSteampipePostgresInstances() ([]*psutils.Process, error)

func GetCountOfConnectedClients 

func GetCountOfConnectedClients() (int, error)

GetCountOfConnectedClients returns the number of clients currently connected to the service

func GetLocalClient 

func GetLocalClient(invoker constants.Invoker) (db_common.Client, error)

GetLocalClient starts service if needed and creates a new LocalDbClient

func IsInstalled 

func IsInstalled() bool

IsInstalled checks and reports whether the embedded database is installed and setup

func PidExists 

func PidExists(targetPid int) (bool, error)

PidExists scans through the list of PIDs in the system and checks for the `targetPID`.

PidExists uses iteration, instead of signalling, since we have observed that signalling does not always work reliably when the destination of the signal is a child of the source of the signal - which may be the case then starting implicit services

func PrepareDb 

func PrepareDb(spinner *spinner.Spinner) error

PrepareDb updates the FDW if needed, and inits the database if required

func RefreshConnectionAndSearchPaths 

func RefreshConnectionAndSearchPaths(invoker constants.Invoker) error

RefreshConnectionAndSearchPaths creates a local client and refreshed connections and search paths

func RemoveAllCertificates 

func RemoveAllCertificates() error

RemoveAllCertificates removes root and server certificates so that they can be regenerated

func RemoveServerCertificate 

func RemoveServerCertificate() error

RemoveServerCertificate removes the server certificate certificates so it will be regenerated

func ShutdownService 

func ShutdownService(invoker constants.Invoker)

ShutdownService stops the database instance if the given 'invoker' matches

func TrimLogs 

func TrimLogs()

func ValidateRootCertificate 

func ValidateRootCertificate() bool

ValidateRootCertificate checks the root certificate exists, is not expired and has correct Subject

func ValidateServerCertificate 

func ValidateServerCertificate() bool

ValidateServerCertificate checks the server certificate exists, is not expired and has correct issuer

Types

type CreateDbOptions 

type CreateDbOptions struct {
	DatabaseName, Username string
}

type LocalDbClient 

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

LocalDbClient wraps over DbClient

func NewLocalClient 

func NewLocalClient(invoker constants.Invoker) (*LocalDbClient, error)

NewLocalClient ensures that the database instance is running and returns a `Client` to interact with it

func (*LocalDbClient) CacheClear 

func (c *LocalDbClient) CacheClear() error

CacheClear implements Client

func (*LocalDbClient) CacheOff 

func (c *LocalDbClient) CacheOff() error

CacheOff implements Client

func (*LocalDbClient) CacheOn 

func (c *LocalDbClient) CacheOn() error

CacheOn implements Client

func (*LocalDbClient) Close 

func (c *LocalDbClient) Close() error

Close implements Client close the connection to the database and shuts down the backend

func (*LocalDbClient) ConnectionMap 

func (c *LocalDbClient) ConnectionMap() *steampipeconfig.ConnectionDataMap

func (*LocalDbClient) Execute 

func (c *LocalDbClient) Execute(ctx context.Context, query string, disableSpinner bool) (res *queryresult.Result, err error)

Execute implements Client

func (*LocalDbClient) ExecuteSync 

func (c *LocalDbClient) ExecuteSync(ctx context.Context, query string, disableSpinner bool) (*queryresult.SyncQueryResult, error)

ExecuteSync implements Client

func (*LocalDbClient) GetCurrentSearchPath 

func (c *LocalDbClient) GetCurrentSearchPath() ([]string, error)

GetCurrentSearchPath implements Client

func (*LocalDbClient) LoadSchema 

func (c *LocalDbClient) LoadSchema()

LoadSchema implements Client

func (*LocalDbClient) RefreshConnectionAndSearchPaths 

func (c *LocalDbClient) RefreshConnectionAndSearchPaths() *steampipeconfig.RefreshConnectionResult

func (*LocalDbClient) SchemaMetadata 

func (c *LocalDbClient) SchemaMetadata() *schema.Metadata

SchemaMetadata implements Client

func (*LocalDbClient) SetEnsureSessionDataFunc 

func (c *LocalDbClient) SetEnsureSessionDataFunc(f db_common.EnsureSessionStateCallback)

EnsureSessionState implements Client

func (*LocalDbClient) SetSessionSearchPath 

func (c *LocalDbClient) SetSessionSearchPath(currentSearchPath ...string) error

SetSessionSearchPath implements Client

type Passwords 

type Passwords struct {
	Root      string
	Steampipe string
}

Passwords :: structure for working with DB passwords

type RunningDBInstanceInfo 

type RunningDBInstanceInfo struct {
	Pid        int
	Port       int
	Listen     []string
	ListenType StartListenType
	Invoker    constants.Invoker
	Password   string
	User       string
	Database   string
}

RunningDBInstanceInfo contains data about the running process and it's credentials

func GetStatus 

func GetStatus() (*RunningDBInstanceInfo, error)

GetStatus checks that the database instance is running and returns its details

func (*RunningDBInstanceInfo) Save 

func (r *RunningDBInstanceInfo) Save() error

func (*RunningDBInstanceInfo) String 

func (r *RunningDBInstanceInfo) String() string

type StartListenType 

type StartListenType string

StartListenType is a pseudoEnum of network binding for postgres 

const (
	// ListenTypeNetwork - bind to all known interfaces
	ListenTypeNetwork StartListenType = "network"
	// ListenTypeLocal - bind to localhost only
	ListenTypeLocal = "local"
)

func (StartListenType) IsValid 

func (slt StartListenType) IsValid() error

IsValid is a validator for StartListenType known values

type StartResult 

type StartResult int

StartResult is a pseudoEnum for outcomes of Start 

const (
	// start from 10 to prevent confusion with int zero-value
	ServiceStarted StartResult = iota + 1
	ServiceAlreadyRunning
	ServiceFailedToStart
)

func StartDB 

func StartDB(port int, listen StartListenType, invoker constants.Invoker) (startResult StartResult, err error)

StartDB starts the database if not already running

type StopStatus 

type StopStatus int

StopStatus is a pseudoEnum for service stop result 

const (
	// start from 1 to prevent confusion with int zero-value
	ServiceStopped StopStatus = iota + 1
	ServiceNotRunning
	ServiceStopFailed
	ServiceStopTimedOut
)

func StopDB 

func StopDB(force bool, invoker constants.Invoker, spinner *spinner.Spinner) (status StopStatus, e error)

StopDB searches for and stops the running instance. Does nothing if an instance was not found

Source Files

View all Source files

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.