Documentation
¶
Overview ¶
Package peercall holds the tiny typed clients doze-aws services use to call each other — hand-rolled requests in the target service's own wire format, so aws-sdk-go stays a test-only dependency. All calls are best-effort: callers log and drop on failure, they never crash a publish path.
Index ¶
- Constants
- func DDBGetRecords(dir peers.Directory, iterator string, limit int) (records []json.RawMessage, next string, err error)
- func DDBGetShardIterator(dir peers.Directory, streamArn, shardID, iterType string) (string, error)
- func LambdaInvoke(dir peers.Directory, function string, payload []byte) ([]byte, error)
- func LambdaInvokeAsync(dir peers.Directory, function string, payload []byte) error
- func SNSPublish(dir peers.Directory, topicARN, message string) error
- func SQSDelete(dir peers.Directory, queue, receiptHandle string) error
- func SQSSend(dir peers.Directory, queue, body string, attrs map[string]string) error
- type SQSMessage
Constants ¶
const DDBStreamShardID = "shardId-00000000000000000000-00000000"
DDBStreamShardID is the single shard doze-aws streams expose.
Variables ¶
This section is empty.
Functions ¶
func DDBGetRecords ¶ added in v0.2.0
func DDBGetRecords(dir peers.Directory, iterator string, limit int) (records []json.RawMessage, next string, err error)
DDBGetRecords fetches records from a stream shard iterator, returning the raw record documents and the next iterator to poll.
func DDBGetShardIterator ¶ added in v0.2.0
DDBGetShardIterator opens a shard iterator on a DynamoDB stream (used by Lambda event source mappings whose EventSourceArn is a stream ARN).
func LambdaInvoke ¶
LambdaInvokeAsync fires an Event-type invocation of a function. LambdaInvoke fires a synchronous (RequestResponse) invocation and returns the function's response payload. Used by Secrets Manager rotation, which drives a rotation function step by step.
func LambdaInvokeAsync ¶
func SNSPublish ¶
SNSPublish publishes a message to a topic by ARN (Query protocol).
Types ¶
type SQSMessage ¶
type SQSMessage struct {
MessageID string `json:"MessageId"`
ReceiptHandle string `json:"ReceiptHandle"`
Body string `json:"Body"`
}
SQSReceive long-polls a queue for up to max messages (used by Lambda event source mappings).
Source Files