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 ¶
- 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 ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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).
func SQSReceive ¶
Source Files
Click to show internal directories.
Click to hide internal directories.