1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
// Copyright (C) MongoDB, Inc. 2017-present.
//
// Licensed under the Apache License, Version 2.0 (the "License"); you may
// not use this file except in compliance with the License. You may obtain
// a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
package unified
import (
"context"
"fmt"
"go.mongodb.org/mongo-driver/mongo"
)
// ctxKey is used to define keys for values stored in context.Context objects.
type ctxKey string
const (
// entitiesKey is used to store an entityMap instance in a Context.
entitiesKey ctxKey = "test-entities"
// failPointsKey is used to store a map from a fail point name to the Client instance used to configure it.
failPointsKey ctxKey = "test-failpoints"
// targetedFailPointsKey is used to store a map from a fail point name to the host on which the fail point is set.
targetedFailPointsKey ctxKey = "test-targeted-failpoints"
)
// newTestContext creates a new Context derived from ctx with values initialized to store the state required for test
// execution.
func newTestContext(ctx context.Context, entityMap *EntityMap) context.Context {
ctx = context.WithValue(ctx, entitiesKey, entityMap)
ctx = context.WithValue(ctx, failPointsKey, make(map[string]*mongo.Client))
ctx = context.WithValue(ctx, targetedFailPointsKey, make(map[string]string))
return ctx
}
func addFailPoint(ctx context.Context, failPoint string, client *mongo.Client) error {
failPoints := ctx.Value(failPointsKey).(map[string]*mongo.Client)
if _, ok := failPoints[failPoint]; ok {
return fmt.Errorf("fail point %q already exists in tracked fail points map", failPoint)
}
failPoints[failPoint] = client
return nil
}
func addTargetedFailPoint(ctx context.Context, failPoint string, host string) error {
failPoints := ctx.Value(targetedFailPointsKey).(map[string]string)
if _, ok := failPoints[failPoint]; ok {
return fmt.Errorf("fail point %q already exists in tracked targeted fail points map", failPoint)
}
failPoints[failPoint] = host
return nil
}
func failPoints(ctx context.Context) map[string]*mongo.Client {
return ctx.Value(failPointsKey).(map[string]*mongo.Client)
}
func targetedFailPoints(ctx context.Context) map[string]string {
return ctx.Value(targetedFailPointsKey).(map[string]string)
}
func entities(ctx context.Context) *EntityMap {
return ctx.Value(entitiesKey).(*EntityMap)
}
|
