flowpipeconfig

package
v1.6.4 Latest Latest
Warning

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

Go to latest
Published: Oct 23, 2024 License: AGPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FlowpipeConfig

type FlowpipeConfig struct {
	ConfigPaths []string

	CredentialImports   map[string]credential.CredentialImport
	Credentials         map[string]credential.Credential
	Integrations        map[string]modconfig.Integration
	Notifiers           map[string]modconfig.Notifier
	ConnectionImports   map[string]modconfig.ConnectionImport
	PipelingConnections map[string]connection.PipelingConnection

	// Hooks
	OnFileWatcherError func(context.Context, error)
	OnFileWatcherEvent func(context.Context, *FlowpipeConfig)
	// contains filtered or unexported fields
}

func LoadFlowpipeConfig

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

func NewFlowpipeConfig

func NewFlowpipeConfig(configPaths []string) *FlowpipeConfig

func (*FlowpipeConfig) Equals

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

func (*FlowpipeConfig) SetupWatcher

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL