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