frontend

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 Parquet(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

Functions

func DelimiterStrategy

func DelimiterStrategy(app *config.S3StreamingLister, prefix *string, next *string, chi myq.MyQueue)

func Frontend

func Frontend(app *config.S3StreamingLister, cho myq.MyQueue, chstatus myq.MyQueue)

func Parquet

func Parquet(app *config.S3StreamingLister, cho myq.MyQueue, chStatus myq.MyQueue)

func S3Lister

func S3Lister(app *config.S3StreamingLister, input s3.ListObjectsV2Input, chi myq.MyQueue, cho myq.MyQueue, chstatus myq.MyQueue)

func S3ListerWorker

func S3ListerWorker(app *config.S3StreamingLister, cho myq.MyQueue, chstatus myq.MyQueue) myq.MyQueue

func SingleLetterStrategy

func SingleLetterStrategy(app *config.S3StreamingLister, prefix *string, chi myq.MyQueue)

func Sqlite

func Sqlite(app *config.S3StreamingLister, cho myq.MyQueue, chStatus myq.MyQueue)

Types

type Complete

type Complete struct {
	Completed bool
	Todo      []types.Object
}