mysql

Documentation

Index

• Constants
• func GetSqlForProcessor(processor *thunder.Processor) (string, error)
• func StatsQuery(database string) string
• type Driver
  • func (d *Driver) Config() thunder.SourceDriverConfig
  • func (d *Driver) GetDocumentsForProcessor(processor *thunder.Processor, in chan<- *thunder.Document, ctx context.Context, ...) error
  • func (d *Driver) ID() string
  • func (d *Driver) New(config any) (thunder.SourceDriver, error)
  • func (d *Driver) Start(p *thunder.Processor, in utils.BroadcasterIn[thunder.DbEvent]) error
  • func (d *Driver) Stats() (*thunder.SourceDriverStats, error)
  • func (d *Driver) Stop() error
  • func (d *Driver) TestConfig() (string, error)
• type DriverConfig
  • func (cfg DriverConfig) Excerpt() string

Constants

const DriverID = "thunder.mysql"

Functions

func GetSqlForProcessor

func GetSqlForProcessor(processor *thunder.Processor) (string, error)

func StatsQuery

func StatsQuery(database string) string

Types

type Driver

type Driver struct {
	// contains filtered or unexported fields
}

func (*Driver) Config

func (d *Driver) Config() thunder.SourceDriverConfig

func (*Driver) GetDocumentsForProcessor

func (d *Driver) GetDocumentsForProcessor(processor *thunder.Processor, in chan<- *thunder.Document, ctx context.Context, limit uint64) error

func (*Driver) ID

func (d *Driver) ID() string

func (*Driver) New

func (d *Driver) New(config any) (thunder.SourceDriver, error)

func (*Driver) Start

func (d *Driver) Start(p *thunder.Processor, in utils.BroadcasterIn[thunder.DbEvent]) error

func (*Driver) Stats

func (d *Driver) Stats() (*thunder.SourceDriverStats, error)

func (*Driver) Stop

func (d *Driver) Stop() error

func (*Driver) TestConfig

func (d *Driver) TestConfig() (string, error)

type DriverConfig

type DriverConfig struct {
	Host     string `default:"localhost"`
	Port     uint16 `type:"number" default:"3306"`
	User     string `required:"true"`
	Password string `required:"true" type:"password"`
	Database string `required:"true"`
}

func (DriverConfig) Excerpt

func (cfg DriverConfig) Excerpt() string