-
Notifications
You must be signed in to change notification settings - Fork 24
/
first-valid.go
53 lines (41 loc) · 1.9 KB
/
first-valid.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
package components
import (
policylangv1 "github.com/fluxninja/aperture/v2/api/gen/proto/go/aperture/policy/language/v1"
"github.com/fluxninja/aperture/v2/pkg/config"
"github.com/fluxninja/aperture/v2/pkg/notifiers"
"github.com/fluxninja/aperture/v2/pkg/policies/controlplane/iface"
"github.com/fluxninja/aperture/v2/pkg/policies/controlplane/runtime"
"go.uber.org/fx"
)
// FirstValid picks the first valid input signal from the array of input signals and emits it as an output signal.
type FirstValid struct{}
// Name implements runtime.Component.
func (*FirstValid) Name() string { return "FirstValid" }
// Type implements runtime.Component.
func (*FirstValid) Type() runtime.ComponentType { return runtime.ComponentTypeSignalProcessor }
// ShortDescription implements runtime.Component.
func (*FirstValid) ShortDescription() string { return "" }
// IsActuator implements runtime.Component.
func (*FirstValid) IsActuator() bool { return false }
// Make sure FirstValid complies with Component interface.
var _ runtime.Component = (*FirstValid)(nil)
// NewFirstValidAndOptions creates a new FirstValid component and its Fx option.
func NewFirstValidAndOptions(firstValidProto *policylangv1.FirstValid, _ runtime.ComponentID, policyReadAPI iface.Policy) (*FirstValid, fx.Option, error) {
return &FirstValid{}, fx.Options(), nil
}
// Execute implements runtime.Component.Execute.
func (fv *FirstValid) Execute(inPortReadings runtime.PortToReading, circuitAPI runtime.CircuitAPI) (runtime.PortToReading, error) {
inputs := inPortReadings.ReadRepeatedReadingPort("inputs")
output := runtime.InvalidReading()
for _, input := range inputs {
if input.Valid() {
output = input
break
}
}
return runtime.PortToReading{
"output": []runtime.Reading{output},
}, nil
}
// DynamicConfigUpdate is a no-op for FirstValid.
func (fv *FirstValid) DynamicConfigUpdate(event notifiers.Event, unmarshaller config.Unmarshaller) {}