flowpipeconfig

Dec 23, 2024

Changes in this version

+ type FlowpipeConfig struct

+ ConfigPaths []string

+ ConnectionImports map[string]modconfig.ConnectionImport

+ CredentialImports map[string]credential.CredentialImport

+ Credentials map[string]credential.Credential

+ Integrations map[string]resources.Integration

+ Notifiers map[string]resources.Notifier

+ OnFileWatcherError func(context.Context, error)

+ OnFileWatcherEvent func(context.Context, *FlowpipeConfig)

+ PipelingConnections map[string]connection.PipelingConnection

+ func LoadFlowpipeConfig(configPaths []string) (config *FlowpipeConfig, errorsAndWarnings error_helpers.ErrorAndWarnings)

+ func NewFlowpipeConfig(configPaths []string) *FlowpipeConfig

+ func (f *FlowpipeConfig) Equals(other *FlowpipeConfig) bool

+ func (f *FlowpipeConfig) NotifierValueMap() (map[string]cty.Value, error)

+ func (f *FlowpipeConfig) SetupWatcher(ctx context.Context, errorHandler func(context.Context, error)) error