flowpipeconfig

Documentation

Index

• type FlowpipeConfig
  • func LoadFlowpipeConfig(configPaths []string) (res *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

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

func LoadFlowpipeConfig

func LoadFlowpipeConfig(configPaths []string) (res *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