Documentation
¶
Index ¶
- func DelimiterStrategy(app *config.S3StreamingLister, prefix *string, next *string, chi myq.MyQueue)
- func Frontend(app *config.S3StreamingLister, cho myq.MyQueue, chstatus myq.MyQueue)
- func S3Lister(app *config.S3StreamingLister, input s3.ListObjectsV2Input, chi myq.MyQueue, ...)
- func S3ListerWorker(app *config.S3StreamingLister, cho myq.MyQueue, chstatus myq.MyQueue) myq.MyQueue
- func SingleLetterStrategy(app *config.S3StreamingLister, prefix *string, chi myq.MyQueue)
- func Sqlite(app *config.S3StreamingLister, cho myq.MyQueue, chStatus myq.MyQueue)
- type Complete
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DelimiterStrategy ¶
func S3Lister ¶
func S3Lister(app *config.S3StreamingLister, input s3.ListObjectsV2Input, chi myq.MyQueue, cho myq.MyQueue, chstatus myq.MyQueue)
func S3ListerWorker ¶
func SingleLetterStrategy ¶
func SingleLetterStrategy(app *config.S3StreamingLister, prefix *string, chi myq.MyQueue)
Types ¶
Click to show internal directories.
Click to hide internal directories.