Method GetPublishedStorage

context/context.go:417–504

GetPublishedStorage returns instance of PublishedStorage, or an error if the storage is not configured

(name string)

// GetPublishedStorage returns instance of PublishedStorage, or an error if the storage is not configured
func (context *AptlyContext) GetPublishedStorage(name string) (aptly.PublishedStorage, error) {
	context.Lock()
	defer context.Unlock()

	publishedStorage, ok := context.publishedStorages[name]
	if !ok {
		if name == "" {
			publishedStorage = files.NewPublishedStorage(filepath.Join(context.config().GetRootDir(), "public"), "hardlink", "")
		} else if strings.HasPrefix(name, "filesystem:") {
			params, ok := context.config().FileSystemPublishRoots[name[11:]]
			if !ok {
				return nil, fmt.Errorf("published local storage %v not configured", name[11:])
			}

			publishedStorage = files.NewPublishedStorage(params.RootDir, params.LinkMethod, params.VerifyMethod)
		} else if strings.HasPrefix(name, "s3:") {
			params, ok := context.config().S3PublishRoots[name[3:]]
			if !ok {
				return nil, fmt.Errorf("published S3 storage %v not configured", name[3:])
			}

			var err error
			publishedStorage, err = s3.NewPublishedStorage(
				params.AccessKeyID, params.SecretAccessKey, params.SessionToken,
				params.Region, params.Endpoint, params.Bucket, params.ACL, params.Prefix, params.StorageClass,
				params.EncryptionMethod, params.PlusWorkaround, params.DisableMultiDel,
				params.ForceSigV2, params.ForceVirtualHostedStyle, params.Debug)
			if err != nil {
				return nil, err
			}
		} else if strings.HasPrefix(name, "gcs:") {
			params, ok := context.config().GCSPublishRoots[name[4:]]
			if !ok {
				return nil, fmt.Errorf("published GCS storage %v not configured", name[4:])
			}

			var err error
			publishedStorage, err = gcs.NewPublishedStorage(
				params.Bucket, params.Prefix, params.CredentialsFile, params.ServiceAccountJSON,
				params.Project, params.Endpoint, params.ACL, params.StorageClass, params.EncryptionKey,
				params.DisableMultiDel, params.Debug)
			if err != nil {
				return nil, err
			}
		} else if strings.HasPrefix(name, "swift:") {
			params, ok := context.config().SwiftPublishRoots[name[6:]]
			if !ok {
				return nil, fmt.Errorf("published Swift storage %v not configured", name[6:])
			}

			var err error
			publishedStorage, err = swift.NewPublishedStorage(params.UserName, params.Password,
				params.AuthURL, params.Tenant, params.TenantID, params.Domain, params.DomainID, params.TenantDomain, params.TenantDomainID, params.Container, params.Prefix)
			if err != nil {
				return nil, err
			}
		} else if strings.HasPrefix(name, "azure:") {
			params, ok := context.config().AzurePublishRoots[name[6:]]