dstream

Documentation

Index

• type Details
• type DynamoDetails
  • func (d *DynamoDetails) Get(tableName string) (details *Details, err error)
• type Elasticsearch
  • func (e *Elasticsearch) Update(d *Details, item map[string]events.DynamoDBAttributeValue) (*es.IndexResponse, error)

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