types

type CloudWatchEvent struct {
	Version    string          `json:"version"`     // e.g. 0
	ID         string          `json:"id"`          // e.g. 12345678-1234-1234-1234-123456789012
	DetailType string          `json:"detail-type"` // e.g. AWS API Call via CloudTrail or mobile
	Source     string          `json:"source"`      // aws.partner/salesforce.com/... or aws.ec2 or rudderstack
	AccountID  string          `json:"account"`     // e.g. 123456789012
	Time       time.Time       `json:"time"`        // e.g. 2019-03-01T21:49:13Z
	Region     string          `json:"region"`      // e.g. us-east-1
	Resources  []string        `json:"resources"`   // ARNs of resources
	Detail     json.RawMessage `json:"detail"`      // this is the raw JSON event
}

type CredentialsType struct {
	Username string `json:"username"`
	Password string `json:"password"`
}

type DynamoDBEvent struct {
	Records []DynamoDBEventRecord `json:"Records"`
}

type DynamoDBEventRecord struct {
	EventID        string                       `json:"eventID"`   // e.g. 1
	EventName      string                       `json:"eventName"` // e.g. 1.1
	Change         DynamoDBStreamRecord         `json:"dynamodb"`
	AWSRegion      string                       `json:"awsRegion"`
	EventSourceArn string                       `json:"eventSourceARN"` // e.g. arn:aws:dynamodb:us-east-1:123456789012:table/MyTableWithStream/stream/2019-03-01T22:00:00.000
	EventSource    string                       `json:"eventSource"`
	EventVersion   string                       `json:"eventVersion"`
	UserIdentity   *events.DynamoDBUserIdentity `json:"userIdentity,omitempty"`
}

type DynamoDBStreamRecord struct {
	ApproximateCreationDateTime events.SecondsEpochTime `json:"ApproximateCreationDateTime,omitempty"`
	Keys                        json.RawMessage         `json:"Keys,omitempty"`
	NewImage                    json.RawMessage         `json:"NewImage,omitempty"`
	OldImage                    json.RawMessage         `json:"OldImage,omitempty"`
	StreamViewType              string                  `json:"StreamViewType"`
	SequenceNumber              string                  `json:"SequenceNumber"`
	SizeBytes                   int64                   `json:"SizeBytes"`
}

type DynamoDBUserIdentity struct {
	Type        string `json:"type"`
	PrincipalID string `json:"principalId"`
}

type KafkaPartitionLogEvent struct {
	Partition int64           `json:"partition"`
	Offset    int64           `json:"offset"`
	SchemaId  int             `json:"schema_id"`
	Payload   json.RawMessage `json:"payload"`
}

type LambdaProxyResponse struct {
	Body       string `json:"body"`
	StatusCode int    `json:"statusCode"`
}

type SalesforceDetailEvent struct {
	Payload json.RawMessage `json:"payload"`
}

type SourceKey struct{}

type TagsType struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type TopicKey struct{}