Documentation
¶
Index ¶
- Constants
- type GcpStorageBucketSource
- func (s *GcpStorageBucketSource) Close() error
- func (s *GcpStorageBucketSource) DiscoverArtifacts(ctx context.Context) error
- func (s *GcpStorageBucketSource) DownloadArtifact(ctx context.Context, info *types.ArtifactInfo) error
- func (s *GcpStorageBucketSource) Identifier() string
- func (s *GcpStorageBucketSource) Init(ctx context.Context, params *row_source.RowSourceParams, ...) error
- type GcpStorageBucketSourceConfig
Constants ¶
View Source
const GcpStorageBucketSourceIdentifier = "gcp_storage_bucket"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GcpStorageBucketSource ¶
type GcpStorageBucketSource struct {
artifact_source.ArtifactSourceImpl[*GcpStorageBucketSourceConfig, *config.GcpConnection]
// contains filtered or unexported fields
}
GcpStorageBucketSource is a [ArtifactSource] implementation that reads artifacts from a GCP Storage bucket
func (*GcpStorageBucketSource) Close ¶
func (s *GcpStorageBucketSource) Close() error
func (*GcpStorageBucketSource) DiscoverArtifacts ¶
func (s *GcpStorageBucketSource) DiscoverArtifacts(ctx context.Context) error
func (*GcpStorageBucketSource) DownloadArtifact ¶
func (s *GcpStorageBucketSource) DownloadArtifact(ctx context.Context, info *types.ArtifactInfo) error
func (*GcpStorageBucketSource) Identifier ¶
func (s *GcpStorageBucketSource) Identifier() string
func (*GcpStorageBucketSource) Init ¶
func (s *GcpStorageBucketSource) Init(ctx context.Context, params *row_source.RowSourceParams, opts ...row_source.RowSourceOption) error
type GcpStorageBucketSourceConfig ¶
type GcpStorageBucketSourceConfig struct {
artifact_source_config.ArtifactSourceConfigImpl
// required to allow partial decoding
Remain hcl.Body `hcl:",remain" json:"-"`
Bucket string `hcl:"bucket"`
Prefix *string `hcl:"prefix,optional"`
}
GcpStorageBucketSourceConfig is the configuration for GcpStorageBucketSource
func (*GcpStorageBucketSourceConfig) Identifier ¶
func (*GcpStorageBucketSourceConfig) Identifier() string
func (*GcpStorageBucketSourceConfig) Validate ¶
func (g *GcpStorageBucketSourceConfig) Validate() error
Click to show internal directories.
Click to hide internal directories.