(key string, address string)
| 503 | } |
| 504 | |
| 505 | func (c Client) listGetByAddress(key string, address string) (node listNode, found bool, err error) { |
| 506 | resp, err := c.ddbClient.GetItemRequest(&dynamodb.GetItemInput{ |
| 507 | ConsistentRead: aws.Bool(true), |
| 508 | Key: listNode{ |
| 509 | key: key, |
| 510 | address: address, |
| 511 | }.keyAV(c), |
| 512 | TableName: aws.String(c.table), |
| 513 | }).Send(context.TODO()) |
| 514 | |
| 515 | if err != nil { |
| 516 | return |
| 517 | } |
| 518 | |
| 519 | if len(resp.Item) > 0 { |
| 520 | found = true |
| 521 | node = lParseNode(resp.Item, c) |
| 522 | } |
| 523 | |
| 524 | return |
| 525 | } |
| 526 | |
| 527 | func (c Client) LPUSHX(key string, elements ...Value) (newLength int64, err error) { |
| 528 | for _, element := range elements { |
no test coverage detected