Merge 26edb84 into 5668d21

builder.go

@@ -1,13 +1,23 @@
 package stl
 
-import "context"
+import (
+	"context"
+
+	"github.com/gofrs/uuid"
+)
 
 // New creates an instance of default Builder.
 func New() Builder {
-	return &builder{}
+	id, err := uuid.NewV4()
+	if err != nil {
+		panic(err)
+	}
+
+	return &builder{id: id.String()}
 }
 
 type builder struct {
+	id  string
 	shs []string
 	exs []string
 	v   Vault
@@ -33,6 +43,10 @@ func (t *builder) Exclusive(name string) Builder {
 	return t
 }
 
+func (t *builder) ID() string {
+	return t.id
+}
+
 func (t *builder) ListShared() []string {
 	return t.shs
 }

merge_tx.go

@@ -1,5 +1,7 @@
 package stl
 
+import "github.com/gofrs/uuid"
+
 // MergeTx prepares a single transaction from several simultaneous ones.
 func MergeTx(ttx ...Tx) Tx {
 	txMap := map[string]bool{}
@@ -23,9 +25,15 @@ func MergeTx(ttx ...Tx) Tx {
 		}
 	}
 
+	id, err := uuid.NewV4()
+	if err != nil {
+		panic(err)
+	}
+
 	return &builder{
+		id:  id.String(),
 		shs: shs,
 		exs: exs,
 		v:   nil,
 	}
-}
+}

stacked_builder.go

@@ -1,13 +1,23 @@
 package stl
 
-import "context"
+import (
+	"context"
+
+	"github.com/gofrs/uuid"
+)
 
 // NewStacked creates an instance of stacked Builder.
 func NewStacked() Builder {
-	return &stackedBuilder{}
+	id, err := uuid.NewV4()
+	if err != nil {
+		panic(err)
+	}
+
+	return &stackedBuilder{id: id.String()}
 }
 
 type stackedBuilder struct {
+	id     string
 	prefix string
 	shs    []string
 	exs    []string
@@ -44,6 +54,10 @@ func (t *stackedBuilder) ListExclusive() []string {
 	return t.exs
 }
 
+func (t *stackedBuilder) ID() string {
+	return t.id
+}
+
 func (t *stackedBuilder) ToTx() Tx {
 	return t
 }

stl.go

@@ -15,6 +15,7 @@ type Locker interface {
 // Tx holds the names of shared and exclusive resources to be locked
 // atomically.
 type Tx interface {
+	ID() string
 	ListShared() []string
 	ListExclusive() []string
 }

stl_test.go

@@ -348,6 +348,11 @@ func TestDiningPhilosophers(t *testing.T) {
 	wg.Wait()
 }
 
+func TestGenerateID(t *testing.T) {
+	require.NotEmpty(t, New().ToTx().ID())
+	require.NotEmpty(t, NewStacked().ToTx().ID())
+}
+
 func TestMergeTx(t *testing.T) {
 	ttx := []Tx{
 		NewStacked().Shared("resource1").Shared("resource2").Exclusive("resource3").ToTx(),
@@ -371,6 +376,7 @@ func TestMergeTx(t *testing.T) {
 
 	require.ElementsMatch(t, expectedExs, tx.ListExclusive())
 	require.ElementsMatch(t, expectedShs, tx.ListShared())
+	require.NotEmpty(t, tx.ID())
 }
 
 func TestTryLock(t *testing.T) {