_switch

package

v0.0.9 Latest Latest Go to latest Published: Nov 24, 2024 License: GPL-3.0 Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dipper-iot/dipper-engine

Links

Open Source Insights

Documentation ¶

Index ¶

type Option
type Switch
- func NewSwitch(mainBranch string, dataQuery map[string]interface{}) *Switch
- func (r Switch) Run(dataMap map[string]string, key string) (result string, err error)
type SwitchRule
- func NewSwitchRule() *SwitchRule

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Option ¶

type Option struct {
	Key       string            `json:"key"`
	MapSwitch map[string]string `json:"map_switch"`
	NextError string            `json:"next_error"`
	Debug     bool              `json:"debug"`
}

type Switch ¶

type Switch struct {
	// contains filtered or unexported fields
}

func NewSwitch ¶

func NewSwitch(mainBranch string, dataQuery map[string]interface{}) *Switch

func (Switch) Run ¶

func (r Switch) Run(dataMap map[string]string, key string) (result string, err error)

type SwitchRule ¶

type SwitchRule struct {
}

func NewSwitchRule ¶ added in v0.0.4

func NewSwitchRule() *SwitchRule

func (SwitchRule) Id ¶

func (a SwitchRule) Id() string

func (SwitchRule) Infinity ¶ added in v0.0.4

func (a SwitchRule) Infinity() bool

func (SwitchRule) Initialize ¶

func (a SwitchRule) Initialize(ctx context.Context, options map[string]interface{}) error

func (SwitchRule) Run ¶

func (a SwitchRule) Run(ctx context.Context, subscribeQueueInput func(ctx context.Context, callback queue.SubscribeFunction[*data.InputEngine]) error, pushQueueOutput func(ctx context.Context, input *data.OutputEngine) error)

func (SwitchRule) Stop ¶

func (a SwitchRule) Stop(ctx context.Context) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL