/
event_data_filter.go
45 lines (39 loc) · 1.69 KB
/
event_data_filter.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
// Copyright 2022 The Serverless Workflow Specification Authors
//
// 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
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package model
import "github.com/serverlessworkflow/sdk-go/v2/util"
// EventDataFilter used to filter consumed event payloads.
type EventDataFilter struct {
// If set to false, event payload is not added/merged to state data. In this case 'data' and 'toStateData'
// should be ignored. Default is true.
// +optional
UseData bool `json:"useData,omitempty"`
// Workflow expression that filters of the event data (payload).
// +optional
Data string `json:"data,omitempty"`
// Workflow expression that selects a state data element to which the action results should be added/merged into.
// If not specified denotes the top-level state data element
// +optional
ToStateData string `json:"toStateData,omitempty"`
}
type eventDataFilterUnmarshal EventDataFilter
// UnmarshalJSON implements json.Unmarshaler
func (f *EventDataFilter) UnmarshalJSON(data []byte) error {
f.ApplyDefault()
return util.UnmarshalObject("eventDataFilter", data, (*eventDataFilterUnmarshal)(f))
}
// ApplyDefault set the default values for Event Data Filter
func (f *EventDataFilter) ApplyDefault() {
f.UseData = true
}