i

Documentation

Index

• type Reader
• type ReaderParams
• type Storer
• type StorerParams
• type Switcher
• type SwitcherParams

Types

type Reader

type Reader interface {
	// Description read model
	Description() string

	Create() (tables []string, sqls []string, err error)
	Delete() error
	Detach() error
	Attach() error
}

type ReaderParams

type ReaderParams struct {
	// common
	CreateType int

	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
	Conn      *sql.DB // clickhouse

	// reader
	Brokers                 string
	Topics                  string
	GroupName               string
	KafkaNumConsumers       int
	KafkaSkipBrokenMessages int
}

type Storer

type Storer interface {
	// Description read model
	Description() string

	Create() (tables []string, sqls []string, err error)
	Delete() error
	Detach() error
	Attach() error
}

type StorerParams

type StorerParams struct {
	// common
	CreateType int

	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
	Conn      *sql.DB // clickhouse

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

}

type Switcher

type Switcher interface {
	// Description read model
	Description() string

	Create() (tables []string, sqls []string, err error)
	Delete() error
	Detach() error
	Attach() error
}

type SwitcherParams

type SwitcherParams struct {
	// common
	CreateType int

	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
	Conn      *sql.DB // clickhouse

	// switcher
	RawLogField         string
	RawLogFieldParent   string
	ParseIndexes        string
	ParseFields         string
	ParseTime           string
	ParseWhere          string
	IsRawLogFieldString bool
	CustomTimeField     string
}