steampipeconfig

Documentation

Index

• Constants
• func IsCloudWorkspaceIdentifier(name string) bool
• func LoadFlowpipeConfig(configPaths []string) (*modconfig.FlowpipeConfig, *error_helpers.ErrorAndWarnings)
• func ValidateConnectionName(connectionName string) error
• type ActorMetadata
• type CloudMetadata
• type DependencyPathKey
  • func NewDependencyPathKey(dependencyPath ...string) DependencyPathKey
  • func (k DependencyPathKey) GetParent() DependencyPathKey
  • func (k DependencyPathKey) PathLength() int
• type ErrorsAndWarningsNotification
  • func NewErrorsAndWarningsNotification(errorAndWarnings *error_helpers.ErrorAndWarnings) *ErrorsAndWarningsNotification
• type IdentityMetadata
• type MissingVariableError
  • func NewMissingVarsError(workspaceMod *modconfig.Mod) MissingVariableError
  • func (m MissingVariableError) Error() string
• type PluginRemoveReport
• type PluginRemoveReports
  • func (r PluginRemoveReports) Print()
• type PostgresNotification
  • func NewSchemaUpdateNotification() *PostgresNotification
• type PostgresNotificationType
• type ValidationFailure
  • func (v ValidationFailure) String() string
• type VariableValidationFailedError
  • func NewVariableValidationFailedError(diags tfdiags.Diagnostics) VariableValidationFailedError
  • func (m VariableValidationFailedError) Error() string
• type WorkspaceMetadata
• type WorkspaceProfileLoader
  • func NewWorkspaceProfileLoader[T modconfig.WorkspaceProfile](workspaceProfilePaths ...string) (*WorkspaceProfileLoader[T], error)
  • func (l *WorkspaceProfileLoader[T]) GetActiveWorkspaceProfile() T

Constants

const PostgresNotificationStructVersion = 20230306

Functions

func IsCloudWorkspaceIdentifier

func IsCloudWorkspaceIdentifier(name string) bool

IsCloudWorkspaceIdentifier returns whether name is a cloud workspace identifier of the form: {identity_handle}/{workspace_handle},

func LoadFlowpipeConfig

func LoadFlowpipeConfig(configPaths []string) (*modconfig.FlowpipeConfig, *error_helpers.ErrorAndWarnings)

func ValidateConnectionName

func ValidateConnectionName(connectionName string) error

Types

type ActorMetadata

type ActorMetadata struct {
	Id     string `json:"id,omitempty"`
	Handle string `json:"handle,omitempty"`
}

type CloudMetadata

type CloudMetadata struct {
	Actor             *ActorMetadata     `json:"actor,omitempty"`
	Identity          *IdentityMetadata  `json:"identity,omitempty"`
	WorkspaceDatabase *WorkspaceMetadata `json:"workspace,omitempty"`
	ConnectionString  string             `json:"-"`
}

type DependencyPathKey

type DependencyPathKey string

DependencyPathKey is a string representation of a dependency path

• a set of mod dependencyPath values separated by '->'

e.g. local -> github.com/kaidaguerre/steampipe-mod-m1@v3.1.1 -> github.com/kaidaguerre/steampipe-mod-m2@v5.1.1

func NewDependencyPathKey

func NewDependencyPathKey(dependencyPath ...string) DependencyPathKey

func (DependencyPathKey) GetParent

func (k DependencyPathKey) GetParent() DependencyPathKey

func (DependencyPathKey) PathLength

func (k DependencyPathKey) PathLength() int

how long is the depdency path

type ErrorsAndWarningsNotification

type ErrorsAndWarningsNotification struct {
	PostgresNotification
	Errors   []string
	Warnings []string
}

func NewErrorsAndWarningsNotification

func NewErrorsAndWarningsNotification(errorAndWarnings *error_helpers.ErrorAndWarnings) *ErrorsAndWarningsNotification

type IdentityMetadata

type IdentityMetadata struct {
	Id     string `json:"id,omitempty"`
	Handle string `json:"handle,omitempty"`
	Type   string `json:"type,omitempty"`
}

type MissingVariableError

type MissingVariableError struct {
	MissingVariables           []*modconfig.Variable
	MissingTransitiveVariables map[DependencyPathKey][]*modconfig.Variable
	// contains filtered or unexported fields
}

func NewMissingVarsError

func NewMissingVarsError(workspaceMod *modconfig.Mod) MissingVariableError

func (MissingVariableError) Error

func (m MissingVariableError) Error() string

type PluginRemoveReport

type PluginRemoveReport struct {
	Image       *ociinstaller.SteampipeImageRef
	ShortName   string
	Connections []*modconfig.Connection
}

type PluginRemoveReports

type PluginRemoveReports []PluginRemoveReport

func (PluginRemoveReports) Print

func (r PluginRemoveReports) Print()

type PostgresNotification

type PostgresNotification struct {
	StructVersion int
	Type          PostgresNotificationType
}

func NewSchemaUpdateNotification

func NewSchemaUpdateNotification() *PostgresNotification

type PostgresNotificationType

type PostgresNotificationType int

const (
	PgNotificationSchemaUpdate PostgresNotificationType = iota + 1
	PgNotificationConnectionError
)

type ValidationFailure

type ValidationFailure struct {
	Plugin             string
	ConnectionName     string
	Message            string
	ShouldDropIfExists bool
}

func (ValidationFailure) String

func (v ValidationFailure) String() string

type VariableValidationFailedError

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

func NewVariableValidationFailedError

func NewVariableValidationFailedError(diags tfdiags.Diagnostics) VariableValidationFailedError

func (VariableValidationFailedError) Error

func (m VariableValidationFailedError) Error() string

type WorkspaceMetadata

type WorkspaceMetadata struct {
	Id     string `json:"id,omitempty"`
	Handle string `json:"handle,omitempty"`
}

type WorkspaceProfileLoader

type WorkspaceProfileLoader[T modconfig.WorkspaceProfile] struct {
	DefaultProfile    T
	ConfiguredProfile T
	// contains filtered or unexported fields
}

func NewWorkspaceProfileLoader

func NewWorkspaceProfileLoader[T modconfig.WorkspaceProfile](workspaceProfilePaths ...string) (*WorkspaceProfileLoader[T], error)

func (*WorkspaceProfileLoader[T]) GetActiveWorkspaceProfile

func (l *WorkspaceProfileLoader[T]) GetActiveWorkspaceProfile() T