dstream

package
v0.0.0-...-f8bfda6 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2019 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Details 

type Details struct {
	HashKey, RangeKey, TableName string
}

Details is the data needed to index the most recent dataoff to elasticsearch

type DynamoDetails 

type DynamoDetails struct {
	dynamodbiface.DynamoDBAPI
}

DynamoDetails is a wrapper around the DynamoDBAPI interface, it defines behavior for accessing DynamoDB Table metadata

func (*DynamoDetails) Get 

func (d *DynamoDetails) Get(tableName string) (details *Details, err error)

Get Extracts out the attribute Value of Hash Key and Range key from the describe table output

type Elasticsearch 

type Elasticsearch struct {
	*es.Client
}

Elasticsearch is an ES Client which will perform Elasticsearch Updates for Dynamo Items

func (*Elasticsearch) Update 

func (e *Elasticsearch) Update(d *Details, item map[string]events.DynamoDBAttributeValue) (*es.IndexResponse, error)

Update takes a reference to adstream.Details object; which is used to figure out which Elasticsearch Index to update; And an item map[string]events.DynamoDBAttributeValue which will be turned into JSON then indexed into Elasticsearch

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.