plugins

Documentation

Index

• Variables
• func BindConfig(set *pflag.FlagSet) error
• func NewCollectNotifier(provider string, viper *viper.Viper) (api.Notifier[api.CollectNotification], error)
• func NewHistoricalWriter(provider string, viper *viper.Viper) (api.HistoricalWriter, error)
• func NewState(provider string, viper *viper.Viper) (api.State, error)
• func NewWriteNotifier(provider string, viper *viper.Viper) (api.Notifier[api.WriteNotification], error)

Variables

var CollectNotifierFactories = make(registry[api.CollectNotifierFactory])

var Configurers = make(registry[api.BindConfig])

var DataConnectorReconciler = make(registry[api.DataConnectorReconcile])

var FeatureAppliers = make(registry[api.FeatureApply])

var HistoricalWriterFactories = make(registry[api.HistoricalWriterFactory])

var StateFactories = make(registry[api.StateFactory])

var WriteNotifierFactories = make(registry[api.WriteNotifierFactory])

Functions

func BindConfig

func BindConfig(set *pflag.FlagSet) error

BindConfig adds config flags for the plugin.

func NewCollectNotifier

func NewCollectNotifier(provider string, viper *viper.Viper) (api.Notifier[api.CollectNotification], error)

NewCollectNotifier creates a new api.Notifier[api.CollectNotification] for a notifier provider.

func NewHistoricalWriter

func NewHistoricalWriter(provider string, viper *viper.Viper) (api.HistoricalWriter, error)

NewHistoricalWriter creates a new HistoricalWriter for an historical writer provider.

func NewState

func NewState(provider string, viper *viper.Viper) (api.State, error)

NewState creates a new State for a state provider.

func NewWriteNotifier

func NewWriteNotifier(provider string, viper *viper.Viper) (api.Notifier[api.WriteNotification], error)

NewWriteNotifier creates a new api.Notifier[api.WriteNotification] for a notifier provider.