Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

petalflow

package module

Go to main page

Versions in this module

v0

v0.4.0

Aug 3, 2026

v0.3.0

Jul 31, 2026

Changes in this version

+ const NodeKindWebhookCall

+ const NodeKindWebhookTrigger

+ const WebhookAuthTypeHeaderToken

+ const WebhookAuthTypeNone

+ const WebhookCallErrorPolicyContinue

+ const WebhookCallErrorPolicyFail

+ const WebhookCallErrorPolicyRecord

+ var NewWebhookCallNode = nodes.NewWebhookCallNode

+ var NewWebhookTriggerNode = nodes.NewWebhookTriggerNode

+ type StreamChunk = core.StreamChunk

+ type StreamingLLMClient = core.StreamingLLMClient

+ type WebhookAuthType = nodes.WebhookAuthType

+ type WebhookCallErrorPolicy = nodes.WebhookCallErrorPolicy

+ type WebhookCallNode = nodes.WebhookCallNode

+ type WebhookCallNodeConfig = nodes.WebhookCallNodeConfig

+ type WebhookTriggerAuthConfig = nodes.WebhookTriggerAuthConfig

+ type WebhookTriggerNode = nodes.WebhookTriggerNode

+ type WebhookTriggerNodeConfig = nodes.WebhookTriggerNodeConfig

v0.2.0

Feb 6, 2026

Changes in this version

+ const ErrorPolicyContinue

+ const ErrorPolicyFail

+ const ErrorPolicyRecord

+ const EventNodeFailed

+ const EventNodeFinished

+ const EventNodeOutput

+ const EventNodeStarted

+ const EventRouteDecision

+ const EventRunFinished

+ const EventRunStarted

+ const EventStepAborted

+ const EventStepPaused

+ const EventStepResumed

+ const EventStepSkipped

+ const FilterOpByType

+ const FilterOpCustom

+ const FilterOpDedupe

+ const FilterOpExclude

+ const FilterOpMatch

+ const FilterOpThreshold

+ const FilterOpTopN

+ const FilterTargetArtifacts

+ const FilterTargetMessages

+ const FilterTargetVar

+ const GateActionBlock

+ const GateActionRedirect

+ const GateActionSkip

+ const GuardianActionFail

+ const GuardianActionRedirect

+ const GuardianActionSkip

+ const GuardianCheckCustom

+ const GuardianCheckEnum

+ const GuardianCheckMaxLength

+ const GuardianCheckMinLength

+ const GuardianCheckPII

+ const GuardianCheckPattern

+ const GuardianCheckRange

+ const GuardianCheckRequired

+ const GuardianCheckSchema

+ const GuardianCheckTypeCheck

+ const HumanRequestApproval

+ const HumanRequestChoice

+ const HumanRequestEdit

+ const HumanRequestInput

+ const HumanRequestReview

+ const HumanTimeoutDefault

+ const HumanTimeoutFail

+ const HumanTimeoutSkip

+ const NodeKindCache

+ const NodeKindFilter

+ const NodeKindGate

+ const NodeKindGuardian

+ const NodeKindHuman

+ const NodeKindLLM

+ const NodeKindMap

+ const NodeKindMerge

+ const NodeKindNoop

+ const NodeKindRouter

+ const NodeKindSink

+ const NodeKindTool

+ const NodeKindTransform

+ const OpContains

+ const OpEquals

+ const OpExists

+ const OpGreaterThan

+ const OpIn

+ const OpLessThan

+ const OpNotEquals

+ const OpNotExists

+ const PIITypeCreditCard

+ const PIITypeDateOfBirth

+ const PIITypeEmail

+ const PIITypeIPAddress

+ const PIITypePhone

+ const PIITypeSSN

+ const SinkErrorPolicyContinue

+ const SinkErrorPolicyFail

+ const SinkErrorPolicyRecord

+ const SinkTypeCustom

+ const SinkTypeFile

+ const SinkTypeLog

+ const SinkTypeMetric

+ const SinkTypeVar

+ const SinkTypeWebhook

+ const StepActionAbort

+ const StepActionContinue

+ const StepActionRunToBreakpoint

+ const StepActionSkipNode

+ const StepPointAfterNode

+ const StepPointBeforeNode

+ const TransformCustom

+ const TransformFlatten

+ const TransformMap

+ const TransformMerge

+ const TransformOmit

+ const TransformParse

+ const TransformPick

+ const TransformRename

+ const TransformStringify

+ const TransformTemplate

+ var ChannelEventHandler = runtime.ChannelEventHandler

+ var DefaultRetryPolicy = core.DefaultRetryPolicy

+ var DefaultRunOptions = runtime.DefaultRunOptions

+ var DefaultStepConfig = runtime.DefaultStepConfig

+ var ErrCycleDetected = graph.ErrCycleDetected

+ var ErrDuplicateNode = graph.ErrDuplicateNode

+ var ErrEmptyGraph = graph.ErrEmptyGraph

+ var ErrInvalidEdge = graph.ErrInvalidEdge

+ var ErrMaxHopsExceeded = runtime.ErrMaxHopsExceeded

+ var ErrNoEntryNode = graph.ErrNoEntryNode

+ var ErrNodeAlreadyAdded = graph.ErrNodeAlreadyAdded

+ var ErrNodeExecution = runtime.ErrNodeExecution

+ var ErrNodeNotFound = graph.ErrNodeNotFound

+ var ErrRunCanceled = runtime.ErrRunCanceled

+ var ErrStepAborted = runtime.ErrStepAborted

+ var ErrStepRequestNotFound = runtime.ErrStepRequestNotFound

+ var MultiEventHandler = runtime.MultiEventHandler

+ var NewAllMergeStrategy = nodes.NewAllMergeStrategy

+ var NewAutoApproveHandler = nodes.NewAutoApproveHandler

+ var NewAutoRejectHandler = nodes.NewAutoRejectHandler

+ var NewAutoStepController = runtime.NewAutoStepController

+ var NewBaseNode = core.NewBaseNode

+ var NewBestScoreMergeStrategy = nodes.NewBestScoreMergeStrategy

+ var NewBranch = graph.NewBranch

+ var NewBreakpointStepController = runtime.NewBreakpointStepController

+ var NewCacheKeyBuilder = nodes.NewCacheKeyBuilder

+ var NewCacheNode = nodes.NewCacheNode

+ var NewCallbackHumanHandler = nodes.NewCallbackHumanHandler

+ var NewCallbackStepController = runtime.NewCallbackStepController

+ var NewChannelHumanHandler = nodes.NewChannelHumanHandler

+ var NewChannelStepController = runtime.NewChannelStepController

+ var NewConcatMergeStrategy = nodes.NewConcatMergeStrategy

+ var NewEnvelope = core.NewEnvelope

+ var NewEvent = runtime.NewEvent

+ var NewFilterNode = nodes.NewFilterNode

+ var NewFuncMergeStrategy = nodes.NewFuncMergeStrategy

+ var NewFuncNode = core.NewFuncNode

+ var NewFuncTool = core.NewFuncTool

+ var NewGateNode = nodes.NewGateNode

+ var NewGraph = graph.NewGraph

+ var NewGraphBuilder = graph.NewGraphBuilder

+ var NewGuardianNode = nodes.NewGuardianNode

+ var NewHumanNode = nodes.NewHumanNode

+ var NewJSONMergeStrategy = nodes.NewJSONMergeStrategy

+ var NewLLMNode = nodes.NewLLMNode

+ var NewLLMRouter = nodes.NewLLMRouter

+ var NewMapNode = nodes.NewMapNode

+ var NewMemoryCacheStore = nodes.NewMemoryCacheStore

+ var NewMergeNode = nodes.NewMergeNode

+ var NewMockHTTPClient = nodes.NewMockHTTPClient

+ var NewMockMetricRecorder = nodes.NewMockMetricRecorder

+ var NewMockNode = nodes.NewMockNode

+ var NewNoopNode = core.NewNoopNode

+ var NewPipelineBranch = graph.NewPipelineBranch

+ var NewQueuedHumanHandler = nodes.NewQueuedHumanHandler

+ var NewRuleRouter = nodes.NewRuleRouter

+ var NewRuntime = runtime.NewRuntime

+ var NewSinkNode = nodes.NewSinkNode

+ var NewToolNode = nodes.NewToolNode

+ var NewToolNodeWithRegistry = nodes.NewToolNodeWithRegistry

+ var NewToolRegistry = core.NewToolRegistry

+ var NewTransformNode = nodes.NewTransformNode

+ type AllMergeStrategy = nodes.AllMergeStrategy

+ type Artifact = core.Artifact

+ type AutoApproveHandler = nodes.AutoApproveHandler

+ type AutoStepController = runtime.AutoStepController

+ type BaseNode = core.BaseNode

+ type BasicGraph = graph.BasicGraph

+ type BasicRuntime = runtime.BasicRuntime

+ type BestScoreMergeConfig = nodes.BestScoreMergeConfig

+ type BestScoreMergeStrategy = nodes.BestScoreMergeStrategy

+ type BreakpointStepController = runtime.BreakpointStepController

+ type Budget = core.Budget

+ type CacheKeyBuilder = nodes.CacheKeyBuilder

+ type CacheNode = nodes.CacheNode

+ type CacheNodeConfig = nodes.CacheNodeConfig

+ type CacheResult = nodes.CacheResult

+ type CacheStore = nodes.CacheStore

+ type CallbackHumanHandler = nodes.CallbackHumanHandler

+ type CallbackStepController = runtime.CallbackStepController

+ type ChannelHumanHandler = nodes.ChannelHumanHandler

+ type ChannelStepController = runtime.ChannelStepController

+ type ConcatMergeConfig = nodes.ConcatMergeConfig

+ type ConcatMergeStrategy = nodes.ConcatMergeStrategy

+ type ConditionFunc = func(ctx context.Context, env *Envelope) (bool, error)

+ type ConditionOp = nodes.ConditionOp

+ type Edge = graph.Edge

+ type EnvFunc = func(ctx context.Context, env *Envelope) (*Envelope, error)

+ type Envelope = core.Envelope

+ func Run(ctx context.Context, g Graph, env *Envelope) (*Envelope, error)

+ func RunParallel(ctx context.Context, g Graph, env *Envelope, concurrency int) (*Envelope, error)

+ func RunWithHandler(ctx context.Context, g Graph, env *Envelope, handler EventHandler) (*Envelope, error)

+ func RunWithOptions(ctx context.Context, g Graph, env *Envelope, opts RunOptions) (*Envelope, error)

+ type EnvelopeModification = runtime.EnvelopeModification

+ type EnvelopeSnapshot = runtime.EnvelopeSnapshot

+ type ErrorPolicy = core.ErrorPolicy

+ type Event = runtime.Event

+ type EventEmitter = runtime.EventEmitter

+ type EventHandler = runtime.EventHandler

+ type EventKind = runtime.EventKind

+ type FanOutBranch = graph.FanOutBranch

+ type FilterNode = nodes.FilterNode

+ type FilterNodeConfig = nodes.FilterNodeConfig

+ type FilterOp = nodes.FilterOp

+ type FilterOpType = nodes.FilterOpType

+ type FilterStats = nodes.FilterStats

+ type FilterTarget = nodes.FilterTarget

+ type FuncMergeStrategy = nodes.FuncMergeStrategy

+ type FuncNode = core.FuncNode

+ type FuncTool = core.FuncTool

+ type GateAction = nodes.GateAction

+ type GateNode = nodes.GateNode

+ type GateNodeConfig = nodes.GateNodeConfig

+ type GateResult = nodes.GateResult

+ type Graph = graph.Graph

+ func BuildGraph(name string, nodes ...Node) (Graph, error)

+ func MustBuildGraph(name string, nodes ...Node) Graph

+ type GraphBuilder = graph.GraphBuilder

+ type GraphSnapshot = runtime.GraphSnapshot

+ type GuardianAction = nodes.GuardianAction

+ type GuardianCheck = nodes.GuardianCheck

+ type GuardianCheckType = nodes.GuardianCheckType

+ type GuardianFailure = nodes.GuardianFailure

+ type GuardianNode = nodes.GuardianNode

+ type GuardianNodeConfig = nodes.GuardianNodeConfig

+ type GuardianResult = nodes.GuardianResult

+ type HTTPClient = nodes.HTTPClient

+ type HumanCallbackFunc = func(ctx context.Context, req *HumanRequest) (*HumanResponse, error)

+ type HumanHandler = nodes.HumanHandler

+ type HumanNode = nodes.HumanNode

+ type HumanNodeConfig = nodes.HumanNodeConfig

+ type HumanOption = nodes.HumanOption

+ type HumanRequest = nodes.HumanRequest

+ type HumanRequestType = nodes.HumanRequestType

+ type HumanResponse = nodes.HumanResponse

+ type HumanTimeoutAction = nodes.HumanTimeoutAction

+ type JSONMergeConfig = nodes.JSONMergeConfig

+ type JSONMergeStrategy = nodes.JSONMergeStrategy

+ type LLMClient = core.LLMClient

+ type LLMMessage = core.LLMMessage

+ type LLMNode = nodes.LLMNode

+ type LLMNodeConfig = nodes.LLMNodeConfig

+ type LLMReasoningOutput = core.LLMReasoningOutput

+ type LLMRequest = core.LLMRequest

+ type LLMResponse = core.LLMResponse

+ type LLMRouter = nodes.LLMRouter

+ type LLMRouterConfig = nodes.LLMRouterConfig

+ type LLMTokenUsage = core.LLMTokenUsage

+ type LLMToolCall = core.LLMToolCall

+ type LLMToolResult = core.LLMToolResult

+ type MapNode = nodes.MapNode

+ type MapNodeConfig = nodes.MapNodeConfig

+ type MemoryCacheStore = nodes.MemoryCacheStore

+ type MergeCapable = core.MergeCapable

+ type MergeFunc = func(ctx context.Context, inputs []*Envelope) (*Envelope, error)

+ type MergeNode = nodes.MergeNode

+ type MergeNodeConfig = nodes.MergeNodeConfig

+ type MergeStrategy = nodes.MergeStrategy

+ type Message = core.Message

+ type MetricRecorder = nodes.MetricRecorder

+ type MockHTTPClient = nodes.MockHTTPClient

+ type MockMetric = nodes.MockMetric

+ type MockMetricRecorder = nodes.MockMetricRecorder

+ type MockNode = nodes.MockNode

+ type Node = core.Node

+ type NodeError = core.NodeError

+ type NodeFunc = core.NodeFunc

+ type NodeKind = core.NodeKind

+ type NoopNode = core.NoopNode

+ type PIIType = nodes.PIIType

+ type PetalTool = core.PetalTool

+ type QueuedHumanHandler = nodes.QueuedHumanHandler

+ type RetryPolicy = core.RetryPolicy

+ type RouteCondition = nodes.RouteCondition

+ type RouteDecision = core.RouteDecision

+ type RouteRule = nodes.RouteRule

+ type RouterNode = core.RouterNode

+ type RuleRouter = nodes.RuleRouter

+ type RuleRouterConfig = nodes.RuleRouterConfig

+ type RunOptions = runtime.RunOptions

+ func NewStepRunOptions(controller StepController) RunOptions

+ func NewStepRunOptionsWithConfig(controller StepController, config *StepConfig) RunOptions

+ func NewTimedRunOptions(now func() time.Time) RunOptions

+ type Runtime = runtime.Runtime

+ type ShouldPauseFunc = runtime.ShouldPauseFunc

+ type SinkErrorPolicy = nodes.SinkErrorPolicy

+ type SinkNode = nodes.SinkNode

+ type SinkNodeConfig = nodes.SinkNodeConfig

+ type SinkResult = nodes.SinkResult

+ type SinkTarget = nodes.SinkTarget

+ type SinkTargetResult = nodes.SinkTargetResult

+ type SinkType = nodes.SinkType

+ type SinkWriteFunc = func(ctx context.Context, env *Envelope, target *SinkTarget) error

+ type StepAction = runtime.StepAction

+ type StepCallback = runtime.StepCallback

+ type StepConfig = runtime.StepConfig

+ type StepController = runtime.StepController

+ type StepHandler = runtime.StepHandler

+ type StepPoint = runtime.StepPoint

+ type StepRequest = runtime.StepRequest

+ type StepResponse = runtime.StepResponse

+ type TokenUsage = core.TokenUsage

+ type ToolNode = nodes.ToolNode

+ type ToolNodeConfig = nodes.ToolNodeConfig

+ type ToolRegistry = core.ToolRegistry

+ type TraceInfo = core.TraceInfo

+ type TransformFunc = func(ctx context.Context, env *Envelope) (*Envelope, error)

+ type TransformNode = nodes.TransformNode

+ type TransformNodeConfig = nodes.TransformNodeConfig

+ type TransformType = nodes.TransformType

+ type ValidateFunc = func(ctx context.Context, env *Envelope, check *GuardianCheck) (bool, string, error)

v0.1.0

Feb 2, 2026