INNER CODE UNIT · Go
objectStoreClient
datastax-archive/kaskada · wren/main.go:183
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)
// Defines the authorization function as a client ID header
authFunc := auth.ClientIDHeaderAuthFunc(*defaultClientID, ownerClient)
// populate parallize config
// see: https://github.com/kaskada-ai/kaskada/issues/69
var parallelizeConfig *utils.ParallelizeConfig
if entConfig.DriverName() == "sqlite3" {