client

package

Go to main page

Versions in this module

v0

v0.3.9

Aug 21, 2026

v0.3.8

Aug 21, 2026

v0.3.7

Aug 21, 2026

v0.3.6

Aug 21, 2026

Changes in this version

type Client

+ func (c *Client) HTTPClient() *http.Client

type DispatchOpts

+ Discipline string

v0.3.5

Aug 20, 2026

Changes in this version

type Client

+ func (c *Client) BaseURL() string

v0.3.4

Aug 20, 2026

v0.3.3

Aug 20, 2026

Changes in this version

type Client

+ func (c *Client) PutDesktopState(ctx context.Context, st proto.DesktopState) error

v0.3.2

Aug 19, 2026

Changes in this version

type Client

+ func NewRelay(d *relay.Dialer, token string) *Client

v0.3.1

Aug 19, 2026

v0.3.0

Aug 19, 2026

Changes in this version

+ var ErrArchivedEventMissing = errors.New("任务已归档但 archived 事件缺失")

+ var ErrBundleUnsupported = errors.New("对端 agentd 不支持 /api/tasks/{id}/bundle")

+ var ErrDependencyFailed = errors.New("依赖任务已失败")

type Client

+ func (c *Client) Bundle(ctx context.Context, taskID, have string) (io.ReadCloser, error)

+ func (c *Client) FramesStream(ctx context.Context, taskID string, offset, tail int64, follow bool) (io.ReadCloser, int64, error)

+ func (c *Client) IssueAuthTicket(ctx context.Context, deviceName string) (*proto.AuthTicketResp, error)

+ func (c *Client) ListSessions(ctx context.Context) ([]proto.SessionInfo, error)

+ func (c *Client) ListTasksAll(ctx context.Context) (*proto.TasksResp, error)

+ func (c *Client) Machines(ctx context.Context) (*proto.MachinesResp, error)

+ func (c *Client) MarkForwarded() *Client

+ func (c *Client) NoRedirect() *Client

+ func (c *Client) PatchProject(ctx context.Context, name, newName, path string) (proto.ProjectLocation, error)

+ func (c *Client) ProjectTree(ctx context.Context) (*proto.ProjectTreeResp, error)

+ func (c *Client) ProjectTreeAll(ctx context.Context) (*proto.ProjectTreeResp, error)

+ func (c *Client) PtySessions(ctx context.Context) (*proto.PtySessionsResp, error)

+ func (c *Client) PullUpdate(ctx context.Context, tag, sum string, force bool) (*proto.UpdateResp, error)

+ func (c *Client) RevokeSession(ctx context.Context, id string) error

+ func (c *Client) StreamEventsOnce(ctx context.Context, taskID string, fromSeq int64, ...) error

+ func (c *Client) WaitArchived(ctx context.Context, taskID string) (*proto.Event, error)

v0.2.3

Aug 13, 2026

Changes in this version

+ const BacklogSummaryType

+ var ErrFootprintUnsupported = errors.New("对端 agentd 不支持足迹体检")

+ var ErrIdleTimeout = errors.New("空闲超时：期间未收到任何帧")

+ var ErrReclaimUnsupported = errors.New("对端 agentd 不支持 worktree 回收")

+ var ErrStatusUnsupported = errors.New("对端 agentd 不支持 /api/status")

+ var ErrUnreachable = errors.New("对端 agentd 够不着")

+ var ErrUpdateUnsupported = errors.New("对端 agentd 不支持 /api/update")

+ type AttachInfo struct

+ PendingTickets []proto.Ticket

+ RecentEvents []proto.Event

+ Task proto.TaskView

+ type BacklogSummary struct

+ Actionable []proto.Ticket

+ FromSeq int64

+ Missed int

+ MissedTruncated bool

+ Stale int

+ State proto.TaskState

+ TaskID string

+ ToSeq int64

+ Type string

+ type Client struct

+ func New(addr, token string) *Client

+ func NewWithWSTiming(addr, token string, initial, max, stableAfter time.Duration) *Client

+ func (c *Client) Attach(ctx context.Context, taskID string) (*AttachInfo, error)

+ func (c *Client) Continue(ctx context.Context, taskID, instructions string) error

+ func (c *Client) Diff(ctx context.Context, taskID, base string) (string, error)

+ func (c *Client) Dispatch(ctx context.Context, opts DispatchOpts) (*proto.Task, error)

+ func (c *Client) Done(ctx context.Context, taskID, note string) (bool, error)

+ func (c *Client) DropCursor(taskID string)

+ func (c *Client) Fetch(ctx context.Context, taskID, relPath string) (string, error)

+ func (c *Client) FollowEvents(ctx context.Context, taskID string, all bool, idle time.Duration, ...) error

+ func (c *Client) Footprint(ctx context.Context) (*proto.FootprintResp, error)

+ func (c *Client) ListTasks(ctx context.Context) ([]proto.TaskView, error)

+ func (c *Client) ProjectAdd(ctx context.Context, opts ProjectAddOpts) (*proto.ProjectLocation, error)

+ func (c *Client) ProjectList(ctx context.Context) ([]proto.ProjectLocation, error)

+ func (c *Client) ProjectRemove(ctx context.Context, name string) error

+ func (c *Client) PushUpdate(ctx context.Context, tag, sum string, tgz []byte, force bool) (*proto.UpdateResp, error)

+ func (c *Client) Reclaim(ctx context.Context, taskID string, force bool) (*proto.ReclaimResp, error)

+ func (c *Client) ReclaimList(ctx context.Context) (*proto.ReclaimListResp, error)

+ func (c *Client) RenderStream(ctx context.Context, taskID string, offset, tail int64, follow bool) (io.ReadCloser, int64, error)

+ func (c *Client) Reply(ctx context.Context, taskID, ticketID, answer string) error

+ func (c *Client) RestartAgentd(ctx context.Context, force bool) (*proto.UpdateResp, error)

+ func (c *Client) Resume(ctx context.Context, taskID string, force bool) (string, error)

+ func (c *Client) Run(ctx context.Context, taskID, cmd string) (stdout string, exitCode int, err error)

+ func (c *Client) Status(ctx context.Context) (*proto.StatusResp, error)

+ func (c *Client) Stop(ctx context.Context, taskID string) (worktreeRemoved bool, err error)

+ func (c *Client) WaitEvent(ctx context.Context, taskID string, all bool) (*proto.Event, error)

+ func (c *Client) WaitVersion(ctx context.Context, want string, timeout, interval time.Duration) error

+ type DispatchOpts struct

+ Base string

+ BaseCommit string

+ Branch string

+ Executor string

+ Model string

+ Name string

+ NewBranch string

+ NewWorktree bool

+ PlanB64 string

+ PlanName string

+ ProjectID string

+ ProjectName string

+ Prompt string

+ Target string

+ Worktree string

+ type ProjectAddOpts struct

+ Name string

+ OriginURL string

+ Path string

+ type ReclaimRejected struct

+ Dirty []proto.DirtyFile

+ Msg string

+ Reason proto.ReclaimReason

+ func (e *ReclaimRejected) Error() string

+ type UpdateRejected struct

+ Msg string

+ Reason string

+ func (e *UpdateRejected) Error() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL