| 400 | } |
| 401 | |
| 402 | func (c Client) ZREM(key string, members ...string) (removedMembers []string, err error) { |
| 403 | for _, member := range members { |
| 404 | resp, err := c.ddbClient.DeleteItemRequest(&dynamodb.DeleteItemInput{ |
| 405 | Key: keyDef{pk: key, sk: member}.toAV(c), |
| 406 | ReturnValues: dynamodb.ReturnValueAllOld, |
| 407 | TableName: aws.String(c.table), |
| 408 | }).Send(context.TODO()) |
| 409 | |
| 410 | if err != nil { |
| 411 | return removedMembers, err |
| 412 | } |
| 413 | |
| 414 | if len(resp.Attributes) > 0 { |
| 415 | removedMembers = append(removedMembers, member) |
| 416 | } |
| 417 | } |
| 418 | |
| 419 | return |
| 420 | } |
| 421 | |
| 422 | func (c Client) ZREMRANGEBYLEX(key string, min, max string) (removedMembers []string, err error) { |
| 423 | membersWithScores, err := c.ZRANGEBYLEX(key, min, max, 0, 0) |