Documentation
¶
Index ¶
- Constants
- type BenchmarkExecutor
- type StarRocksConverter
- type StarRocksPlugin
- func (p *StarRocksPlugin) ConvertSchema(schema *models.Schema) (*models.Schema, error)
- func (p *StarRocksPlugin) ExecuteQuery(ctx context.Context, req *proto.ExecuteQueryRequest) (*proto.ExecuteQueryResponse, error)
- func (p *StarRocksPlugin) GetBenchmarkExecutor() (*BenchmarkExecutor, error)
- func (p *StarRocksPlugin) GetName() string
- func (p *StarRocksPlugin) Name() string
- func (p *StarRocksPlugin) TranslateQuery(sql string) (string, error)
- func (p *StarRocksPlugin) Version() string
- type StarRocksTranslator
Constants ¶
const PluginName = "starrocks"
PluginName exported
const PluginVersion = "1.0.0"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BenchmarkExecutor ¶
type BenchmarkExecutor struct {
// contains filtered or unexported fields
}
func NewBenchmarkExecutor ¶
func NewBenchmarkExecutor(conn *sql.DB) *BenchmarkExecutor
func (*BenchmarkExecutor) ExecuteQuery ¶
func (e *BenchmarkExecutor) ExecuteQuery(ctx context.Context, req *proto.ExecuteQueryRequest) (*proto.ExecuteQueryResponse, error)
type StarRocksConverter ¶
type StarRocksConverter struct{}
StarRocksConverter handles schema conversion from generic/MySQL to StarRocks.
func NewSchemaConverter ¶
func NewSchemaConverter() *StarRocksConverter
NewSchemaConverter creates a new instance of StarRocksConverter.
func (*StarRocksConverter) ConvertSchema ¶
ConvertSchema converts the source schema to a StarRocks compatible schema.
type StarRocksPlugin ¶
type StarRocksPlugin struct {
// contains filtered or unexported fields
}
StarRocksPlugin implements the DatabasePlugin interface.
func (*StarRocksPlugin) ConvertSchema ¶
ConvertSchema converts a schema to StarRocks schema.
func (*StarRocksPlugin) ExecuteQuery ¶
func (p *StarRocksPlugin) ExecuteQuery(ctx context.Context, req *proto.ExecuteQueryRequest) (*proto.ExecuteQueryResponse, error)
func (*StarRocksPlugin) GetBenchmarkExecutor ¶
func (p *StarRocksPlugin) GetBenchmarkExecutor() (*BenchmarkExecutor, error)
GetBenchmarkExecutor returns the benchmark executor.
func (*StarRocksPlugin) GetName ¶
func (p *StarRocksPlugin) GetName() string
GetName alias for interface compatibility
func (*StarRocksPlugin) Name ¶
func (p *StarRocksPlugin) Name() string
Name returns the name of the plugin.
func (*StarRocksPlugin) TranslateQuery ¶
func (p *StarRocksPlugin) TranslateQuery(sql string) (string, error)
TranslateQuery translates a SQL query to StarRocks dialect.
func (*StarRocksPlugin) Version ¶
func (p *StarRocksPlugin) Version() string
Version returns the version of the plugin.
type StarRocksTranslator ¶
type StarRocksTranslator struct{}
StarRocksTranslator handles query translation from MySQL dialect to StarRocks dialect.