blob_storage

Documentation

Index

• Constants
• type AzureBlobStorageSource
  • func (s *AzureBlobStorageSource) Close() error
  • func (s *AzureBlobStorageSource) DiscoverArtifacts(ctx context.Context) error
  • func (s *AzureBlobStorageSource) DownloadArtifact(ctx context.Context, info *types.ArtifactInfo) error
  • func (s *AzureBlobStorageSource) Identifier() string
  • func (s *AzureBlobStorageSource) Init(ctx context.Context, params *row_source.RowSourceParams, ...) error
• type AzureBlobStorageSourceConfig
  • func (a *AzureBlobStorageSourceConfig) Identifier() string
  • func (a *AzureBlobStorageSourceConfig) Validate() error

Constants

const AzureBlobStorageSourceIdentifier = "azure_blob_storage"

Types

type AzureBlobStorageSource

type AzureBlobStorageSource struct {
	artifact_source.ArtifactSourceImpl[*AzureBlobStorageSourceConfig, *config.AzureConnection]
	// contains filtered or unexported fields
}

AzureBlobStorageSource is a [ArtifactSource] implementation that reads artifacts from an Azure Blob Storage container

func (*AzureBlobStorageSource) Close

func (s *AzureBlobStorageSource) Close() error

func (*AzureBlobStorageSource) DiscoverArtifacts

func (s *AzureBlobStorageSource) DiscoverArtifacts(ctx context.Context) error

func (*AzureBlobStorageSource) DownloadArtifact

func (s *AzureBlobStorageSource) DownloadArtifact(ctx context.Context, info *types.ArtifactInfo) error

func (*AzureBlobStorageSource) Identifier

func (s *AzureBlobStorageSource) Identifier() string

func (*AzureBlobStorageSource) Init

func (s *AzureBlobStorageSource) Init(ctx context.Context, params *row_source.RowSourceParams, opts ...row_source.RowSourceOption) error

type AzureBlobStorageSourceConfig

type AzureBlobStorageSourceConfig struct {
	artifact_source_config.ArtifactSourceConfigImpl

	// required to allow partial decoding
	Remain hcl.Body `hcl:",remain" json:"-"`

	AccountName string `hcl:"account_name"`
	Container   string `hcl:"container"`

	// TODO: determine if these are required
	Prefix *string `hcl:"prefix,optional"`
}

func (*AzureBlobStorageSourceConfig) Identifier

func (a *AzureBlobStorageSourceConfig) Identifier() string

func (*AzureBlobStorageSourceConfig) Validate

func (a *AzureBlobStorageSourceConfig) Validate() error