s3

package
v0.11.310 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 7, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client struct {
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(c Config) (*Client, error)

func (*Client) GetIngestrURI 

func (c *Client) GetIngestrURI() (string, error)

type Config 

type Config struct {
	BucketName      string
	PathToFile      string
	AccessKeyID     string
	SecretAccessKey string
	EndpointURL     string
	Layout          string
}

func (*Config) GetIngestrURI 

func (c *Config) GetIngestrURI() string

s3://<bucket_name>/<path_to_file>?access_key_id=<access_key_id>&secret_access_key=<secret_access_key>

type GetIngestrURI 

type GetIngestrURI interface {
	GetIngestrURI() string
}

type KeySensor added in v0.11.280 

type KeySensor struct {
	// contains filtered or unexported fields
}

func NewKeySensor added in v0.11.280 

func NewKeySensor(conn config.ConnectionAndDetailsGetter, sensorMode string) *KeySensor

func (*KeySensor) Run added in v0.11.280 

func (ks *KeySensor) Run(ctx context.Context, ti scheduler.TaskInstance) error

func (*KeySensor) RunTask added in v0.11.280 

func (ks *KeySensor) RunTask(ctx context.Context, p *pipeline.Pipeline, t *pipeline.Asset) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.