flowpipeconfig

Documentation

Index

• type FlowpipeConfig
  • 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) SetupWatcher(ctx context.Context, errorHandler func(context.Context, error)) error

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