db_local

May 10, 2022

Changes in this version

+ func TrimBackups()

May 9, 2022

Changes in this version

+ const RunningDBStructVersion

type LocalDbClient

+ func (c *LocalDbClient) GetRequiredSessionSearchPath() []string

type RunningDBInstanceInfo

+ StructVersion int64

Mar 31, 2022

Changes in this version

type LocalDbClient

+ func (c *LocalDbClient) ForeignSchemaNames() []string

+ func (c *LocalDbClient) GetCurrentSearchPathForDbConnection(ctx context.Context, databaseConnection *sql.Conn) ([]string, error)

+ func (c *LocalDbClient) GetDefaultSearchPath(ctx context.Context) []string

+ func (c *LocalDbClient) SetRequiredSessionSearchPath(ctx context.Context) error

Dec 21, 2021

Changes in this version

+ func GetCountOfThirdPartyClients(ctx context.Context) (i int, e error)

type LocalDbClient

+ func (c *LocalDbClient) ForeignSchemas() []string

+ func (c *LocalDbClient) GetSchemaFromDB(ctx context.Context, schemas []string) (*schema.Metadata, error)

+ func (c *LocalDbClient) LoadForeignSchemaNames(ctx context.Context) error

+ type StartDbStatus int

type StartResult

+ DbState *RunningDBInstanceInfo

+ Error error

+ PluginManagerState *plugin_manager.PluginManagerState

+ Status StartDbStatus

+ func (r *StartResult) SetError(err error) *StartResult

Nov 24, 2021

Changes in this version

type LocalDbClient

+ func (c *LocalDbClient) AcquireSession(ctx context.Context) *db_common.AcquireSessionResult

+ func (c *LocalDbClient) ContructSearchPath(requiredSearchPath []string, searchPathPrefix []string, ...) ([]string, error)

+ func (c *LocalDbClient) ExecuteInSession(ctx context.Context, session *db_common.DatabaseSession, query string, ...) (res *queryresult.Result, err error)

+ func (c *LocalDbClient) ExecuteSyncInSession(ctx context.Context, session *db_common.DatabaseSession, query string, ...) (*queryresult.SyncQueryResult, error)

+ func (c *LocalDbClient) RefreshSessions(ctx context.Context) *db_common.AcquireSessionResult

type RunningDBInstanceInfo

+ func GetState() (*RunningDBInstanceInfo, error)

type StartResult

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

type StopStatus

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

Oct 22, 2021

Changes in this version

+ const CertIssuer

+ const ServiceExecutableRelativeLocation

+ var CertExpiryTolerance = 180 * (24 * time.Hour)

+ var RootCertValidityPeriod = 5 * 365 * (24 * time.Hour)

+ var ServerCertValidityPeriod = 365 * (24 * time.Hour)

+ func CertificatesExist() bool

+ func EnsureDBInstalled() (err error)

+ func EnsureDbAndStartService(invoker constants.Invoker) error

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

+ func GetCountOfConnectedClients() (int, error)

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

+ func IsInstalled() bool

+ func PidExists(targetPid int) (bool, error) — darwin/amd64, linux/amd64

+ func PrepareDb(spinner *spinner.Spinner) error

+ func RefreshConnectionAndSearchPaths(invoker constants.Invoker) error

+ func RemoveAllCertificates() error

+ func RemoveServerCertificate() error

+ func ShutdownService(invoker constants.Invoker)

+ func TrimLogs()

+ func ValidateRootCertificate() bool

+ func ValidateServerCertificate() bool

+ type CreateDbOptions struct

+ DatabaseName string

+ Username string

+ type LocalDbClient struct

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

+ func (c *LocalDbClient) CacheClear() error

+ func (c *LocalDbClient) CacheOff() error

+ func (c *LocalDbClient) CacheOn() error

+ func (c *LocalDbClient) Close() error

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

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

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

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

+ func (c *LocalDbClient) LoadSchema()

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

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

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

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

+ type Passwords struct

+ Root string

+ Steampipe string

+ type RunningDBInstanceInfo struct

+ Database string

+ Invoker constants.Invoker

+ Listen []string

+ ListenType StartListenType

+ Password string

+ Pid int

+ Port int

+ User string

+ func GetStatus() (*RunningDBInstanceInfo, error)

+ func (r *RunningDBInstanceInfo) Save() error

+ func (r *RunningDBInstanceInfo) String() string

+ type StartListenType string

+ const ListenTypeLocal

+ const ListenTypeNetwork

+ func (slt StartListenType) IsValid() error

+ type StartResult int

+ const ServiceAlreadyRunning

+ const ServiceFailedToStart

+ const ServiceStarted

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

+ type StopStatus int

+ const ServiceNotRunning

+ const ServiceStopFailed

+ const ServiceStopTimedOut

+ const ServiceStopped

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