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

doris

package
v0.11.796 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewColumnCheckOperator

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

func NewMaterializer

func NewMaterializer(fullRefresh bool) *pipeline.Materializer

Types

type AcceptedValuesCheck

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

func (*AcceptedValuesCheck) Check

type BasicOperator

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

func NewBasicOperator

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

func (BasicOperator) Run

func (BasicOperator) RunTask

type Client

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

func NewClient

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

func NewClientWithContext

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

func (*Client) BuildTableExistsQuery

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

func (*Client) CreateSchemaIfNotExist

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

func (*Client) GetDatabaseSummary

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

func (*Client) GetIngestrURI

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

func (*Client) Ping

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

func (*Client) RunQueryWithoutResult

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

func (*Client) Select

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

func (*Client) SelectWithSchema

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

type Config

type Config struct {
	Username    string
	Password    string
	Host        string
	Port        int
	Database    string
	Driver      string
	SslCaPath   string
	SslCertPath string
	SslKeyPath  string
}

func (Config) GetIngestrURI

func (c Config) GetIngestrURI() string

func (Config) ToDBConnectionURI

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

type DB

type DB interface {
	Querier
	Selector
}

type DorisConfig

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

type PatternCheck

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

func (*PatternCheck) Check

type Querier

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

type SeedOperator

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

func NewSeedOperator

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

func (SeedOperator) Run

type Selector

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL