Skip to content

Commit 0f2bf7e

Browse files
cloorcmassiveio
cloorc
authored and
massiveio
committed
enhance: re-format
Signed-off-by: Cloorc <wittcnezh@foxmail.com>
1 parent a168030 commit 0f2bf7e

6 files changed

Lines changed: 45 additions & 26 deletions

File tree

‎example/brokers_demo/main.go‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import (
66
"log/slog"
77
"time"
88

9-
"github.com/Fabricates/Matcher"
9+
matcher "github.com/Fabricates/Matcher"
1010
)
1111

1212
func main() {
@@ -85,7 +85,7 @@ func main() {
8585

8686
redisCASBroker, err := matcher.NewRedisCASBroker(redisCASConfig)
8787
if err != nil {
88-
slog.Error("Failed to create Redis CAS broker: %v", err)
88+
slog.Error("Failed to create Redis CAS broker", "error", err)
8989
} else {
9090
defer redisCASBroker.Close()
9191

@@ -171,7 +171,7 @@ func main() {
171171
}
172172

173173
if err := kafkaBroker.Publish(ctx, testEvent); err != nil {
174-
slog.Error("Failed to publish event: %v", err)
174+
slog.Error("Failed to publish event", "error", err)
175175
} else {
176176
fmt.Println("Published test event to Kafka")
177177
}
@@ -198,7 +198,7 @@ func main() {
198198

199199
// Subscribe to events
200200
if err := memoryBroker.Subscribe(ctx, events); err != nil {
201-
slog.Error("Failed to subscribe: %v", err)
201+
slog.Error("Failed to subscribe", "error", err)
202202
} else {
203203
// Publish a test event
204204
testEvent := &matcher.Event{

‎example/clustered/main.go‎

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,8 @@ func main() {
3232
nodeID,
3333
)
3434
if err != nil {
35-
slog.Error("Failed to create engine", "nodeID", nodeID, "error", err); os.Exit(1)
35+
slog.Error("Failed to create engine", "nodeID", nodeID, "error", err)
36+
os.Exit(1)
3637
}
3738

3839
engines[i] = engine
@@ -47,7 +48,8 @@ func main() {
4748

4849
for _, dim := range dimensions {
4950
if err := engine.AddDimension(dim); err != nil {
50-
slog.Error("Failed to add dimension", "dimension", dim.Name, "nodeID", nodeID, "error", err); os.Exit(1)
51+
slog.Error("Failed to add dimension", "dimension", dim.Name, "nodeID", nodeID, "error", err)
52+
os.Exit(1)
5153
}
5254
}
5355

‎example/dimension_consistency/main.go‎

Lines changed: 14 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,13 @@ func main() {
1414
// Create a matcher with persistence
1515
engine, err := matcher.NewMatcherEngineWithDefaults("./example_data")
1616
if err != nil {
17-
slog.Error("Failed to create matcher engine", "error", err); os.Exit(1)
17+
slog.Error("Failed to create matcher engine", "error", err)
18+
os.Exit(1)
1819
}
1920
defer func() {
2021
if err := engine.Close(); err != nil {
21-
slog.Error("Error closing engine", "error", err); os.Exit(1)
22+
slog.Error("Error closing engine", "error", err)
23+
os.Exit(1)
2224
}
2325
}()
2426

@@ -32,7 +34,8 @@ func main() {
3234

3335
err = engine.AddRule(rule1)
3436
if err != nil {
35-
slog.Error("Failed to add flexible rule", "error", err); os.Exit(1)
37+
slog.Error("Failed to add flexible rule", "error", err)
38+
os.Exit(1)
3639
} else {
3740
fmt.Println("✅ Added rule with 2 dimensions (product, environment)")
3841
}
@@ -45,7 +48,8 @@ func main() {
4548

4649
err = engine.AddRule(rule2)
4750
if err != nil {
48-
slog.Error("Failed to add flexible rule", "error", err); os.Exit(1)
51+
slog.Error("Failed to add flexible rule", "error", err)
52+
os.Exit(1)
4953
} else {
5054
fmt.Println("✅ Added rule with 3 dimensions (product, region, tier)")
5155
}
@@ -60,7 +64,8 @@ func main() {
6064
Weight: 10.0,
6165
})
6266
if err != nil {
63-
slog.Error("Failed to add product dimension", "error", err); os.Exit(1)
67+
slog.Error("Failed to add product dimension", "error", err)
68+
os.Exit(1)
6469
}
6570

6671
err = engine.AddDimension(&matcher.DimensionConfig{
@@ -70,7 +75,8 @@ func main() {
7075
Weight: 8.0,
7176
})
7277
if err != nil {
73-
slog.Error("Failed to add environment dimension", "error", err); os.Exit(1)
78+
slog.Error("Failed to add environment dimension", "error", err)
79+
os.Exit(1)
7480
}
7581

7682
err = engine.AddDimension(&matcher.DimensionConfig{
@@ -80,7 +86,8 @@ func main() {
8086
Weight: 5.0,
8187
})
8288
if err != nil {
83-
slog.Error("Failed to add region dimension", "error", err); os.Exit(1)
89+
slog.Error("Failed to add region dimension", "error", err)
90+
os.Exit(1)
8491
}
8592

8693
fmt.Println("✅ Configured dimensions: product (required), environment (required), region (optional)")

‎example/multitenant_demo/main.go‎

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import (
55
"log/slog"
66
"os"
77

8-
"github.com/Fabricates/Matcher"
8+
matcher "github.com/Fabricates/Matcher"
99
)
1010

1111
func main() {
@@ -14,7 +14,8 @@ func main() {
1414
// Create engine with JSON persistence
1515
engine, err := matcher.NewMatcherEngineWithDefaults("./demo_data")
1616
if err != nil {
17-
slog.Error("Failed to create engine", "error", err); os.Exit(1)
17+
slog.Error("Failed to create engine", "error", err)
18+
os.Exit(1)
1819
}
1920
defer engine.Close()
2021

@@ -63,7 +64,8 @@ func main() {
6364

6465
resultA, err := engine.FindBestMatch(tenantAQuery)
6566
if err != nil {
66-
slog.Error("Tenant A query failed: %v", err); os.Exit(1)
67+
slog.Error("Tenant A query failed", "error", err)
68+
os.Exit(1)
6769
}
6870
if resultA != nil {
6971
fmt.Printf(" 🎯 Match: %s (Weight: %.1f)\n", resultA.Rule.ID, resultA.TotalWeight)
@@ -80,7 +82,8 @@ func main() {
8082

8183
resultB, err := engine.FindBestMatch(tenantBQuery)
8284
if err != nil {
83-
slog.Error("Tenant B query failed: %v", err); os.Exit(1)
85+
slog.Error("Tenant B query failed", "error", err)
86+
os.Exit(1)
8487
}
8588
if resultB != nil {
8689
fmt.Printf(" 🎯 Match: %s (Weight: %.1f)\n", resultB.Rule.ID, resultB.TotalWeight)
@@ -123,7 +126,8 @@ func main() {
123126

124127
authResult, err := engine.FindBestMatch(authQuery)
125128
if err != nil {
126-
slog.Error("Auth query failed: %v", err); os.Exit(1)
129+
slog.Error("Auth query failed", "error", err)
130+
os.Exit(1)
127131
}
128132
if authResult != nil {
129133
fmt.Printf(" 🎯 Match: %s (Weight: %.1f)\n", authResult.Rule.ID, authResult.TotalWeight)
@@ -138,7 +142,8 @@ func main() {
138142

139143
paymentResult, err := engine.FindBestMatch(paymentQuery)
140144
if err != nil {
141-
slog.Error("Payment query failed: %v", err); os.Exit(1)
145+
slog.Error("Payment query failed", "error", err)
146+
os.Exit(1)
142147
}
143148
if paymentResult != nil {
144149
fmt.Printf(" 🎯 Match: %s (Weight: %.1f)\n", paymentResult.Rule.ID, paymentResult.TotalWeight)
@@ -158,7 +163,8 @@ func main() {
158163

159164
crossResult, err := engine.FindBestMatch(crossTenantQuery)
160165
if err != nil {
161-
slog.Error("Cross-tenant query failed: %v", err); os.Exit(1)
166+
slog.Error("Cross-tenant query failed", "error", err)
167+
os.Exit(1)
162168
}
163169
if crossResult == nil {
164170
fmt.Println("✅ Tenant isolation working: Tenant B cannot access Tenant A's rules")

‎example/weight_conflict_demo/main.go‎

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import (
55
"log/slog"
66
"os"
77

8-
"github.com/Fabricates/Matcher"
8+
matcher "github.com/Fabricates/Matcher"
99
)
1010

1111
func main() {
@@ -15,7 +15,8 @@ func main() {
1515
persistence := matcher.NewJSONPersistence("./data")
1616
engine, err := matcher.NewMatcherEngine(persistence, nil, "weight-demo")
1717
if err != nil {
18-
slog.Error("Failed to create engine", "error", err); os.Exit(1)
18+
slog.Error("Failed to create engine", "error", err)
19+
os.Exit(1)
1920
}
2021
defer engine.Close()
2122

@@ -29,7 +30,8 @@ func main() {
2930
Build()
3031

3132
if err := engine.AddRule(rule1); err != nil {
32-
slog.Error("Failed to add rule1", "error", err); os.Exit(1)
33+
slog.Error("Failed to add rule1", "error", err)
34+
os.Exit(1)
3335
} else {
3436
fmt.Printf("✅ Added rule1 with total weight: %.2f\n", rule1.CalculateTotalWeight())
3537
}
@@ -123,7 +125,8 @@ func main() {
123125

124126
result, err := engine.FindBestMatch(query)
125127
if err != nil {
126-
slog.Error("Query failed: %v", err); os.Exit(1)
128+
slog.Error("Query failed", "error", err)
129+
os.Exit(1)
127130
} else if result != nil {
128131
fmt.Printf("🎯 Best match: %s (weight: %.2f, description: %s)\n",
129132
result.Rule.ID, result.TotalWeight, result.Rule.Metadata["description"])
@@ -134,7 +137,8 @@ func main() {
134137
// Find all matches
135138
allMatches, err := engine.FindAllMatches(query)
136139
if err != nil {
137-
slog.Error("FindAllMatches failed", "error", err); os.Exit(1)
140+
slog.Error("FindAllMatches failed", "error", err)
141+
os.Exit(1)
138142
} else {
139143
fmt.Printf("\n📋 All matches (%d found):\n", len(allMatches))
140144
for i, match := range allMatches {

‎redis_cas_broker_test.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ func isRedisAvailable(addr string) bool {
3838
return client.Ping(ctx).Err() == nil
3939
}
4040

41-
func cleanupRedisKey(t *testing.T, redisAddr, namespace string) {
41+
func cleanupRedisKey(_ *testing.T, redisAddr, namespace string) {
4242
client := redis.NewClient(&redis.Options{
4343
Addr: redisAddr,
4444
DB: 0,

0 commit comments

Comments
 (0)