clickhouse

package

v0.10.4 Latest Latest Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

source:
  name: clickhouse
  config:
    connection_url: tcp://localhost:3306?username=admin&password=pass123&debug=true

Key	Value	Example	Description
`connection_url`	`string`	`tcp://localhost:3306?username=admin&password=pass123&debug=true`	URL to access the clickhouse server	required

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

This section is empty.

This section is empty.

This section is empty.

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

Config holds the connection URL for the extractor

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

Extractor manages the output stream and logger interface for the extractor

func New(logger log.Logger) *Extractor

New returns a pointer to an initialized Extractor Object

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

Extract checks if the extractor is configured and if the connection to the DB is successful and then starts the extraction process

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

Init initializes the extractor