Documentation
¶
Index ¶
- func NewFileProvider(logger logger.Logger, urlstring string, opts *ProviderOpts) (internal.Provider, error)
- func NewGormProvider(logger logger.Logger, url string, opts *ProviderOpts) (internal.Provider, error)
- func NewNatsProvider(logger logger.Logger, urlstring string, opts *ProviderOpts) (internal.Provider, error)
- func NewProviderForURL(logger logger.Logger, url string, opts *ProviderOpts) (internal.Provider, error)
- type FileProvider
- type GormProvider
- type NatsProvider
- type ProviderOpts
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFileProvider ¶
func NewFileProvider(logger logger.Logger, urlstring string, opts *ProviderOpts) (internal.Provider, error)
NewFileProvider returns a provider that will stream files to a folder provided in the url
func NewGormProvider ¶
func NewNatsProvider ¶ added in v1.0.2
func NewNatsProvider(logger logger.Logger, urlstring string, opts *ProviderOpts) (internal.Provider, error)
NewFileProvider returns a provider that will stream files to a folder provided in the url
func NewProviderForURL ¶
func NewProviderForURL(logger logger.Logger, url string, opts *ProviderOpts) (internal.Provider, error)
NewProviderForURL will return a new internal.Provider for the driver based on the url
Types ¶
type FileProvider ¶
type FileProvider struct {
// contains filtered or unexported fields
}
func (*FileProvider) Migrate ¶
func (p *FileProvider) Migrate() error
Migrate will tell the provider to do any migration work and return an error or nil if ok
func (*FileProvider) Process ¶
func (p *FileProvider) Process(data datatypes.ChangeEventPayload) error
Process data received and return an error or nil if processed ok
func (*FileProvider) Start ¶
func (p *FileProvider) Start() error
Start the provider and return an error or nil if ok
func (*FileProvider) Stop ¶
func (p *FileProvider) Stop() error
Stop the provider and return an error or nil if ok
type GormProvider ¶
type GormProvider struct {
// contains filtered or unexported fields
}
func (*GormProvider) Migrate ¶
func (p *GormProvider) Migrate() error
Migrate will tell the provider to do any migration work and return an error or nil if ok
func (*GormProvider) Process ¶
func (p *GormProvider) Process(data datatypes.ChangeEventPayload) error
Process data received and return an error or nil if processed ok
func (*GormProvider) Start ¶
func (p *GormProvider) Start() error
Start the provider and return an error or nil if ok
func (*GormProvider) Stop ¶
func (p *GormProvider) Stop() error
Stop the provider and return an error or nil if ok
type NatsProvider ¶ added in v1.0.2
type NatsProvider struct {
// contains filtered or unexported fields
}
func (*NatsProvider) Migrate ¶ added in v1.0.2
func (p *NatsProvider) Migrate() error
Migrate will tell the provider to do any migration work and return an error or nil if ok
func (*NatsProvider) Process ¶ added in v1.0.2
func (p *NatsProvider) Process(data datatypes.ChangeEventPayload) error
Process data received and return an error or nil if processed ok
func (*NatsProvider) Start ¶ added in v1.0.2
func (p *NatsProvider) Start() error
Start the provider and return an error or nil if ok
func (*NatsProvider) Stop ¶ added in v1.0.2
func (p *NatsProvider) Stop() error
Stop the provider and return an error or nil if ok
type ProviderOpts ¶
type ProviderOpts struct {
DryRun bool
}
Source Files