Versions in this module Expand all Collapse all v1 v1.1.0 May 22, 2026 Changes in this version + type Client struct + func Connect(ctx context.Context, t transport.Transport, opts Options) (*Client, error) + func (c *Client) Ack(ctx context.Context, seq uint64) error + func (c *Client) Close(ctx context.Context) error + func (c *Client) Features() []string + func (c *Client) HasFeature(name string) bool + func (c *Client) ListJobs(ctx context.Context, req ListJobsRequest) (*JobList, error) + func (c *Client) SessionID() string + func (c *Client) Submit(ctx context.Context, req SubmitRequest) (*JobHandle, error) + func (c *Client) Subscribe(ctx context.Context, jobID string, opts SubscribeOptions) (*Subscription, error) + func (c *Client) Welcome() *messages.SessionWelcome + type JobHandle struct + func (h *JobHandle) Accepted() *messages.JobAccepted + func (h *JobHandle) Agent() string + func (h *JobHandle) Cancel(ctx context.Context, reason string) error + func (h *JobHandle) Chunks() <-chan messages.ResultChunkBody + func (h *JobHandle) CollectChunks(ctx context.Context) ([]byte, error) + func (h *JobHandle) Done() <-chan struct{} + func (h *JobHandle) Err() error + func (h *JobHandle) Events() <-chan messages.JobEvent + func (h *JobHandle) ID() string + func (h *JobHandle) Result() *messages.JobResult + func (h *JobHandle) Wait(ctx context.Context) (*messages.JobResult, error) + type JobList struct + Jobs []messages.JobInfo + NextCursor string + type ListJobsRequest struct + Cursor string + Filter messages.ListJobsFilter + Limit int + type Options struct + AutoAckInterval time.Duration + AutoAckWindow uint64 + ClientName string + ClientVersion string + Features []string + Logger *slog.Logger + Token string + type SubmitRequest struct + Agent string + IdempotencyKey string + Input any + LeaseConstraints *messages.LeaseConstraints + LeaseRequest arcp.Lease + MaxRuntimeSec int + TraceID string + type SubscribeOptions struct + FromEventSeq uint64 + History bool + type Subscription struct + func (s *Subscription) Close(ctx context.Context) error + func (s *Subscription) Done() <-chan struct{} + func (s *Subscription) Err() error + func (s *Subscription) Events() <-chan messages.JobEvent + func (s *Subscription) JobID() string
Go to main page