testutils

Documentation

Index

• Constants
• func CopyFile(src, dst string) error
• func FunctionExists(ctx context.Context, t *testing.T, database, function, uri string) bool
• func GetGitRootDir() (string, error)
• 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 WriteKubeConfig(ctx context.Context, k *k3s.K3sContainer, dir string) (string, error)
• type Function
• type RowCount
• type Table
• type Uploader
  • 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)

Constants

const K3sManifests = "/var/lib/rancher/k3s/server/manifests/"

Functions

func CopyFile

func CopyFile(src, dst string) error

func FunctionExists

func FunctionExists(ctx context.Context, t *testing.T, database, function, uri string) bool

func GetGitRootDir

func GetGitRootDir() (string, error)

func TableExists

func TableExists(ctx context.Context, t *testing.T, database, table, uri string) bool

func TableHasRows

func TableHasRows(ctx context.Context, t *testing.T, database, table, uri string) bool

func WriteKubeConfig

func WriteKubeConfig(ctx context.Context, k *k3s.K3sContainer, dir string) (string, error)

Types

type Function

type Function struct {
	Name       string `kusto:"Name"`
	Parameters string `kusto:"Parameters"`
	Body       string `kusto:"Body"`
	Folder     string `kusto:"Folder"`
	DocString  string `kusto:"DocString"`
}

type RowCount

type RowCount struct {
	Count int64 `kusto:"Count"`
}

type Table

type Table struct {
	TableName    string `kusto:"TableName"`
	DatabaseName string `kusto:"DatabaseName"`
	Folder       string `kusto:"Folder"`
	DocString    string `kusto:"DocString"`
}

type Uploader

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

func NewUploadReader

func NewUploadReader(client *kusto.Client, database string, table string) *Uploader

NewUploadReader implements ingest.Ingestor

func (*Uploader) Close

func (u *Uploader) Close() error

func (*Uploader) FromFile

func (u *Uploader) FromFile(ctx context.Context, fPath string, options ...ingest.FileOption) (*ingest.Result, error)

func (*Uploader) FromReader

func (u *Uploader) FromReader(ctx context.Context, reader io.Reader, options ...ingest.FileOption) (*ingest.Result, error)