Documentation ¶
Index ¶
- Constants
- func CleanDatabase(dbDialect *string)
- func DecodeAvroFromBytes(schema string, payload []byte) (interface{}, error)
- func DeleteAllExistingObjects(objectStoreType string, objectStoreBucket string, objectStorePath string)
- func DeleteTestFile(fileName string)
- func DownloadCSV(url string) [][]string
- func DownloadParquet(url string) []interface{}
- func EmptyOutputPath(subPath string)
- func EncodeAvroToBytes(schema string, datum interface{}) ([]byte, error)
- func EventuallyListOutputFiles(subPath string, g types.Gomega) []string
- func GetCSV(filePath string) [][]string
- func GetCreateQueryResponses(stream v1alpha.QueryService_CreateQueryClient) ([]*v1alpha.CreateQueryResponse, error)
- func GetMergedCreateQueryResponse(stream v1alpha.QueryService_CreateQueryClient) (*v1alpha.CreateQueryResponse, error)
- func GetOutputPathURI(subPath string) string
- func GetTestFileURI(fileName string) string
- func ListOutputFiles(subPath string) []string
- func LoadTestFileIntoTable(ctx context.Context, conn *grpc.ClientConn, table *v1alpha.Table, ...) *v1alpha.LoadDataResponse
- func LoadTestFilesIntoTable(ctx context.Context, conn *grpc.ClientConn, table *v1alpha.Table, ...) []*v1alpha.LoadDataResponse
- func LogLn(format string, args ...any)
- func ReadTestFile(fileName string) []byte
- func TestsAreRunningLocally() bool
- func TestsAreRunningLocallyInDocker() bool
- func WriteTestFile(fileName string, data []byte)
- type HostConfig
- type MinioHelper
Constants ¶
View Source
const ( Object_store_type_local = "local" Object_store_type_s3 = "s3" Object_store_type_gcs = "gcs" Object_store_type_azure = "azure" )
Variables ¶
This section is empty.
Functions ¶
func CleanDatabase ¶
func CleanDatabase(dbDialect *string)
func DecodeAvroFromBytes ¶
DecodeAvroFromBytes convert bytes to interface{} datum
func DownloadCSV ¶
func DownloadParquet ¶
func DownloadParquet(url string) []interface{}
func EncodeAvroToBytes ¶
EncodeAvroToBytes convert interface{} datum to bytes
func EventuallyListOutputFiles ¶
Lists all files at the output path
func GetCreateQueryResponses ¶
func GetCreateQueryResponses(stream v1alpha.QueryService_CreateQueryClient) ([]*v1alpha.CreateQueryResponse, error)
func GetMergedCreateQueryResponse ¶
func GetMergedCreateQueryResponse(stream v1alpha.QueryService_CreateQueryClient) (*v1alpha.CreateQueryResponse, error)
func GetTestFileURI ¶
Gets a file URI for file in the testdata path
func ListOutputFiles ¶
Lists all files at the output path
func LoadTestFileIntoTable ¶
func LoadTestFileIntoTable(ctx context.Context, conn *grpc.ClientConn, table *v1alpha.Table, fileURI string) *v1alpha.LoadDataResponse
loads a file from testdata/ into a table.
func LoadTestFilesIntoTable ¶
func LoadTestFilesIntoTable(ctx context.Context, conn *grpc.ClientConn, table *v1alpha.Table, fileNames ...string) []*v1alpha.LoadDataResponse
loads files from testdata/ into a table.
func TestsAreRunningLocally ¶
func TestsAreRunningLocally() bool
func TestsAreRunningLocallyInDocker ¶
func TestsAreRunningLocallyInDocker() bool
func WriteTestFile ¶
Writes a file to the testdata path
Types ¶
type HostConfig ¶
HostConfig holds the data needed to connect to a particular grpc server
func (HostConfig) GetContextCancelConnection ¶
func (c HostConfig) GetContextCancelConnection(seconds int) (context.Context, context.CancelFunc, *grpc.ClientConn)
func (HostConfig) GetGrpcConnection ¶
func (c HostConfig) GetGrpcConnection(ctx context.Context) *grpc.ClientConn
Click to show internal directories.
Click to hide internal directories.