src

type AuditLogScanOpts struct {
	// filter
	DBs                []string
	QueryMinDurationMs int64
	QueryStates        []string
	OnlySelect         bool
	From, To           string

	Strict bool
}

type AuditLogScanner interface {
	Init()
	ScanOne(oneLine []byte) error
	Consume(w SqlWriter) (int, error)
	Close()
}

type BytesEncoder interface {
	Encode(b []byte) ([]byte, error)
}

type ClientSqls struct {
	Client string
	Sqls   []*ReplaySql
}

type ColumnStats struct {
	Name        string `yaml:"name"`
	Count       int64  `yaml:"-"`
	Ndv         int64  `yaml:"ndv"`
	NullCount   int64  `yaml:"null_count"`
	DataSize    int64  `yaml:"data_size"`
	AvgSizeByte int64  `yaml:"avg_size_byte"`
	Min         string `yaml:"min"`
	Max         string `yaml:"max"`
	Method      string `yaml:"method"`
}

type CreateParserListener struct {
	*parser.BaseDorisParserListener
	// contains filtered or unexported fields
}

type DBSchema struct {
	Name    string        `yaml:"db"`
	Schemas []*Schema     `yaml:"-"`
	Stats   []*TableStats `yaml:"tables,omitempty"`
}

type DummyEncoder struct {
}

type GenRule = gen.GenRule

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

type ReplayResult struct {
	Ts      string `json:"ts,omitempty"`
	QueryId string `json:"queryId"`

	ReturnRows     int    `json:"returnRows"`
	ReturnRowsHash string `json:"returnRowsHash,omitempty"`
	DurationMs     int64  `json:"durationMs"`
	Err            string `json:"err,omitempty"`
	Stmt           string `json:"stmt,omitempty"`
}

type ReplaySql struct {
	ReplaySqlMeta

	Stmt string
}

type ReplaySqlMeta struct {
	Ts_        string `json:"ts"`
	Ts         int64  `json:"-"`
	Client     string `json:"client"`
	User       string `json:"user"`
	Db         string `json:"db"`
	QueryId    string `json:"queryId"`
	DurationMs int64  `json:"durationMs,omitempty"`
}

type Schema struct {
	Name       string     `db:"TABLE_NAME"`
	Type       SchemaType `db:"TABLE_TYPE"`
	DB         string     `db:"TABLE_SCHEMA"`
	CreateStmt string     `db:"-"`
}

type SchemaType string

type SimpleAuditLogScanner struct {
	AuditLogScanOpts
	// contains filtered or unexported fields
}

type SqlWriter interface {
	io.Closer
	WriteSql(s string) error
}

type TableGen struct {
	Name       string
	Columns    []string
	DDLFile    string
	Rows       int
	RefToTable map[string]struct{} // ref generator to other tables

	StreamloadColMapping string
	// contains filtered or unexported fields
}

type TableStats struct {
	Name     string         `yaml:"name"`
	RowCount int64          `yaml:"row_count"`
	Columns  []*ColumnStats `yaml:"columns,omitempty"`
}

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