/
activity_example.go
92 lines (83 loc) · 2.94 KB
/
activity_example.go
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
package examples
import (
"github.com/project-flogo/contrib/activity/rest"
trigger "github.com/project-flogo/contrib/trigger/rest"
"github.com/project-flogo/core/api"
"github.com/project-flogo/core/engine"
"github.com/project-flogo/microgateway"
"github.com/project-flogo/microgateway/activity/circuitbreaker"
microapi "github.com/project-flogo/microgateway/api"
)
// Example returns an API example
func Example(mode string, threshold int, timeout int, period int) (engine.Engine, error) {
app := api.NewApp()
gateway := microapi.New("Pets")
serviceCircuitBreaker := gateway.NewService("CircuitBreaker", &circuitbreaker.Activity{})
serviceCircuitBreaker.SetDescription("Circuit breaker service")
serviceCircuitBreaker.AddSetting("mode", mode)
if threshold > 0 {
serviceCircuitBreaker.AddSetting("threshold", threshold)
}
if timeout > 0 {
serviceCircuitBreaker.AddSetting("timeout", timeout)
}
if period > 0 {
serviceCircuitBreaker.AddSetting("period", period)
}
serviceStore := gateway.NewService("PetStorePets", &rest.Activity{})
serviceStore.SetDescription("Get pets by ID from the petstore")
serviceStore.AddSetting("uri", "http://localhost:1234/pets")
serviceStore.AddSetting("method", "GET")
gateway.NewStep(serviceCircuitBreaker)
step := gateway.NewStep(serviceStore)
step.SetHalt("($.PetStorePets.error != nil) && !error.isneterror($.PetStorePets.error)")
step = gateway.NewStep(serviceCircuitBreaker)
step.SetIf("$.PetStorePets.error != nil")
step.AddInput("operation", "counter")
step = gateway.NewStep(serviceCircuitBreaker)
step.SetIf("$.PetStorePets.error == nil")
step.AddInput("operation", "reset")
response := gateway.NewResponse(true)
response.SetIf("$.CircuitBreaker.outputs.tripped == true")
response.SetCode(403)
response.SetData(map[string]interface{}{
"error": "circuit breaker tripped",
})
response = gateway.NewResponse(true)
response.SetIf("$.PetStorePets.outputs.data.status != 'available'")
response.SetCode(403)
response.SetData(map[string]interface{}{
"error": "Pet is unavailable",
"pet": "=$.PetStorePets.outputs.data",
"status": "=$.PetStorePets.outputs.data.status",
})
response = gateway.NewResponse(false)
response.SetIf("$.PetStorePets.outputs.data.status == 'available'")
response.SetCode(200)
response.SetData(map[string]interface{}{
"pet": "=$.PetStorePets.outputs.data",
"status": "=$.PetStorePets.outputs.data.status",
})
response = gateway.NewResponse(true)
response.SetCode(403)
response.SetData(map[string]interface{}{
"error": "connection failure",
})
settings, err := gateway.AddResource(app)
if err != nil {
return nil, err
}
trg := app.NewTrigger(&trigger.Trigger{}, &trigger.Settings{Port: 9096})
handler, err := trg.NewHandler(&trigger.HandlerSettings{
Method: "GET",
Path: "/pets/:petId",
})
if err != nil {
return nil, err
}
_, err = handler.NewAction(µgateway.Action{}, settings)
if err != nil {
return nil, err
}
return api.NewEngine(app)
}