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