agentfleet

Jun 17, 2026

Changes in this version

type Fleet

+ func (f *Fleet) Remove(taskID string)

Jun 17, 2026

Changes in this version

type FleetConfig

+ VTERows int

Jun 16, 2026

Changes in this version

type TUIConfig

+ FilterLines func([]string) []string

Jun 16, 2026

Changes in this version

type TUIConfig

+ OnClose func(taskID string)

Jun 15, 2026

Changes in this version

type TUIConfig

+ TitleRight func() string

Jun 15, 2026

Changes in this version

+ type LogBuffer struct

+ func NewLogBuffer(maxLines int) *LogBuffer

+ func (b *LogBuffer) Lines() []string

+ func (b *LogBuffer) Write(p []byte) (int, error)

type TUIConfig

+ Log *LogBuffer

+ MaxDoneTasks int

Jun 14, 2026

Changes in this version

type AgentConfig

+ Env []string

type Runner

+ func (r *Runner) Resize(rows, cols int) error

type TUIConfig

+ Title func() string

Jun 1, 2026

Changes in this version

+ func CommandFields(t Task) []string

+ type Agent interface

+ Done func() <-chan struct{}

+ Read func(p []byte) (int, error)

+ Resize func(rows, cols int) error

+ Start func(rows, cols int) error

+ Stop func() error

+ Write func(p []byte) (int, error)

+ type AgentConfig struct

+ PTYCols int

+ PTYRows int

+ func AgentConfigFromTerminal() AgentConfig

+ type BasicTask struct

+ Cmd string

+ TaskID string

+ TaskName string

+ func (t *BasicTask) Command() string

+ func (t *BasicTask) ID() string

+ func (t *BasicTask) Name() string

+ type Config struct

+ Agent AgentConfig

+ Fleet FleetConfig

+ TUI TUIConfig

+ func DefaultConfig() Config

+ type Fleet struct

+ func NewFleet(cfg FleetConfig) *Fleet

+ func (f *Fleet) Add(ctx context.Context, r *Runner) error

+ func (f *Fleet) Runners() []*Runner

+ func (f *Fleet) Wait(ctx context.Context) error

+ type FleetConfig struct

+ LogDir string

+ MaxConcurrent int

+ RingBufferSize int

+ SocketDir string

+ type Manager interface

+ Run func(ctx context.Context, fleet *Fleet) error

+ type MockAgent struct

+ func NewMockAgent() *MockAgent

+ func (m *MockAgent) Done() <-chan struct{}

+ func (m *MockAgent) Read(p []byte) (int, error)

+ func (m *MockAgent) ReadInput(timeout time.Duration) ([]byte, error)

+ func (m *MockAgent) Resize(rows, cols int) error

+ func (m *MockAgent) SimulateOutput(data []byte) error

+ func (m *MockAgent) Start(rows, cols int) error

+ func (m *MockAgent) Stop() error

+ func (m *MockAgent) Write(p []byte) (int, error)

+ type PtyAgent struct

+ func NewPtyAgent(command []string, cfg AgentConfig) *PtyAgent

+ func (a *PtyAgent) Done() <-chan struct{}

+ func (a *PtyAgent) Read(p []byte) (int, error)

+ func (a *PtyAgent) Resize(rows, cols int) error

+ func (a *PtyAgent) Start(rows, cols int) error

+ func (a *PtyAgent) Stop() error

+ func (a *PtyAgent) Write(p []byte) (int, error)

+ type Runner struct

+ func NewRunner(task Task, ag Agent, cfg FleetConfig, agentCfg AgentConfig) *Runner

+ func (r *Runner) Done() <-chan struct{}

+ func (r *Runner) FinishedAt() time.Time

+ func (r *Runner) Lines() []string

+ func (r *Runner) SetOutput(w io.Writer)

+ func (r *Runner) Start()

+ func (r *Runner) StartedAt() time.Time

+ func (r *Runner) Status() Status

+ func (r *Runner) StdinWriter() io.Writer

+ func (r *Runner) Stop() error

+ func (r *Runner) Task() Task

+ type Status int32

+ const StatusDone

+ const StatusFailed

+ const StatusPending

+ const StatusRunning

+ func (s Status) String() string

+ type TUIConfig struct

+ AutoOpen bool

+ CardWidth int

+ Columns int

+ PreviewLines int

+ RefreshRate time.Duration

+ type Task interface

+ Command func() string

+ ID func() string

+ Name func() string