dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

💄 

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
This commit is contained in:
ItalyPaleAle 2022-09-16 20:49:14 +00:00
parent cec34b9a95
commit 3c2e82a0e7
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
state/azure/cosmosdb/cosmosdb.go
View File

@ -277,7 +277,8 @@ func (c *StateStore) Set(req *state.SetRequest) error {
options.IfMatchEtag = &etag
}
if req.Options.Concurrency == state.FirstWrite && (req.ETag == nil || *req.ETag == "") {
u, err := uuid.NewRandom()
var u uuid.UUID
u, err = uuid.NewRandom()
if err != nil {
return err
}
@ -345,7 +346,7 @@ func (c *StateStore) Delete(req *state.DeleteRequest) error {
}
// Multi performs a transactional operation. succeeds only if all operations succeed, and fails if one or more operations fail.
func (c *StateStore) Multi(request *state.TransactionalStateRequest) error {
func (c *StateStore) Multi(request *state.TransactionalStateRequest) (err error) {
if len(request.Operations) == 0 {
c.logger.Debugf("No Operations Provided")
return nil
@ -363,7 +364,8 @@ func (c *StateStore) Multi(request *state.TransactionalStateRequest) error {
if o.Operation == state.Upsert {
req := o.Request.(state.SetRequest)
doc, err := createUpsertItem(c.contentType, req, partitionKey)
var doc CosmosItem
doc, err = createUpsertItem(c.contentType, req, partitionKey)
if err != nil {
return err
}
@ -373,14 +375,16 @@ func (c *StateStore) Multi(request *state.TransactionalStateRequest) error {
options.IfMatchETag = &etag
}
if req.Options.Concurrency == state.FirstWrite && (req.ETag == nil || *req.ETag == "") {
u, err := uuid.NewRandom()
var u uuid.UUID
u, err = uuid.NewRandom()
if err != nil {
return err
}
options.IfMatchETag = ptr.Of(azcore.ETag(u.String()))
}
marsh, err := json.Marshal(doc)
var marsh []byte
marsh, err = json.Marshal(doc)
if err != nil {
return err
}
@ -394,7 +398,8 @@ func (c *StateStore) Multi(request *state.TransactionalStateRequest) error {
options.IfMatchETag = &etag
}
if req.Options.Concurrency == state.FirstWrite && (req.ETag == nil || *req.ETag == "") {
u, err := uuid.NewRandom()
var u uuid.UUID
u, err = uuid.NewRandom()
if err != nil {
return err
}