Go

conn, err := threadify.Connect(ctx, apiKey,
    threadify.WithEngineURL("https://threadify.example.com"))
if err != nil { return err }
defer func() { _ = conn.Close() }()
threads, err := conn.GetThreadsByRef(ctx, map[string]string{"order_id": "ORD-1001"})
if err != nil { return err }
_ = threads
thread, err := conn.Join(ctx, threadify.WithJoinThreadID(threadID), threadify.WithJoinRole("processor"))
if err != nil { return err }
grant, err := thread.WaitFor(ctx, "charge", &threadify.WaitOptions{Timeout: 15 * time.Second})
if err != nil { return err }
_ = grant // Execute the operation, or call grant.Cancel(ctx) if abandoning it.
result, err := thread.Step("charge").AddContext(map[string]any{"amount": 42}).Success(
    ctx, "charged", threadify.ReportOptions{WaitFor: true})
if err != nil { return err }
validation, err := thread.WaitForValidation(ctx, "charge", result.StepID, nil)