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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
package workflows
import (
"encoding/json"
"time"
"github.com/gophercloud/gophercloud"
"github.com/gophercloud/gophercloud/pagination"
)
// CreateResult is the response of a Post operations. Call its Extract method to interpret it as a list of Workflows.
type CreateResult struct {
gophercloud.Result
}
// DeleteResult is the result from a Delete operation. Call its ExtractErr method to determine the success of the call.
type DeleteResult struct {
gophercloud.ErrResult
}
// Extract helps to get created Workflow struct from a Create function.
func (r CreateResult) Extract() ([]Workflow, error) {
var s struct {
Workflows []Workflow `json:"workflows"`
}
err := r.ExtractInto(&s)
return s.Workflows, err
}
// GetResult is the response of Get operations. Call its Extract method to interpret it as a Workflow.
type GetResult struct {
gophercloud.Result
}
// Extract helps to get a Workflow struct from a Get function.
func (r GetResult) Extract() (*Workflow, error) {
var s Workflow
err := r.ExtractInto(&s)
return &s, err
}
// Workflow represents a workflow execution on OpenStack mistral API.
type Workflow struct {
// ID is the workflow's unique ID.
ID string `json:"id"`
// Definition is the workflow definition in Mistral v2 DSL.
Definition string `json:"definition"`
// Name is the name of the workflow.
Name string `json:"name"`
// Namespace is the namespace of the workflow.
Namespace string `json:"namespace"`
// Input represents the needed input to execute the workflow.
// This parameter is a list of each input, comma separated.
Input string `json:"input"`
// ProjectID is the project id owner of the workflow.
ProjectID string `json:"project_id"`
// Scope is the scope of the workflow.
// Values can be "private" or "public".
Scope string `json:"scope"`
// Tags is a list of tags associated to the workflow.
Tags []string `json:"tags"`
// CreatedAt is the creation date of the workflow.
CreatedAt time.Time `json:"-"`
// UpdatedAt is the last update date of the workflow.
UpdatedAt *time.Time `json:"-"`
}
// UnmarshalJSON implements unmarshalling custom types
func (r *Workflow) UnmarshalJSON(b []byte) error {
type tmp Workflow
var s struct {
tmp
CreatedAt gophercloud.JSONRFC3339ZNoTNoZ `json:"created_at"`
UpdatedAt *gophercloud.JSONRFC3339ZNoTNoZ `json:"updated_at"`
}
err := json.Unmarshal(b, &s)
if err != nil {
return err
}
*r = Workflow(s.tmp)
r.CreatedAt = time.Time(s.CreatedAt)
if s.UpdatedAt != nil {
t := time.Time(*s.UpdatedAt)
r.UpdatedAt = &t
}
return nil
}
// WorkflowPage contains a single page of all workflows from a List call.
type WorkflowPage struct {
pagination.LinkedPageBase
}
// IsEmpty checks if an WorkflowPage contains any results.
func (r WorkflowPage) IsEmpty() (bool, error) {
if r.StatusCode == 204 {
return true, nil
}
exec, err := ExtractWorkflows(r)
return len(exec) == 0, err
}
// NextPageURL finds the next page URL in a page in order to navigate to the next page of results.
func (r WorkflowPage) NextPageURL() (string, error) {
var s struct {
Next string `json:"next"`
}
err := r.ExtractInto(&s)
if err != nil {
return "", err
}
return s.Next, nil
}
// ExtractWorkflows get the list of cron triggers from a page acquired from the List call.
func ExtractWorkflows(r pagination.Page) ([]Workflow, error) {
var s struct {
Workflows []Workflow `json:"workflows"`
}
err := (r.(WorkflowPage)).ExtractInto(&s)
return s.Workflows, err
}
|
