Versions in this module Expand all Collapse all v0 v0.2.0 Apr 7, 2026 Changes in this version + func InstallCrds(ctx context.Context, k *k3s.K3sContainer) error + func RelativePath(artifact string) (string, bool) v0.1.0 Jan 22, 2025 Changes in this version + const K3sManifests + func CopyFile(src, dst string) error + func ExtractManifests(to, from string, isolateKinds []string) error + func FunctionExists(ctx context.Context, t *testing.T, database, function, uri string) bool + func GetGitRootDir() (string, error) + func GetKubeConfig(ctx context.Context, k *k3s.K3sContainer) (*rest.Config, ctrlclient.Client, error) + func IntegrationTest(t *testing.T) + func TableExists(ctx context.Context, t *testing.T, database, table, uri string) bool + func TableHasRows(ctx context.Context, t *testing.T, database, table, uri string) bool + func VerifyTableSchema(ctx context.Context, t *testing.T, database, table, uri string, ...) + func WriteKubeConfig(ctx context.Context, k *k3s.K3sContainer, dir string) (string, error) + type Function struct + Body string + DocString string + Folder string + Name string + Parameters string + func GetFunction(ctx context.Context, t *testing.T, database, function, uri string) Function + type KqlSchema struct + ColumnName string + ColumnOrdinal int + ColumnType string + DataType string + type RowCount struct + Count int64 + type Table struct + DatabaseName string + DocString string + Folder string + TableName string + type TableSchema interface + CslColumns func() []string + TableName func() string + type Uploader struct + func NewUploadReader(client *kusto.Client, database string, table string) *Uploader + func (u *Uploader) Close() error + func (u *Uploader) FromFile(ctx context.Context, fPath string, options ...ingest.FileOption) (*ingest.Result, error) + func (u *Uploader) FromReader(ctx context.Context, reader io.Reader, options ...ingest.FileOption) (*ingest.Result, error)
Go to main page