mysql

package
v0.10.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 19, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

README

mysql

Usage

source:
  name: mysql
  config:
    connection_url: admin:pass123@tcp(localhost:3306)/
    identifier: my-mysql

Inputs

Key Value Example Description
connection_url string admin:pass123@tcp(localhost:3306)/ URL to access the mysql server required
identifier string my-mysql Instance alias, the value will be used as part of the urn component required

Outputs

Field Sample Value
resource.urn mysql::my-mysql/my_database/my_table
resource.name my_table
resource.service mysql
description table description
profile.total_rows 2100
schema []Column
Column
Field Sample Value
name total_price
description item's total price
data_type decimal
is_nullable true
length 12,2

Contributing

Refer to the contribution guidelines for information on contributing to this module.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	ConnectionURL string `mapstructure:"connection_url" validate:"required"`
}

Config holds the connection URL for the extractor

type Extractor

type Extractor struct {
	plugins.BaseExtractor
	// contains filtered or unexported fields
}

Extractor manages the extraction of data from MySQL

func New

func New(logger log.Logger) *Extractor

New returns a pointer to an initialized Extractor Object

func (*Extractor) Extract

func (e *Extractor) Extract(ctx context.Context, emit plugins.Emit) error

Extract extracts the data from the MySQL server and collected through the emitter

func (*Extractor) Init

func (e *Extractor) Init(ctx context.Context, config plugins.Config) (err error)

Init initializes the extractor

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL