s3list

Documentation

Index

• func GetS3Region(sess *session.Session, s3Path string) (string, error)
• func ListPath(ctx context.Context, input *Input) (err error)
• type Input
• type Stats

Functions

func GetS3Region

func GetS3Region(sess *session.Session, s3Path string) (string, error)

func ListPath

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

ListPath given an s3path (e.g., s3://mybucket/myprefix) list files and send to notifyChan

Types

type Input

type Input struct {
	Logger   *zap.SugaredLogger
	S3Client s3iface.S3API
	S3Path   string
	Limit    uint64
	Write    func(*events.S3Event) // called on each event
	Done     func()                // called when complete
	Stats    *Stats
}

type Stats

type Stats struct {
	NumFiles uint64
	NumBytes uint64
}