s3

Documentation

Index

• Variables
• func Poll(bucket, bucketRegion string, log *zap.Logger)
• func Sync(t time.Time, log *zap.Logger)
• type S3API

Variables

var (
	// Up contains the systems availability. If true the s3 service is up.
	Up bool

	// Health contains the systems readiness. If false the s3 service
	// most likely can't read or download from s3. Most likely temporary.
	Health bool

	// Config contains parameters related to S3.
	Config config
)

Functions

func Poll

func Poll(bucket, bucketRegion string, log *zap.Logger)

Poll polls every 60 seconds, kicking of an s3 sync.

func Sync

func Sync(t time.Time, log *zap.Logger)

Sync sets up an s3 session, parses all files and puts them into the kv store.

Types

type S3API

type S3API interface {
	s3iface.S3API
}

S3API is a local wrapper over aws-sdk-go's S3 API