s3queue

package
v1.16.0 Latest Latest
Warning

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

Go to latest
Published: Mar 10, 2021 License: AGPL-3.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func S3Queue

func S3Queue(ctx context.Context, input *Input) (err error)

Types

type Driver added in v1.15.0

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

func NewDriver added in v1.15.0

func NewDriver(ctx context.Context, sqsClient sqsiface.SQSAPI, input *DriverInput) (*Driver, error)

func (*Driver) Done added in v1.15.0

func (d *Driver) Done()

func (*Driver) Wait added in v1.15.0

func (d *Driver) Wait() error

func (*Driver) Write added in v1.15.0

func (d *Driver) Write(event *events.S3Event)

type DriverInput added in v1.15.0

type DriverInput struct {
	Logger         *zap.SugaredLogger
	Account        string
	QueueName      string
	Concurrency    int
	FilesPerSecond float64       // if non-zero,  attempt to send at this rate
	Duration       time.Duration // if set, stop after this much elapsed time
}

type Input added in v1.15.0

type Input struct {
	DriverInput
	Session  *session.Session
	S3Path   string
	S3Region string
	Limit    uint64
	Loop     bool
	Stats    s3list.Stats // passed in so we can get stats if canceled
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL