source

Documentation

Index

• type ClickHouse
  • func NewClickHouse(s *Source) *ClickHouse
  • func (c *ClickHouse) ClusterInfo() (isCluster, isShard, isReplica int, clusters []string, err error)
  • func (c *ClickHouse) Columns(database, table string) (res []view.Column, err error)
  • func (c *ClickHouse) Databases() (res []string, err error)
  • func (c *ClickHouse) Exec(s string) (err error)
  • func (c *ClickHouse) Query(s string) (res []map[string]interface{}, err error)
  • func (c *ClickHouse) Tables(database string) (res []string, err error)
• type Databend
  • func NewDatabend(s *Source) *Databend
  • func (c *Databend) ClusterInfo() (isCluster, isShard, isReplica int, clusters []string, err error)
  • func (c *Databend) Columns(database, table string) (res []view.Column, err error)
  • func (d *Databend) Databases() (res []string, err error)
  • func (c *Databend) Exec(s string) (err error)
  • func (c *Databend) Query(s string) (res []map[string]interface{}, err error)
  • func (c *Databend) Tables(database string) (res []string, err error)
• type MySQL
  • func NewMySQL(s *Source) *MySQL
  • func (c *MySQL) ClusterInfo() (isCluster, isShard, isReplica int, clusters []string, err error)
  • func (c *MySQL) Columns(database, table string) (res []view.Column, err error)
  • func (c *MySQL) Databases() (res []string, err error)
  • func (c *MySQL) Exec(s string) (err error)
  • func (c *MySQL) Query(s string) (res []map[string]interface{}, err error)
  • func (c *MySQL) Tables(database string) (res []string, err error)
• type Operator
  • func Instantiate(s *Source) Operator
• type Source
  • func (s *Source) GetDSN() string

Types

type ClickHouse

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

func NewClickHouse

func NewClickHouse(s *Source) *ClickHouse

func (*ClickHouse) ClusterInfo

func (c *ClickHouse) ClusterInfo() (isCluster, isShard, isReplica int, clusters []string, err error)

func (*ClickHouse) Columns

func (c *ClickHouse) Columns(database, table string) (res []view.Column, err error)

func (*ClickHouse) Databases

func (c *ClickHouse) Databases() (res []string, err error)

func (*ClickHouse) Exec

func (c *ClickHouse) Exec(s string) (err error)

func (*ClickHouse) Query

func (c *ClickHouse) Query(s string) (res []map[string]interface{}, err error)

func (*ClickHouse) Tables

func (c *ClickHouse) Tables(database string) (res []string, err error)

type Databend

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

func NewDatabend

func NewDatabend(s *Source) *Databend

func (*Databend) ClusterInfo

func (c *Databend) ClusterInfo() (isCluster, isShard, isReplica int, clusters []string, err error)

func (*Databend) Columns

func (c *Databend) Columns(database, table string) (res []view.Column, err error)

func (*Databend) Databases

func (d *Databend) Databases() (res []string, err error)

func (*Databend) Exec

func (c *Databend) Exec(s string) (err error)

func (*Databend) Query

func (c *Databend) Query(s string) (res []map[string]interface{}, err error)

func (*Databend) Tables

func (c *Databend) Tables(database string) (res []string, err error)

type MySQL

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

func NewMySQL

func NewMySQL(s *Source) *MySQL

func (*MySQL) ClusterInfo

func (c *MySQL) ClusterInfo() (isCluster, isShard, isReplica int, clusters []string, err error)

func (*MySQL) Columns

func (c *MySQL) Columns(database, table string) (res []view.Column, err error)

func (*MySQL) Databases

func (c *MySQL) Databases() (res []string, err error)

func (*MySQL) Exec

func (c *MySQL) Exec(s string) (err error)

func (*MySQL) Query

func (c *MySQL) Query(s string) (res []map[string]interface{}, err error)

func (*MySQL) Tables

func (c *MySQL) Tables(database string) (res []string, err error)

type Operator

type Operator interface {
	Databases() ([]string, error)
	Tables(string) ([]string, error)
	Columns(string, string) ([]view.Column, error)
	Query(s string) (res []map[string]interface{}, err error)
	Exec(s string) error
	ClusterInfo() (isCluster, isShard, isReplica int, clusters []string, err error)
}

func Instantiate

func Instantiate(s *Source) Operator

type Source

type Source struct {
	DSN      string
	URL      string
	UserName string
	Password string
	Typ      int
}

func (*Source) GetDSN

func (s *Source) GetDSN() string