powerpipeconfig

Documentation

Index

• type PowerpipeConfig
  • func LoadPowerpipeConfig(configPaths ...string) (res *PowerpipeConfig, errorsAndWarnings error_helpers.ErrorAndWarnings)
  • func NewPowerpipeConfig() *PowerpipeConfig
  • func (c *PowerpipeConfig) Equals(other *PowerpipeConfig) bool
  • func (c *PowerpipeConfig) SetupWatcher(ctx context.Context, errorHandler func(context.Context, error)) error

Types

type PowerpipeConfig

type PowerpipeConfig struct {
	// todo only config folder??
	ConfigPaths []string

	PipelingConnections map[string]connection.PipelingConnection

	// Hooks
	OnFileWatcherError func(context.Context, error)
	OnFileWatcherEvent func(context.Context, *PowerpipeConfig)

	DefaultConnection connection.ConnectionStringProvider
	// contains filtered or unexported fields
}

var GlobalConfig *PowerpipeConfig

func LoadPowerpipeConfig

func LoadPowerpipeConfig(configPaths ...string) (res *PowerpipeConfig, errorsAndWarnings error_helpers.ErrorAndWarnings)

func NewPowerpipeConfig

func NewPowerpipeConfig() *PowerpipeConfig

func (*PowerpipeConfig) Equals

func (c *PowerpipeConfig) Equals(other *PowerpipeConfig) bool

func (*PowerpipeConfig) SetupWatcher

func (c *PowerpipeConfig) SetupWatcher(ctx context.Context, errorHandler func(context.Context, error)) error