builderv2

Documentation

Index

• Variables
• type BufferNullDataPipe
  • func (t *BufferNullDataPipe) GetSQLs() (names []string, sqls []string)
• type ComputeTrace
  • func (t *ComputeTrace) GetSQLs() (names []string, sqls []string)
• type IStorageCreator
  • func GetTableCreator(cType int) (IStorageCreator, error)
• type Params
• type Storage
  • func (t *Storage) Execute(sqls []string) (string, error)
  • func (t *Storage) GetSQLs() ([]string, []string)
  • func (t *Storage) SetParams(req Params)

Variables

var (
	ErrorCreateType = errors.New("create type error")
)

Types

type BufferNullDataPipe

type BufferNullDataPipe struct {
	Storage
}

BufferNullDataPipe Link data calculation

func (*BufferNullDataPipe) GetSQLs

func (t *BufferNullDataPipe) GetSQLs() (names []string, sqls []string)

type ComputeTrace

type ComputeTrace struct {
	Storage
}

ComputeTrace Link data calculation

func (*ComputeTrace) GetSQLs

func (t *ComputeTrace) GetSQLs() (names []string, sqls []string)

type IStorageCreator

type IStorageCreator interface {

	// SetParams Initialization parameter
	SetParams(Params)

	// GetSQLs get distribution table sql
	GetSQLs() (names []string, sqls []string)

	// Execute SQL and return the results
	Execute([]string) (string, error)
}

func GetTableCreator

func GetTableCreator(cType int) (IStorageCreator, error)

GetTableCreator Through specific types of logging library access to build table objects, obtain four different SQL statements on the basis of the process to create

type Params

type Params struct {
	IsShard   bool // isShard Does it include shard
	IsReplica bool // isReplica Does it include replica

	Cluster  string // cluster name
	Database string // database name
	Table    string // table name

	TTL int // ttl Data expiration time, unit is the day

	DB *sql.DB // clickhouse instance
}

type Storage

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

func (*Storage) Execute

func (t *Storage) Execute(sqls []string) (string, error)

func (*Storage) GetSQLs

func (t *Storage) GetSQLs() ([]string, []string)

func (*Storage) SetParams

func (t *Storage) SetParams(req Params)