Help us shape the future of Go! Take the 2026 Go Developer Survey

starrocks

package
v0.11.783 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 19, 2026 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewColumnCheckOperator added in v0.11.681 

func NewColumnCheckOperator(manager config.ConnectionGetter) *ansisql.ColumnCheckOperator

func NewMaterializer added in v0.11.681 

func NewMaterializer(fullRefresh bool) *pipeline.Materializer

Types

type AcceptedValuesCheck added in v0.11.681 

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

func (*AcceptedValuesCheck) Check added in v0.11.681 

func (c *AcceptedValuesCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error

type BasicOperator added in v0.11.681 

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

func NewBasicOperator added in v0.11.681 

func NewBasicOperator(conn config.ConnectionGetter, extractor query.QueryExtractor, fullRefresh bool, hoister pipeline.DeclareHoister, parser *sqlparser.SQLParser) *BasicOperator

func (BasicOperator) Run added in v0.11.681 

func (o BasicOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error

func (BasicOperator) RunTask added in v0.11.681 

func (o BasicOperator) RunTask(ctx context.Context, p *pipeline.Pipeline, t *pipeline.Asset) error

type Client 

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

func NewClient 

func NewClient(c StarRocksConfig) (*Client, error)

func NewClientWithContext added in v0.11.681 

func NewClientWithContext(_ context.Context, c StarRocksConfig) (*Client, error)

func (*Client) BuildTableExistsQuery added in v0.11.681 

func (c *Client) BuildTableExistsQuery(tableName string) (string, error)

func (*Client) CreateSchemaIfNotExist added in v0.11.681 

func (c *Client) CreateSchemaIfNotExist(ctx context.Context, asset *pipeline.Asset) error

func (*Client) GetDatabaseSummary added in v0.11.681 

func (c *Client) GetDatabaseSummary(ctx context.Context) (*ansisql.DBDatabase, error)

func (*Client) GetIngestrURI 

func (c *Client) GetIngestrURI() (string, error)

func (*Client) Ping added in v0.11.681 

func (c *Client) Ping(ctx context.Context) error

func (*Client) RunQueryWithoutResult added in v0.11.681 

func (c *Client) RunQueryWithoutResult(ctx context.Context, query *query.Query) error

func (*Client) Select added in v0.11.681 

func (c *Client) Select(ctx context.Context, queryObj *query.Query) ([][]interface{}, error)

func (*Client) SelectWithSchema added in v0.11.681 

func (c *Client) SelectWithSchema(ctx context.Context, queryObj *query.Query) (*query.QueryResult, error)

type Config 

type Config struct {
	Username       string // Required
	Password       string // Optional
	Host           string // Required
	Port           int    // Optional - defaults to 9030 (FE MySQL protocol port)
	Database       string // Optional - default database for unqualified table names
	Catalog        string // Optional - external lakehouse catalog (Iceberg/Hudi/Hive/...)
	SSL            string // Optional - "true" or "skip-verify" to enable TLS
	HTTPPort       int    // Optional - FE HTTP port for Stream Load when used as a destination
	ReplicationNum int    // Optional - replica count for tables created as a destination
}

func (Config) GetIngestrURI 

func (c Config) GetIngestrURI() string

GetIngestrURI builds starrocks://user:pass@host:port/[catalog/]database?ssl=... A lone database maps to the internal catalog; catalog is prefixed only when a database is also set, matching ingestr's [catalog/]database path handling.

func (Config) ToDBConnectionURI added in v0.11.681 

func (c Config) ToDBConnectionURI() (string, error)

ToDBConnectionURI builds a go-sql-driver/mysql DSN for StarRocks, which speaks the MySQL wire protocol on its FE query port (9030 by default). The SSL field carries a driver-native tls mode ("true"/"skip-verify"/"preferred"), so it is forwarded straight to the driver's built-in tls parameter without registering a custom TLS config.

type DB added in v0.11.681 

type DB interface {
	Querier
	Selector
}

type PatternCheck added in v0.11.681 

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

func (*PatternCheck) Check added in v0.11.681 

func (c *PatternCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error

type Querier added in v0.11.681 

type Querier interface {
	RunQueryWithoutResult(ctx context.Context, query *query.Query) error
}

type SeedOperator added in v0.11.681 

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

func NewSeedOperator added in v0.11.681 

func NewSeedOperator(conn config.ConnectionGetter, renderer jinja.RendererInterface) *SeedOperator

func (SeedOperator) Run added in v0.11.681 

func (o SeedOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error

type Selector added in v0.11.681 

type Selector interface {
	Select(ctx context.Context, query *query.Query) ([][]interface{}, error)
	SelectWithSchema(ctx context.Context, queryObj *query.Query) (*query.QueryResult, error)
}

type StarRocksConfig added in v0.11.681 

type StarRocksConfig interface {
	GetIngestrURI() string
	ToDBConnectionURI() (string, error)
}

StarRocksConfig is the driver-level config the client depends on. It is implemented by the package-local Config (see config.go).

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.