42 lines
1.3 KiB
Go
42 lines
1.3 KiB
Go
package config
|
|
|
|
import "github.com/spf13/viper"
|
|
|
|
type IngesterS3Config struct {
|
|
SessionUploadBucket string
|
|
SessionUploadBucketClientMap map[string]string
|
|
}
|
|
|
|
type CoreS3Config struct {
|
|
SessionUploadBucketClientMap map[string]string
|
|
VideoUploadBucketClientMap map[string]string
|
|
WebSessionBucketClientMap map[string]string
|
|
MinWebVersionSupportingFolderUpload int64
|
|
}
|
|
|
|
type CollectorS3Config struct {
|
|
WebSessionBucketClientMap map[string]string
|
|
}
|
|
|
|
func NewIngesterS3Config() *IngesterS3Config {
|
|
return &IngesterS3Config{
|
|
SessionUploadBucket: viper.GetString("s3.session.upload.bucket"),
|
|
SessionUploadBucketClientMap: viper.GetStringMapString("s3.session.upload.bucket.client.map"),
|
|
}
|
|
}
|
|
|
|
func NewCoreS3Config() *CoreS3Config {
|
|
return &CoreS3Config{
|
|
SessionUploadBucketClientMap: viper.GetStringMapString("s3.session.upload.bucket"),
|
|
VideoUploadBucketClientMap: viper.GetStringMapString("s3.video.upload.bucket"),
|
|
WebSessionBucketClientMap: viper.GetStringMapString("s3.web.session.upload.bucket.client.map"),
|
|
MinWebVersionSupportingFolderUpload: viper.GetInt64("s3.min.web.version.supporting.folder.upload"),
|
|
}
|
|
}
|
|
|
|
func NewCollectorS3Config() *CollectorS3Config {
|
|
return &CollectorS3Config{
|
|
WebSessionBucketClientMap: viper.GetStringMapString("s3.web.session.upload.bucket.client.map"),
|
|
}
|
|
}
|