provider

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 NewProviderForURL(logger logger.Logger, url string, opts *ProviderOpts) (internal.Provider, error)
• type FileProvider
  • func (p *FileProvider) Migrate() error
  • func (p *FileProvider) Process(data datatypes.ChangeEventPayload) error
  • func (p *FileProvider) Start() error
  • func (p *FileProvider) Stop() error
• type GormProvider
  • func (p *GormProvider) Migrate() error
  • func (p *GormProvider) Process(data datatypes.ChangeEventPayload) error
  • func (p *GormProvider) Start() error
  • func (p *GormProvider) Stop() error
• type ProviderOpts

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 NewGormProvider(logger logger.Logger, url string, opts *ProviderOpts) (internal.Provider, error)

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 ProviderOpts

type ProviderOpts struct {
	DryRun bool
}