crew

Jul 22, 2026

Changes in this version

type NodeState

+ Skipped bool

Jul 20, 2026

Changes in this version

+ type Awaitable struct

+ func (a *Awaitable) Await(ctx context.Context) (*Result, error)

+ func (a *Awaitable) AwaitWithTimeout(ctx context.Context, d time.Duration) (*Result, error)

+ func (a *Awaitable) State() AwaitableState

+ type AwaitableState uint32

+ const AwaitableCompleted

+ const AwaitableFailed

+ const AwaitablePending

+ const AwaitableRunning

+ func (s AwaitableState) String() string

type Checkpoint

+ CrewID string

+ TaskStates map[string]*NodeState

type CheckpointStore

+ ListCheckpoints func(ctx context.Context, crewID string) ([]*Checkpoint, error)

type Config

+ Cache bool

+ CrewID string

+ MaxParallel int

+ Planning bool

+ PlanningLLM llm.Client

+ Skills []string

type Crew

+ func (c *Crew) CacheHitCount() int64

+ func (c *Crew) CacheMissCount() int64

+ func (c *Crew) ClearToolCache()

+ func (c *Crew) Fork(checkpointID string) (string, error)

+ func (c *Crew) KickoffAsync(ctx context.Context) (*Awaitable, <-chan CrewStreamingOutput, error)

+ func (c *Crew) KickoffForEach(ctx context.Context, inputs []map[string]any) ([]*Result, error)

+ func (c *Crew) KickoffForEachAsync(ctx context.Context, inputs []map[string]any) (<-chan ForEachResult, error)

+ func (c *Crew) Replay(ctx context.Context, freshCrew *Crew, taskID string) (*Result, error)

+ func (c *Crew) ReplayFromCheckpoint(ctx context.Context, freshCrew *Crew, checkpointID, taskID string) (*Result, error)

+ func (c *Crew) SetEventBus(bus *events.EventBus)

+ type ForEachResult struct

+ Error error

+ Index int

+ Input map[string]any

+ Result *Result

type NodeState

+ AgentID string

+ ExpectedOutput string

+ InputContext map[string]string

+ Plan string

+ TaskDescription string

+ TokenUsage map[string]int

Jul 19, 2026

Changes in this version

type Config

+ Memory *memory.UnifiedMemory

+ Stream bool

type Crew

+ func (c *Crew) FrameStream() <-chan stream.Frame

+ func (c *Crew) KickoffStream(ctx context.Context) (<-chan CrewStreamingOutput, error)

+ type CrewStreamingOutput struct

+ AgentRole string

+ Content string

+ Error string

+ IsLast bool

+ TaskID string

+ TokenUsage llm.Usage

Jul 18, 2026

Changes in this version

type Config

+ FlowEdges []flow.Edge

type Crew

+ func (c *Crew) InjectTask(t *task.Task) error

+ func (c *Crew) IsPaused() bool

+ func (c *Crew) Pause()

+ func (c *Crew) ResumeExecution()

Jul 17, 2026

Changes in this version

type Config

+ KnowledgeSources []knowledge.KnowledgeSource

type Crew

+ func (c *Crew) Train(ctx context.Context, iterations int, inputs map[string]any, trainingDir string, ...) (*TrainingReport, error)

+ type TrainingReport struct

+ AgentAdvice map[string]string

+ FeedbackCount int

+ IterationCount int

+ TotalDuration time.Duration

Jul 16, 2026

Changes in this version

+ func GetOutput[T any](r *Result, taskID string) (T, error)

+ type Checkpoint struct

+ CreatedAt time.Time

+ ID string

+ NodeStates map[string]*NodeState

+ OrderedTaskIDs []string

+ Phase string

+ ProcessType string

+ UpdatedAt time.Time

+ type CheckpointStore interface

+ Delete func(ctx context.Context, id string) error

+ List func(ctx context.Context, filter map[string]any) ([]*Checkpoint, error)

+ Load func(ctx context.Context, id string) (*Checkpoint, error)

+ Save func(ctx context.Context, ckpt *Checkpoint) error

+ type Config struct

+ Agents []*agent.Agent

+ CheckpointStore CheckpointStore

+ ManagerAgent *agent.Agent

+ ManagerLLM llm.Client

+ MaxCycles int

+ MaxRPM int

+ Process ProcessType

+ StepCallback callback.Callback

+ Tasks []*task.Task

+ Verbose bool

+ type Crew struct

+ func New(cfg Config) *Crew

+ func (c *Crew) Kickoff(ctx context.Context) (*Result, error)

+ func (c *Crew) Resume(ctx context.Context, freshCrew *Crew, checkpointID string) (*Result, error)

+ func (c *Crew) SetStepCallback(cb callback.Callback)

+ func (c *Crew) StepCallback() callback.Callback

+ type NodeState struct

+ Error string

+ Failed bool

+ Output string

+ Processed bool

+ TaskID string

+ type ProcessType string

+ const ProcessConsensual

+ const ProcessFlow

+ const ProcessHierarchical

+ const ProcessReflective

+ const ProcessSequential

+ const ProcessStateMachine

+ type Result struct

+ Tasks map[string]*task.Task

+ Usage map[string]int