sugar

Documentation

Index

• func DSN(endpoint, database string, secure bool) (s string)
• func GenerateDeclareSection[T *table.QueryParameters | []table.ParameterOption | []sql.NamedArg](params T) (string, error)
• func IsDirectoryExists(ctx context.Context, c scheme.Client, absTablePath string) (exists bool, _ error)
• func IsTableExists(ctx context.Context, c scheme.Client, absTablePath string) (exists bool, _ error)
• func LoadCertificatesFromFile(caFile string) ([]*x509.Certificate, error)
• func LoadCertificatesFromPem(bytes []byte) (certs []*x509.Certificate)
• func MakeRecursive(ctx context.Context, db dbForMakeRecursive, pathToCreate string) error
• func RemoveRecursive(ctx context.Context, db dbFoRemoveRecursive, pathToRemove string) error
• func ToYdbParam(param sql.NamedArg) (table.ParameterOption, error)

Functions

func DSN

func DSN(endpoint, database string, secure bool) (s string)

DSN makes connection string (data source name) by endpoint, database and secure

func GenerateDeclareSection

func GenerateDeclareSection[T *table.QueryParameters | []table.ParameterOption | []sql.NamedArg](
	params T,
) (string, error)

GenerateDeclareSection generates DECLARE section text in YQL query by params

Deprecated: use testutil.QueryBind(ydb.WithAutoDeclare()) helper

func IsDirectoryExists

func IsDirectoryExists(ctx context.Context, c scheme.Client, absTablePath string) (exists bool, _ error)

func IsTableExists

func IsTableExists(ctx context.Context, c scheme.Client, absTablePath string) (exists bool, _ error)

func LoadCertificatesFromFile

func LoadCertificatesFromFile(caFile string) ([]*x509.Certificate, error)

LoadCertificatesFromFile read and parse caFile and returns certificates

func LoadCertificatesFromPem

func LoadCertificatesFromPem(bytes []byte) (certs []*x509.Certificate)

LoadCertificatesFromPem parse bytes and returns certificates

func MakeRecursive

func MakeRecursive(ctx context.Context, db dbForMakeRecursive, pathToCreate string) error

MakeRecursive creates path inside database pathToCreate is a database root relative path MakeRecursive method equal bash command `mkdir -p ~/path/to/create` where `~` - is a root of database

func RemoveRecursive

func RemoveRecursive(ctx context.Context, db dbFoRemoveRecursive, pathToRemove string) error

RemoveRecursive remove selected directory or table names in database. pathToRemove is a database root relative path All database entities in prefix path will remove if names list is empty. Empty prefix means than use root of database. RemoveRecursive method equal bash command `rm -rf ~/path/to/remove` where `~` - is a root of database

func ToYdbParam

func ToYdbParam(param sql.NamedArg) (table.ParameterOption, error)

ToYdbParam converts

Deprecated: use testutil/QueryBind helper