crew

type Checkpoint struct {
	ID             string
	ProcessType    string
	Phase          string
	NodeStates     map[string]*NodeState
	OrderedTaskIDs []string // preserves task execution order for resume
	CreatedAt      time.Time
	UpdatedAt      time.Time
}

type CheckpointStore interface {
	Save(ctx context.Context, ckpt *Checkpoint) error
	Load(ctx context.Context, id string) (*Checkpoint, error)
	List(ctx context.Context, filter map[string]any) ([]*Checkpoint, error)
	Delete(ctx context.Context, id string) error
}

type Config struct {
	Agents          []*agent.Agent
	Tasks           []*task.Task
	Process         ProcessType
	ManagerLLM      llm.Client
	ManagerAgent    *agent.Agent
	Verbose         bool
	MaxRPM          int
	MaxCycles       int
	StepCallback    callback.Callback
	CheckpointStore CheckpointStore
}

type Crew struct {
	// contains filtered or unexported fields
}

type NodeState struct {
	TaskID    string
	Processed bool
	Failed    bool
	Output    string
	Error     string
}

type ProcessType string

type Result struct {
	Tasks map[string]*task.Task
	Usage map[string]int
}