Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Conditional ¶
type Conditional struct {
// contains filtered or unexported fields
}
func NewConditional ¶
func NewConditional(mainBranch string, dataQuery map[string]interface{}) *Conditional
func (Conditional) Data ¶
func (r Conditional) Data() map[string]interface{}
type ConditionalRule ¶
type ConditionalRule struct { }
func NewConditionalRule ¶ added in v0.0.4
func NewConditionalRule() *ConditionalRule
func (ConditionalRule) Id ¶
func (a ConditionalRule) Id() string
func (ConditionalRule) Infinity ¶ added in v0.0.4
func (a ConditionalRule) Infinity() bool
func (ConditionalRule) Initialize ¶
func (a ConditionalRule) Initialize(ctx context.Context, options map[string]interface{}) error
func (ConditionalRule) Run ¶
func (a ConditionalRule) Run(ctx context.Context, subscribeQueueInput func(ctx context.Context, callback queue.SubscribeFunction[*data.InputEngine]) error, pushQueueOutput func(ctx context.Context, input *data.OutputEngine) error)
Click to show internal directories.
Click to hide internal directories.