(item map[string]dynamodb.AttributeValue, c Client)
| 581 | } |
| 582 | |
| 583 | func parseStreamItem(item map[string]dynamodb.AttributeValue, c Client) (si StreamItem) { |
| 584 | si.Fields = make(map[string]ReturnValue) |
| 585 | |
| 586 | for k, v := range item { |
| 587 | if strings.HasPrefix(k, "_") { |
| 588 | si.Fields[k[1:]] = ReturnValue{v} |
| 589 | } |
| 590 | } |
| 591 | |
| 592 | si.ID = XID(aws.StringValue(item[c.sk].S)) |
| 593 | |
| 594 | return |
| 595 | } |
| 596 | |
| 597 | func (c Client) xGroupCursorPushAction(key string, group string, id XID) dynamodb.TransactWriteItem { |
| 598 | builder := newExpresionBuilder() |