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

packtrail

package module

Go to main page

Versions in this module

v0

v0.1.0

Jul 15, 2026

Changes in this version

+ const ExecCancelled

+ func ValidateFlowDef(defs ...FlowDef) error

type Branch

+ Attempt int

+ Generation uint64

+ type DeadLetter = store.DeadLetter

type Execution

+ NodeGeneration uint64

+ OutputVersions map[string]string

+ Outputs []string

type FlowDef

+ Version string

type FlowGraph

+ Version string

type GraphNode

+ OnError string

type NodeDef

+ OnError string

type Option

+ func WithArchive(retention time.Duration) Option

+ func WithAsyncInvoker(kind string, exec invoker.Invoker, opts ...asyncqueue.Option) Option

+ func WithDrainTimeout(d time.Duration) Option

+ func WithHistory(retention time.Duration) Option

+ func WithMaxDeliver(n int) Option

+ func WithMaxDocumentBytes(n int) Option

+ func WithMaxPayloadBytes(n int) Option

+ func WithReconcileActive(cronExpr string) Option

+ func WithReconcileFull(cronExpr string) Option

+ func WithResultCacheTTL(d time.Duration) Option

+ func WithSignalRetention(d time.Duration) Option

+ func WithStallRedrive(d time.Duration) Option

type Server

+ func (s *Server) ArchiveTerminal(ctx context.Context) (int, error)

+ func (s *Server) ByFlowEventsLimit(ctx context.Context, flow string, limit int) ([]Event, error)

+ func (s *Server) ByStatusEventsLimit(ctx context.Context, status string, limit int) ([]Event, error)

+ func (s *Server) Cancel(ctx context.Context, execID, reason string) error

+ func (s *Server) CompleteActivityWithGeneration(ctx context.Context, execID, node string, generation uint64, attempt int, ...) error

+ func (s *Server) DeadLetterCount(ctx context.Context) (uint64, error)

+ func (s *Server) GCIndex(ctx context.Context) (int, error)

+ func (s *Server) History(ctx context.Context, execID string, limit int) ([]Event, error)

+ func (s *Server) Init(ctx context.Context) error

+ func (s *Server) ListFunc(ctx context.Context, fn func(id string) error) error

+ func (s *Server) RecentDeadLetters(ctx context.Context, limit int) ([]DeadLetter, error)

+ func (s *Server) ReconcileActive(ctx context.Context) error

+ func (s *Server) RedriveStalled(ctx context.Context) (int, error)

+ func (s *Server) Results(ctx context.Context, execID string) (json.RawMessage, error)

+ func (s *Server) SignalWithID(ctx context.Context, execID, name, idempotencyKey string, ...) error

+ func (s *Server) StartWithID(ctx context.Context, execID, flow string, payload json.RawMessage) (string, error)

v0.0.2

Jun 23, 2026

Changes in this version

+ type EdgeDef struct

+ From string

+ To string

type Event

+ Error string

+ type FlowDef struct

+ Edges []EdgeDef

+ Name string

+ Nodes []NodeDef

+ type NodeDef struct

+ Branches []string

+ ID string

+ Invoker string

+ JoinPolicy string

+ OnTimeout string

+ Retry *RetryPolicy

+ Rules []RuleDef

+ SignalName string

+ Subject string

+ Target string

+ Timeout time.Duration

+ Type string

+ WaitFor []string

type Option

+ func WithFlowDef(f FlowDef) Option

+ type RetryPolicy struct

+ Backoff string

+ MaxAttempts int

+ type RuleDef struct

+ Default bool

+ To string

+ When string

type Server

+ func (s *Server) ByFlowEvents(ctx context.Context, flow string) ([]Event, error)

+ func (s *Server) ByStatusEvents(ctx context.Context, status string) ([]Event, error)

v0.0.1

Jun 20, 2026

Changes in this version

+ const ExecCompleted

+ const ExecFailed

+ const ExecRunning

+ const ExecWaiting

+ const NATSTaskKind

+ const StatusError

+ const StatusOK

+ const StatusPending

+ const StatusRetry

+ const TaskError

+ const TaskOK

+ const TaskRetry

+ var ErrNotFound = store.ErrNotFound

+ type Branch struct

+ Error string

+ Node string

+ Result json.RawMessage

+ Status string

+ type Event struct

+ ExecID string

+ Flow string

+ Node string

+ Revision uint64

+ Status string

+ Time time.Time

+ type Execution struct

+ Attempt int

+ Branches map[string]Branch

+ CurrentNode string

+ Error string

+ Flow string

+ ID string

+ Payload json.RawMessage

+ Signals map[string]json.RawMessage

+ Status string

+ UpdatedAt time.Time

+ WaitSignal string

+ type FlowGraph struct

+ Edges []GraphEdge

+ Name string

+ Nodes []GraphNode

+ type GraphEdge struct

+ From string

+ To string

+ type GraphNode struct

+ Branches []string

+ ID string

+ Invoker string

+ JoinPolicy string

+ OnTimeout string

+ Rules []GraphRule

+ SignalName string

+ Target string

+ Type string

+ WaitFor []string

+ type GraphRule struct

+ Default bool

+ To string

+ When string

+ type Handler = protocol.Handler

+ type Invoker = invoker.Invoker

+ type InvokerFunc = invoker.Func

+ type Option func(*config)

+ func WithDefaultTimeout(d time.Duration) Option

+ func WithFlow(yamlDoc []byte) Option

+ func WithFlowsDir(dir string) Option

+ func WithInvoker(kind string, inv invoker.Invoker) Option

+ func WithLeaseTTL(d time.Duration) Option

+ func WithMaxConcurrency(n int) Option

+ func WithNamespace(prefix string) Option

+ func WithOwnerID(id string) Option

+ func WithReconcile(cronExpr string) Option

+ func WithResultCache() Option

+ type Request = invoker.Request

+ type Result = invoker.Result

+ type Server struct

+ func New(nc *nats.Conn, opts ...Option) (*Server, error)

+ func (s *Server) ByFlow(ctx context.Context, flow string) ([]string, error)

+ func (s *Server) ByStatus(ctx context.Context, status string) ([]string, error)

+ func (s *Server) Close()

+ func (s *Server) CompleteActivity(ctx context.Context, execID, node string, attempt int, res Result) error

+ func (s *Server) FlowGraph(ctx context.Context, name string) (*FlowGraph, error)

+ func (s *Server) Flows() []string

+ func (s *Server) Get(ctx context.Context, execID string) (*Execution, error)

+ func (s *Server) Handle(subject string, h Handler) error

+ func (s *Server) List(ctx context.Context) ([]string, error)

+ func (s *Server) ListFlows(ctx context.Context) ([]string, error)

+ func (s *Server) Reconcile(ctx context.Context) error

+ func (s *Server) Resume(ctx context.Context, execID string) error

+ func (s *Server) Run(ctx context.Context) error

+ func (s *Server) ScheduleFlow(ctx context.Context, name, flow, cronExpr string, payload json.RawMessage) error

+ func (s *Server) Signal(ctx context.Context, execID, name string, payload json.RawMessage) error

+ func (s *Server) Start(ctx context.Context, flow string, payload json.RawMessage) (string, error)

+ func (s *Server) WatchEvents(ctx context.Context) (<-chan Event, error)

+ type Status = invoker.Status

+ type TaskRequest = protocol.TaskRequest

+ type TaskResponse = protocol.TaskResponse