server

Documentation

Overview

Package server adapts a compiled Datly MCP service to the upstream protocol handler. Transport startup and authorization remain separate concerns.

Index

• func NewHandler(service Service) (protocolserver.NewHandler, error)
• func Release(ctx context.Context)
• func WithRelease(ctx context.Context, release func()) context.Context
• type Config
• type Handler
  • func (h *Handler) CallTool(ctx context.Context, request *jsonrpc.TypedRequest[*schema.CallToolRequest]) (*schema.CallToolResult, *jsonrpc.Error)
  • func (h *Handler) Complete(ctx context.Context, request *jsonrpc.TypedRequest[*schema.CompleteRequest]) (*schema.CompleteResult, *jsonrpc.Error)
  • func (h *Handler) Discover(ctx context.Context, result *schema.DiscoverResult)
  • func (h *Handler) GetPrompt(ctx context.Context, request *jsonrpc.TypedRequest[*schema.GetPromptRequest]) (*schema.GetPromptResult, *jsonrpc.Error)
  • func (h *Handler) GetSkill(ctx context.Context, request *jsonrpc.TypedRequest[*schema.GetSkillRequest]) (*schema.GetSkillResult, *jsonrpc.Error)
  • func (h *Handler) ImplementsContext(ctx context.Context, method string) bool
  • func (h *Handler) Initialize(ctx context.Context, input *schema.InitializeRequestParams, ...)
  • func (h *Handler) ListPrompts(ctx context.Context, request *jsonrpc.TypedRequest[*schema.ListPromptsRequest]) (*schema.ListPromptsResult, *jsonrpc.Error)
  • func (h *Handler) ListResourceTemplates(ctx context.Context, ...) (*schema.ListResourceTemplatesResult, *jsonrpc.Error)
  • func (h *Handler) ListResources(ctx context.Context, ...) (*schema.ListResourcesResult, *jsonrpc.Error)
  • func (h *Handler) ListSkills(ctx context.Context, request *jsonrpc.TypedRequest[*schema.ListSkillsRequest]) (*schema.ListSkillsResult, *jsonrpc.Error)
  • func (h *Handler) ListTools(ctx context.Context, request *jsonrpc.TypedRequest[*schema.ListToolsRequest]) (*schema.ListToolsResult, *jsonrpc.Error)
  • func (h *Handler) OnNotification(ctx context.Context, notification *jsonrpc.Notification)
  • func (h *Handler) ReadResource(ctx context.Context, ...) (*schema.ReadResourceResult, *jsonrpc.Error)
  • func (h *Handler) Subscribe(ctx context.Context, request *jsonrpc.TypedRequest[*schema.SubscribeRequest]) (*schema.SubscribeResult, *jsonrpc.Error)
  • func (h *Handler) Unsubscribe(ctx context.Context, request *jsonrpc.TypedRequest[*schema.UnsubscribeRequest]) (*schema.UnsubscribeResult, *jsonrpc.Error)
• type Server
  • func New(config Config) (*Server, error)
  • func (s *Server) HTTP() (*http.Server, error)
  • func (s *Server) Serve(ctx context.Context) error
  • func (s *Server) Shutdown(ctx context.Context) error
  • func (s *Server) Stdio(ctx context.Context) (*stdio.Server, error)
• type ServerService
• type Service
• type Source
• type TransportConfig
• type TransportKind

Functions

func NewHandler

func NewHandler(service Service) (protocolserver.NewHandler, error)

NewHandler creates one upstream handler factory over a compiled Datly service.

func Release

func Release(ctx context.Context)

Release releases a generation pinned by Source.Pin when a caller uses the source directly instead of the protocol handler.

func WithRelease

func WithRelease(ctx context.Context, release func()) context.Context

WithRelease attaches application-generation ownership to one protocol call.

Types

type Config

type Config struct {
	ResourceAuthorizer auth.ResourceAuthorizer
	Service            ServerService
	Source             Source

	Implementation  schema.Implementation
	ProtocolVersion string
	LoggerName      string
	Transport       TransportConfig
	// contains filtered or unexported fields
}

type Handler

type Handler struct {
	*protocolserver.DefaultHandler
	// contains filtered or unexported fields
}

func (*Handler) CallTool

func (h *Handler) CallTool(ctx context.Context, request *jsonrpc.TypedRequest[*schema.CallToolRequest]) (*schema.CallToolResult, *jsonrpc.Error)

func (*Handler) Complete

func (h *Handler) Complete(ctx context.Context, request *jsonrpc.TypedRequest[*schema.CompleteRequest]) (*schema.CompleteResult, *jsonrpc.Error)

func (*Handler) Discover

func (h *Handler) Discover(ctx context.Context, result *schema.DiscoverResult)

func (*Handler) GetPrompt

func (h *Handler) GetPrompt(ctx context.Context, request *jsonrpc.TypedRequest[*schema.GetPromptRequest]) (*schema.GetPromptResult, *jsonrpc.Error)

func (*Handler) GetSkill

func (h *Handler) GetSkill(ctx context.Context, request *jsonrpc.TypedRequest[*schema.GetSkillRequest]) (*schema.GetSkillResult, *jsonrpc.Error)

func (*Handler) ImplementsContext

func (h *Handler) ImplementsContext(ctx context.Context, method string) bool

ImplementsContext is consumed at the native JSON-RPC ingress after pinning.

func (*Handler) Initialize

func (h *Handler) Initialize(ctx context.Context, input *schema.InitializeRequestParams, result *schema.InitializeResult)

func (*Handler) ListPrompts

func (h *Handler) ListPrompts(ctx context.Context, request *jsonrpc.TypedRequest[*schema.ListPromptsRequest]) (*schema.ListPromptsResult, *jsonrpc.Error)

func (*Handler) ListResourceTemplates

func (h *Handler) ListResourceTemplates(ctx context.Context, request *jsonrpc.TypedRequest[*schema.ListResourceTemplatesRequest]) (*schema.ListResourceTemplatesResult, *jsonrpc.Error)

func (*Handler) ListResources

func (h *Handler) ListResources(ctx context.Context, request *jsonrpc.TypedRequest[*schema.ListResourcesRequest]) (*schema.ListResourcesResult, *jsonrpc.Error)

func (*Handler) ListSkills

func (h *Handler) ListSkills(ctx context.Context, request *jsonrpc.TypedRequest[*schema.ListSkillsRequest]) (*schema.ListSkillsResult, *jsonrpc.Error)

func (*Handler) ListTools

func (h *Handler) ListTools(ctx context.Context, request *jsonrpc.TypedRequest[*schema.ListToolsRequest]) (*schema.ListToolsResult, *jsonrpc.Error)

func (*Handler) OnNotification

func (h *Handler) OnNotification(ctx context.Context, notification *jsonrpc.Notification)

func (*Handler) ReadResource

func (h *Handler) ReadResource(ctx context.Context, request *jsonrpc.TypedRequest[*schema.ReadResourceRequest]) (*schema.ReadResourceResult, *jsonrpc.Error)

func (*Handler) Subscribe

func (h *Handler) Subscribe(ctx context.Context, request *jsonrpc.TypedRequest[*schema.SubscribeRequest]) (*schema.SubscribeResult, *jsonrpc.Error)

func (*Handler) Unsubscribe

func (h *Handler) Unsubscribe(ctx context.Context, request *jsonrpc.TypedRequest[*schema.UnsubscribeRequest]) (*schema.UnsubscribeResult, *jsonrpc.Error)

type Server

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

func New

func New(config Config) (*Server, error)

func (*Server) HTTP

func (s *Server) HTTP() (*http.Server, error)

func (*Server) Serve

func (s *Server) Serve(ctx context.Context) error

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context) error

func (*Server) Stdio

func (s *Server) Stdio(ctx context.Context) (*stdio.Server, error)

type ServerService

type ServerService interface {
	Service
	Authorization() *authorization.Policy
}

type Service

type Service interface {
	Registry() *protocolserver.Registry
	ReadResource(context.Context, *schema.ReadResourceRequest) (*schema.ReadResourceResult, *jsonrpc.Error)
}

Service is the immutable MCP catalog and resource execution surface required by a protocol handler.

type Source

type Source interface {
	Pin(context.Context) (context.Context, ServerService, error)
}

Source pins one immutable service to an invocation context. Repeated calls with that context must return the same service, even after publication.

type TransportConfig

type TransportConfig struct {
	// Zero selects safe listener defaults; negative explicitly disables a deadline.
	ReadHeaderTimeout time.Duration
	IdleTimeout       time.Duration
	Kind              TransportKind
	Address           string
	SSEURI            string
	SSEMessageURI     string
	StreamableURI     string
	RootRedirect      bool
	CORS              *upstream.Cors
}

type TransportKind

type TransportKind string

const (
	TransportStdio      TransportKind = "stdio"
	TransportSSE        TransportKind = "sse"
	TransportStreamable TransportKind = "streamable"
)