cassandra

README

cassandra

Usage

source:
  name: cassandra
  config:
    user_id: admin
    password: 1234
    host: localhost
    port: 9042

Inputs

Key	Value	Example	Description
user_id	string	admin	User ID to access the cassandra server	required
password	string	1234	Password for the cassandra Server	required
host	string	127.0.0.1	The Host address at which server is running	required
port	int	9042	The Port number at which server is running	required

Outputs

Field	Sample Value
resource.urn	my_keyspace.my_table
resource.name	my_table
resource.service	cassandra
description	table description
profile.total_rows	2100
schema	[]Column

Column

Field	Sample Value
name	total_price
type	text

Contributing

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

Documentation

Index

• type Config
• type Extractor
  • func New(logger log.Logger) *Extractor
  • func (e *Extractor) Extract(_ context.Context, emit plugins.Emit) error
  • func (e *Extractor) Init(ctx context.Context, config plugins.Config) error

Types

type Config

type Config struct {
	UserID   string `mapstructure:"user_id" validate:"required"`
	Password string `mapstructure:"password" validate:"required"`
	Host     string `mapstructure:"host" validate:"required"`
	Port     int    `mapstructure:"port" validate:"required"`
}

Config holds the set of configuration for the cassandra extractor

type Extractor

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

Extractor manages the extraction of data from cassandra

func New

func New(logger log.Logger) *Extractor

New returns a pointer to an initialized Extractor Object

func (*Extractor) Extract

func (e *Extractor) Extract(_ 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 (*Extractor) Init

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

Init initializes the extractor