clickhouse

type ClickhouseQueryLogSchema struct {
	QueryType                  string    `db:"type"`
	EventTimeMicroseconds      time.Time `db:"event_time_microseconds"`
	QueryStartTimeMicroseconds time.Time `db:"query_start_time_microseconds"`

	// IO Information
	ReadRows  uint64 `db:"read_rows"`
	ReadBytes uint64 `db:"read_bytes"`

	WrittenRows  uint64 `db:"written_rows"`
	WrittenBytes uint64 `db:"written_bytes"`

	ResultRows  uint64 `db:"result_rows"`
	ResultBytes uint64 `db:"result_bytes"`

	// Query Information
	MemoryUsage     uint64   `db:"memory_usage"`
	CurrentDatabase string   `db:"current_database"`
	Query           string   `db:"normalized_query"`
	QueryHash       uint64   `db:"query_hash"` // cityHash64 of normalizeQuery(query)
	QueryKind       string   `db:"query_kind"`
	Databases       []string `db:"databases"`
	Tables          []string `db:"tables"`
	Columns         []string `db:"columns"`
	Projections     []string `db:"projections"`
	Views           []string `db:"views"`
	ExceptionCode   int32    `db:"exception_code"`
	Exception       string   `db:"exception"`
	StackTrace      string   `db:"stack_trace"`

	// Client Information
	InitialUser                       string    `db:"initial_user"`
	InitialQueryId                    string    `db:"initial_query_id"`
	InitialAddress                    *net.IP   `db:"initial_address"`
	InitialPort                       uint16    `db:"initial_port"`
	InitialQueryStartTimeMicroseconds time.Time `db:"initial_query_start_time_microseconds"`
	OsUser                            string    `db:"os_user"`
	ClientHostname                    string    `db:"client_hostname"`
	ClientName                        string    `db:"client_name"`
	ClientRevision                    uint32    `db:"client_revision"`
	ClientRevisionMajor               uint32    `db:"client_version_major"`
	ClientRevisionMinor               uint32    `db:"client_version_minor"`
	ClientRevisionPatch               uint32    `db:"client_version_patch"`
	DistributedDepth                  uint64    `db:"distributed_depth"`
}

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

type ClickhouseScrapperConf struct {
	dwhexecclickhouse.ClickhouseConf
	DatabaseName string
}