fork

package

v0.0.6 Latest Latest Go to latest Published: Jul 22, 2023 License: GPL-3.0 Imports: 5 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 ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ForkRule ¶

type ForkRule struct {
}

func NewForkRule ¶ added in v0.0.4

func NewForkRule() *ForkRule

func (ForkRule) Id ¶

func (f ForkRule) Id() string

func (ForkRule) Infinity ¶ added in v0.0.4

func (f ForkRule) Infinity() bool

func (ForkRule) Initialize ¶

func (f ForkRule) Initialize(ctx context.Context, option map[string]interface{}) error

func (ForkRule) Run ¶

func (f ForkRule) 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 (ForkRule) Stop ¶

func (f ForkRule) Stop(ctx context.Context) error

type Option ¶

type Option struct {
	NextSuccess []string `json:"next_success"`
	Debug       bool     `json:"debug"`
}

Source Files ¶

View all Source files

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