s3queue

Documentation

Index

• func S3Queue(ctx context.Context, input *Input) (err error)
• type Driver
  • func NewDriver(ctx context.Context, sqsClient sqsiface.SQSAPI, input *DriverInput) (*Driver, error)
  • func (d *Driver) Done()
  • func (d *Driver) Wait() error
  • func (d *Driver) Write(event *events.S3Event)
• type DriverInput
• type Input

Functions

func S3Queue

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

Types

type Driver

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

func NewDriver

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

func (*Driver) Done

func (d *Driver) Done()

func (*Driver) Wait

func (d *Driver) Wait() error

func (*Driver) Write

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

type DriverInput

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

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
}