dashboard

type A2AConnRegistry interface {
	ActiveConnections() []a2a.A2AConnection
}

type A2ARegistryLister interface {
	ListAll() []*a2a.AgentCard
}

type CrewController interface {
	CrewPauser
	CrewInjecter
}

type CrewInjecter interface {
	InjectTask(t *task.Task) error
}

type CrewPauser interface {
	Pause()
	ResumeExecution()
}

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

type DashboardOption func(*Dashboard)

type MCPServerLister interface {
	ListTools() []mcp.ToolDescriptor
}

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

type Session struct {
	ID         string    `json:"id"`
	CrewConfig string    `json:"crew_config,omitempty"`
	Events     string    `json:"events,omitempty"`
	StartedAt  time.Time `json:"started_at"`
	EndedAt    time.Time `json:"ended_at,omitempty"`
	Status     string    `json:"status"`
}

type SessionStore interface {
	Create(ctx context.Context, id, crewConfig string) error
	AppendEvents(ctx context.Context, id string, events []telemetry.Event) error
	List(ctx context.Context) ([]Session, error)
	Get(ctx context.Context, id string) (*Session, error)
	SetStatus(ctx context.Context, id, status string) error
	Close() error
}

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

type TokenUsage struct {
	AgentRole        string  `json:"agent_role,omitempty"`
	TaskID           string  `json:"task_id,omitempty"`
	TokensPrompt     int64   `json:"tokens_prompt"`
	TokensCompletion int64   `json:"tokens_completion"`
	TokensTotal      int64   `json:"tokens_total"`
	CostEstimate     float64 `json:"cost_estimate"`
	Model            string  `json:"model,omitempty"`
}