Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CloudWatchEvent ¶
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 }
CloudWatchEvent is the event sent by CloudWatch to Lambda functions
type CredentialsType ¶
CredentialsType is a struct to hold credentials
type DynamoDBEvent ¶
type DynamoDBEvent struct {
Records []DynamoDBEventRecord `json:"Records"`
}
type DynamoDBEventRecord ¶
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 ¶
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 ¶
type KafkaPartitionLogEvent ¶
type KafkaPartitionLogEvent struct { Partition int64 `json:"partition"` Offset int64 `json:"offset"` SchemaId int `json:"schema_id"` Payload json.RawMessage `json:"payload"` }
KafkaPartitionLogEvent is the event sent by Kafka to Lambda functions
type LambdaProxyResponse ¶
type SalesforceDetailEvent ¶
type SalesforceDetailEvent struct {
Payload json.RawMessage `json:"payload"`
}
SalesforceDetailEvent is the event sent by Salesforce to Lambda functions
type SourceKey ¶
type SourceKey struct{}
SourceKey is the key used to store the source in the context
Click to show internal directories.
Click to hide internal directories.