kinesis

Documentation

Overview

Package kinesis provides types to support unmarshalling generic `event *json.RawMessage` types into Kinesis specific event structures. Sparta-based Kinesis event listeners can unmarshall the RawMesssage into source-specific data. Example:

func s3EventListener(event *json.RawMessage,
                      context *sparta.LambdaContext,
                      w http.ResponseWriter,
                      logger *logrus.Logger) {
  var lambdaEvent spartaKinesis.Event
  err := json.Unmarshal([]byte(*event), &lambdaEvent)
  if err != nil {
    logger.Error("Failed to unmarshal event data: ", err.Error())
    http.Error(w, err.Error(), http.StatusInternalServerError)
  }
  for _, eachRecord := range lambdaEvent.Records {
    logger.Info("Kinesis event:", eachRecord.EventName)
  }
}

Index

• type Event
• type EventRecord
• type Kinesis

Types

type Event

type Event struct {
	Records []EventRecord
}

Event data

type EventRecord

type EventRecord struct {
	EventSource       string  `json:"eventSource"`
	EventID           string  `json:"eventID"`
	InvokeIdentityARN string  `json:"invokeIdentityArn"`
	EventVersion      string  `json:"eventVersion"`
	EventName         string  `json:"eventName"`
	EventSourceARN    string  `json:"eventSourceARN"`
	AWSRegion         string  `json:"awsRegion"`
	Kinesis           Kinesis `json:"kinesis"`
}

EventRecord event data

type Kinesis

type Kinesis struct {
	PartitionKey         string `json:"partitionKey"`
	KinesisSchemaVersion string `json:"kinesisSchemaVersion"`
	Data                 string `json:"data"`
	SequenceNumber       string `json:"sequenceNumber"`
}

Kinesis Event data. TODO - automatically base64 decode `Data`