indexer

package
v0.0.0-...-cbcb865 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 16, 2021 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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:"-"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL