INNER CODE UNIT · Go

entConfig

datastax-archive/kaskada · wren/main.go:176

	entConfig := client.NewEntConfig(*dbDialect, dbName, dbHost, dbInMemory, dbPath, dbPass, dbPort, dbUser, dbUseSSL)
	entClient := client.NewEntClient(ctx, entConfig)
	if *debugDB {
		entClient = entClient.Debug()
	}
	defer entClient.Close()

	objectStoreClient := client.NewObjectStoreClient(*env, *objectStoreType, *objectStoreBucket, *objectStorePath, *objectStoreEndpoint, *objectStoreDisableSSL, *objectStoreForcePathStyle)

	ownerClient := internal.NewOwnerClient(entClient)
	dataTokenClient := internal.NewDataTokenClient(entClient)
	kaskadaTableClient := internal.NewKaskadaTableClient(entClient)
	kaskadaViewClient := internal.NewKaskadaViewClient(entClient)
	materializationClient := internal.NewMaterializationClient(entClient)
	kaskadaQueryClient := internal.NewKaskadaQueryClient(entClient)
	prepareJobClient := internal.NewPrepareJobClient(entClient)

	computeClients := client.CreateComputeClients(fileServiceConfig, prepareServiceConfig, queryServiceConfig)

View source record →

📰 Research Paper
Loading…
⏳ Fetching content…