client

type Attempt struct {
	Fingerprint string          `json:"fingerprint"`
	Stage       string          `json:"stage"`
	Response    json.RawMessage `json:"response,omitempty"`
}

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

type Cursor struct {
	TaskID    string             `json:"taskId"`
	CreatedAt time.Time          `json:"createdAt"`
	Attempts  map[string]Attempt `json:"attempts"`
}

type InputHandler func(context.Context, string, tasks.InputRequest) (json.RawMessage, error)

type InputRequiredError struct{ Task tasks.GetTaskResult }

type Options struct {
	Capabilities schema.ClientCapabilities
	Info         schema.Implementation
	Tasks        bool
	Clock        func() time.Time
	Wait         func(context.Context, time.Duration) error
}

type SubscriptionOptions struct {
	MaxReconnects  int
	ReconnectDelay time.Duration
	OnAcknowledged func([]string) error
	OnTask         func(tasks.DetailedTask) error
}

type ToolOutcome struct {
	Result json.RawMessage
	Task   *tasks.CreateTaskResult
}

type UncertainError struct {
	Method, TaskID string
	Cause          error
}

type WaitOptions struct {
	Cursor     *Cursor
	Initial    *tasks.Task
	Input      InputHandler
	SaveCursor func(context.Context, Cursor) error
	OnState    func(tasks.GetTaskResult)
}