indexer

Documentation

Index

• func MakeIndex(args handler.Arguments, record events.S3EventRecord) error
• func RunIndexer(reader *rlogs.Reader)
• func RunIndexerProc(reader *rlogs.Reader)
• type Arguments

Functions

func MakeIndex

func MakeIndex(args handler.Arguments, record events.S3EventRecord) error

MakeIndex is a process for one S3 object to make index file.

func RunIndexer

func RunIndexer(reader *rlogs.Reader)

RunIndexer is main handler of indexer. It requires log reader based on rlogs. Main procedures are in handleEvent() to reduce number of internal.HandleError().

func RunIndexerProc

func RunIndexerProc(reader *rlogs.Reader)

Types

type Arguments

type Arguments struct {
	handler.EnvVars
	Event  events.SQSEvent
	Reader *rlogs.Reader

	NewS3      adaptor.S3ClientFactory  `json:"-"`
	NewSQS     adaptor.SQSClientFactory `json:"-"`
	NewEncoder adaptor.EncoderFactory   `json:"-"`
	NewDecoder adaptor.DecoderFactory   `json:"-"`
}