datasource

package

v0.0.0-...-b105dfa Latest Latest Go to latest Published: Feb 7, 2024 License: MIT Imports: 16 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

Repository

github.com/arturom/datadiff

Links

Open Source Insights

Documentation ¶

Index ¶

type DataSource
type DataSourceFactory
- func (f DataSourceFactory) Create(driver, cnxString, config string) (DataSource, error)
type ES0DataSource
- func NewES0DataSource(client *elastic.Client, index, typeName, field string) *ES0DataSource
type Elasticsearch7DataSource
- func NewElasticsearch7DataSource(client *elasticsearch.Client, index, field string) *Elasticsearch7DataSource
type Elasticsearch8DataSource
- func NewElasticsearch8DataSource(client *elasticsearch.TypedClient, index, field string) *Elasticsearch8DataSource
type MysqlDataSource

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DataSource ¶

type DataSource interface {
	FetchHistogramAll(interval int) (histogram.Histogram, error)
	FetchHistogramRange(gte, lt, interval int) (histogram.Histogram, error)
	FetchIDRange(gte, lt int) ([]int, error)
}

DataSource describes a source of data containing records with numeric IDs

type DataSourceFactory ¶

type DataSourceFactory struct{}

DataSourceFactory instantiates data sources

func (DataSourceFactory) Create ¶

func (f DataSourceFactory) Create(driver, cnxString, config string) (DataSource, error)

Create instantiates a data source based on the driver given

type ES0DataSource ¶

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

ES0DataSource uses an Elasticsearch 0.90 backend to implement the datasource interface

func NewES0DataSource ¶

func NewES0DataSource(client *elastic.Client, index, typeName, field string) *ES0DataSource

func (ES0DataSource) FetchHistogramAll ¶

func (s ES0DataSource) FetchHistogramAll(interval int) (histogram.Histogram, error)

FetchHistogramAll fetches a histogram of all IDs in an index

func (ES0DataSource) FetchHistogramRange ¶

func (s ES0DataSource) FetchHistogramRange(gte, lt, interval int) (histogram.Histogram, error)

FetchHistogramRange fetches a histogram of a selective range of IDs in an index

func (ES0DataSource) FetchIDRange ¶

func (s ES0DataSource) FetchIDRange(gte, lt int) ([]int, error)

FetchIDRange fetches all the existing IDs in a given range

type Elasticsearch7DataSource ¶

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

func NewElasticsearch7DataSource ¶

func NewElasticsearch7DataSource(client *elasticsearch.Client, index, field string) *Elasticsearch7DataSource

func (Elasticsearch7DataSource) FetchHistogramAll ¶

func (es Elasticsearch7DataSource) FetchHistogramAll(interval int) (h.Histogram, error)

func (Elasticsearch7DataSource) FetchHistogramRange ¶

func (es Elasticsearch7DataSource) FetchHistogramRange(gte, lte, interval int) (h.Histogram, error)

func (Elasticsearch7DataSource) FetchIDRange ¶

func (es Elasticsearch7DataSource) FetchIDRange(gte, lt int) ([]int, error)

type Elasticsearch8DataSource ¶

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

func NewElasticsearch8DataSource ¶

func NewElasticsearch8DataSource(client *elasticsearch.TypedClient, index, field string) *Elasticsearch8DataSource

func (Elasticsearch8DataSource) FetchHistogramAll ¶

func (es Elasticsearch8DataSource) FetchHistogramAll(interval int) (h.Histogram, error)

func (Elasticsearch8DataSource) FetchHistogramRange ¶

func (es Elasticsearch8DataSource) FetchHistogramRange(gte, lte, interval int) (h.Histogram, error)

func (Elasticsearch8DataSource) FetchIDRange ¶

func (es Elasticsearch8DataSource) FetchIDRange(gte, lt int) ([]int, error)

type MysqlDataSource ¶

type MysqlDataSource struct {
	DB         *sql.DB
	Tablename  string
	FieldName  string
	Conditions []string
}

func (MysqlDataSource) FetchHistogramAll ¶

func (s MysqlDataSource) FetchHistogramAll(interval int) (histogram.Histogram, error)

func (MysqlDataSource) FetchHistogramRange ¶

func (s MysqlDataSource) FetchHistogramRange(gte, lt, interval int) (histogram.Histogram, error)

func (MysqlDataSource) FetchIDRange ¶

func (s MysqlDataSource) FetchIDRange(gte, lt int) ([]int, error)

Source Files ¶

View all Source files

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