debug

Documentation

Index

• type Debugger
  • func NewDebugger() *Debugger
  • func (d *Debugger) AfterTaskExecution(step Step, result interface{})
  • func (d *Debugger) BeforeTaskExecution(step Step, request interface{})
  • func (d *Debugger) EnableStepMode(enable bool)
  • func (d *Debugger) RemoveBreakpoint(breakpoint Step)
  • func (d *Debugger) SetBreakpoint(step Step)
• type Step

Types

type Debugger

type Debugger struct {
	Breakpoints map[Step]struct{} // Task names where the debugger will pause execution
	StepMode    bool              // Flag to step through the workflow one task at a time
	// contains filtered or unexported fields
}

Debugger is responsible for debugging Endly workflows.

func NewDebugger

func NewDebugger() *Debugger

NewDebugger creates a new debugger instance with initialized channels.

func (*Debugger) AfterTaskExecution

func (d *Debugger) AfterTaskExecution(step Step, result interface{})

AfterTaskExecution logs task results, similar to the previous implementation.

func (*Debugger) BeforeTaskExecution

func (d *Debugger) BeforeTaskExecution(step Step, request interface{})

BeforeTaskExecution is modified to pause at breakpoints or in step mode, waiting for channel input to continue.

func (*Debugger) EnableStepMode

func (d *Debugger) EnableStepMode(enable bool)

EnableStepMode enables or disables step mode.

func (*Debugger) RemoveBreakpoint

func (d *Debugger) RemoveBreakpoint(breakpoint Step)

RemoveBreakpoint removes a breakpoint from a task by its name.

func (*Debugger) SetBreakpoint

func (d *Debugger) SetBreakpoint(step Step)

SetBreakpoint sets a breakpoint on a task by its name.

type Step

type Step struct {
	Workflow string
	TaskName string
}