redriver

Documentation

Index

• type DDBStreamBatchInfo
• type FailedItem
• type Redriver
  • func New(queueUrl string, sqs sqsiface.SQSAPI, ...) *Redriver
  • func (w *Redriver) Run(ctx context.Context, async bool) error
• type RequestContext
• type ResponseContext

Types

type DDBStreamBatchInfo

type DDBStreamBatchInfo struct {
	ShardId                         string    `json:"shardId"`
	StartSequenceNumber             string    `json:"startSequenceNumber"`
	EndSequenceNumber               string    `json:"endSequenceNumber"`
	ApproximateArrivalOfFirstRecord time.Time `json:"approximateArrivalOfFirstRecord"`
	ApproximateArrivalOfLastRecord  time.Time `json:"approximateArrivalOfLastRecord"`
	BatchSize                       int       `json:"batchSize"`
	StreamArn                       string    `json:"streamArn"`
}

type FailedItem

type FailedItem struct {
	Version         string          `json:"version"`
	Timestamp       time.Time       `json:"timestamp"`
	RequestContext  RequestContext  `json:"requestContext"`
	ResponseContext ResponseContext `json:"responseContext"`

	RequestPayload     json.RawMessage     `json:"requestPayload,omitempty"`
	ResponsePayload    json.RawMessage     `json:"responsePayload,omitempty"`
	DDBStreamBatchInfo *DDBStreamBatchInfo `json:"DDBStreamBatchInfo,omitempty"`
}

type Redriver

type Redriver struct {
	// contains filtered or unexported fields
}

func New

func New(queueUrl string, sqs sqsiface.SQSAPI, streams dynamodbstreamsiface.DynamoDBStreamsAPI, lambda lambdaiface.LambdaAPI) *Redriver

func (*Redriver) Run

func (w *Redriver) Run(ctx context.Context, async bool) error

type RequestContext

type RequestContext struct {
	RequestId              string `json:"requestId"`
	FunctionArn            string `json:"functionArn"`
	Condition              string `json:"condition"`
	ApproximateInvokeCount int    `json:"approximateInvokeCount"`
}

type ResponseContext

type ResponseContext struct {
	StatusCode      int    `json:"statusCode"`
	ExecutedVersion string `json:"executedVersion"`
	FunctionError   string `json:"functionError"`
}