34
)
35
36
>
func (pdb *db) GetTaskQueueUserData(ctx context.Context, request *sqlplugin.GetTaskQueueUserDataRequest) (*sqlplugin.VersionedBlob, error) {
task_user_data.go
37
>
var row sqlplugin.VersionedBlob
38
>
err := pdb.GetContext(ctx, &row, getTaskQueueUserDataQry, request.NamespaceID, request.TaskQueueName)
39
>
return &row, err
40
>
}
41
42
>
func (pdb *db) UpdateTaskQueueUserData(ctx context.Context, request *sqlplugin.UpdateTaskQueueDataRequest) error {
task_user_data.go
43
>
if request.Version == 0 {
44
>
_, err := pdb.ExecContext(
45
>
ctx,
46
>
insertTaskQueueUserDataQry,
47
>
request.NamespaceID,
48
>
request.TaskQueueName,
49
>
request.Data,
50
>
request.DataEncoding)
51
>
return err
52
>
}
53
>
result, err := pdb.ExecContext(
54
>
ctx,
55
>
updateTaskQueueUserDataQry,
56
>
request.Data,
57
>
request.DataEncoding,
58
>
request.Version+1,
59
>
request.NamespaceID,
60
>
request.TaskQueueName,
61
>
request.Version)
62
>
if err != nil {
63
return err
64
}
66
>
if err != nil {
67
return err
68
}
70
return &persistence.ConditionFailedError{Msg: "Expected exactly one row to be updated"}
71
}
73
}
74