Versions in this module Expand all Collapse all v0 v0.1.0 Oct 8, 2026 Changes in this version + const ClientCapabilitiesMeta + const Extension + const MaxJSONBytes + const MaximumSubscriptionTasks + const MethodAcknowledged + const MethodCallTool + const MethodCancel + const MethodGet + const MethodListen + const MethodNotification + const MethodUpdate + const MissingCapabilityCode + const ProtocolVersion + const ResultComplete + const ResultTask + const SubscriptionIDMeta + var ErrConflict = errors.New("task revision conflict") + var ErrDurability = errors.New("task creation was not durably visible") + var ErrKeyReuse = errors.New("task input key cannot be reused") + var ErrNotFound = errors.New("task unavailable") + var ErrTerminal = errors.New("task is terminal") + func Advertise(caps *schema.ClientCapabilities) + func AdvertiseServer(caps *schema.ServerCapabilities) + func RequestCapabilities(params json.RawMessage) (schema.ClientCapabilities, error) + func ServerSupports(caps schema.ServerCapabilities) bool + func Supports(caps schema.ClientCapabilities) bool + func SupportsInput(caps schema.ClientCapabilities, method string) bool + func ValidID(id string) bool + func ValidObject(raw json.RawMessage) bool + func ValidateResponses(responses InputResponses) error + type Acknowledgement struct + Meta map[string]json.RawMessage + ResultType string + type Backend interface + Cancel func(context.Context, Owner, string) (Acknowledgement, error) + Create func(context.Context, Owner, schema.ClientCapabilities, CreateOptions) (CreateTaskResult, error) + Get func(context.Context, Owner, string) (GetTaskResult, error) + Update func(context.Context, Owner, string, InputResponses) (Acknowledgement, error) + type CancelParams = GetParams + type ChangeSource interface + WatchTasks func(context.Context, Owner, []string) (Wakeup, error) + type CreateOptions struct + Method string + Origin json.RawMessage + StatusMessage string + TTLMS *int64 + Unlimited bool + type CreateTaskResult struct + Meta map[string]json.RawMessage + ResultType string + func DecodeCreate(raw json.RawMessage) (CreateTaskResult, error) + func (r CreateTaskResult) MarshalJSON() ([]byte, error) + type DetailedTask struct + Error *RPCError + InputRequests InputRequests + Result json.RawMessage + func (t DetailedTask) Validate() error + type GetParams struct + Meta map[string]json.RawMessage + TaskID string + type GetTaskResult struct + Meta map[string]json.RawMessage + ResultType string + func DecodeGet(raw json.RawMessage) (GetTaskResult, error) + type InputRequest struct + Method string + Params json.RawMessage + func (r InputRequest) Validate() error + type InputRequests map[string]InputRequest + type InputResponses map[string]json.RawMessage + type ListenParams struct + Meta map[string]json.RawMessage + Notifications SubscriptionFilter + type Owner struct + Subject string + Tenant string + func (o Owner) Valid() bool + type RPCError struct + Code int + Data json.RawMessage + Message string + func MissingCapability() *RPCError + func (e *RPCError) Error() string + type Record struct + CancelRequested bool + ClientCapabilities schema.ClientCapabilities + Issued InputRequests + Origin json.RawMessage + OriginMethod string + Owner Owner + Responses InputResponses + Revision uint64 + State DetailedTask + type Status string + const Cancelled + const Completed + const Failed + const InputRequired + const Working + func (s Status) Terminal() bool + func (s Status) Valid() bool + type Store interface + CompareAndSwap func(context.Context, Owner, string, uint64, Record) error + Create func(context.Context, Record) error + Get func(context.Context, Owner, string) (Record, error) + type SubscriptionAcknowledged struct + JSONRPC string + Method string + Params SubscriptionAcknowledgedParams + type SubscriptionAcknowledgedParams struct + Meta map[string]json.RawMessage + Notifications SubscriptionFilter + type SubscriptionFilter struct + PromptsListChanged bool + ResourceSubscriptions []string + ResourcesListChanged bool + TaskIDs []string + ToolsListChanged bool + func (f SubscriptionFilter) Mixed() bool + func (f SubscriptionFilter) Validate() error + type SubscriptionResult struct + Meta map[string]json.RawMessage + ResultType string + type Task struct + CreatedAt time.Time + LastUpdatedAt time.Time + PollIntervalMS *int64 + Status Status + StatusMessage string + TTLMS *int64 + TaskID string + func (t Task) Expired(now time.Time) bool + func (t Task) Validate() error + type TaskNotificationParams struct + Meta map[string]json.RawMessage + func DecodeNotificationParams(raw json.RawMessage) (TaskNotificationParams, error) + type TaskStatusNotification struct + JSONRPC string + Method string + Params TaskNotificationParams + type UpdateParams struct + InputResponses InputResponses + Meta map[string]json.RawMessage + TaskID string + type Wakeup interface + C func() <-chan struct{} + Close func() error
Go to main page