(key string, group string, start XID)
| 398 | } |
| 399 | |
| 400 | func (c Client) xGroupCursorSet(key string, group string, start XID) error { |
| 401 | cursorKey := c.xGroupCursorKey(key, group) |
| 402 | _, err := c.HSET(cursorKey.pk, map[string]Value{cursorKey.sk: StringValue{start.String()}}) |
| 403 | |
| 404 | return err |
| 405 | } |
| 406 | |
| 407 | func (c Client) xGroupCursorGet(key string, group string) (id XID, err error) { |
| 408 | resp, err := c.ddbClient.GetItemRequest(&dynamodb.GetItemInput{ |
no test coverage detected