mcps

package
v0.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 13, 2026 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ServerTable = "mcp_server"
	ServerAlias = "ms"
	ServerLabel = "server"
	ServerTypID = "mcpsServer"
)

consts of Server 服务器

Variables

This section is empty.

Functions

func BoolArg 

func BoolArg(arguments map[string]any, key string) (bool, bool, error)

BoolArg 从参数中获取布尔值

func BuildToolErrorResult 

func BuildToolErrorResult(message string) map[string]any

BuildToolErrorResult 构建标准的 MCP 工具错误结果

func BuildToolSuccessResult 

func BuildToolSuccessResult(structured any) map[string]any

BuildToolSuccessResult 构建标准的 MCP 工具成功结果

func IntArg 

func IntArg(arguments map[string]any, key string) (int, bool, error)

IntArg 从参数中获取整数值

func StringArg 

func StringArg(arguments map[string]any, key string) string

StringArg 从参数中获取字符串值

Types

type Invoker 

type Invoker func(ctx context.Context, params map[string]any) (map[string]any, error)

type Server 

type Server struct {
	comm.BaseModel `bun:"table:mcp_server,alias:ms" json:"-"`

	comm.DefaultModel

	ServerBasic

	comm.MetaField

} // @name mcpsServer

Server 服务器

func NewServerWithBasic 

func NewServerWithBasic(in ServerBasic) *Server

func NewServerWithID 

func NewServerWithID(id any) *Server

func (*Server) Creating 

func (z *Server) Creating() error

Creating function call to it's inner fields defined hooks

func (*Server) IdentityAlias 

func (_ *Server) IdentityAlias() string

func (*Server) IdentityLabel 

func (_ *Server) IdentityLabel() string

func (*Server) IdentityModel 

func (_ *Server) IdentityModel() string

func (*Server) IdentityTable 

func (_ *Server) IdentityTable() string

func (*Server) SetWith 

func (z *Server) SetWith(o ServerSet)

type ServerBasic 

type ServerBasic struct {
	// 名称
	Name string `` /* 140-byte string literal not displayed */
	// 传输类型
	//  * `stdIO` - 标准IO
	//  * `sse`
	//  * `streamable`
	//  * `inMemory` - 内部运行
	TransType TransType `` /* 189-byte string literal not displayed */
	// 指令 仅对 TransType 为 StdIO 时有效
	Command string `bson:"command" bun:",notnull" extensions:"x-order=C" form:"command" json:"command" pg:",notnull"`
	// 完整网址 仅对 TransType 为 SSE 或 HTTP 时有效
	URL string `bson:"url" bun:",notnull" extensions:"x-order=D" form:"url" json:"url" pg:",notnull"`
	// 是否激活
	IsActive bool `bson:"isActive" bun:",notnull" extensions:"x-order=E" form:"isActive" json:"isActive" pg:",notnull"`
	// 连接状态
	//  * `disconnected` - 断开
	//  * `connecting` - 连接中
	//  * `connected` - 已连接
	Status Status `` /* 184-byte string literal not displayed */
	// 备注
	Remark string `bson:"remark" bun:",notnull" extensions:"x-order=G" form:"remark" json:"remark" pg:",notnull"`
	// for meta update
	MetaDiff *comm.MetaDiff `bson:"-" bun:"-" json:"metaUp,omitempty" pg:"-" swaggerignore:"true"`

} // @name mcpsServerBasic

func (*ServerBasic) MetaAddKVs 

func (in *ServerBasic) MetaAddKVs(args ...any) *ServerBasic

type ServerSet 

type ServerSet struct {
	// 名称
	Name *string `extensions:"x-order=A" json:"name"`
	// 传输类型
	//  * `stdIO` - 标准IO
	//  * `sse`
	//  * `streamable`
	//  * `inMemory` - 内部运行
	TransType *TransType `enums:"stdIO,sse,streamable,inMemory" extensions:"x-order=B" json:"transType" swaggertype:"string"`
	// 指令 仅对 TransType 为 StdIO 时有效
	Command *string `extensions:"x-order=C" json:"command"`
	// 完整网址 仅对 TransType 为 SSE 或 HTTP 时有效
	URL *string `extensions:"x-order=D" json:"url"`
	// 是否激活
	IsActive *bool `extensions:"x-order=E" json:"isActive"`
	// 连接状态
	//  * `disconnected` - 断开
	//  * `connecting` - 连接中
	//  * `connected` - 已连接
	Status *Status `enums:"disconnected,connecting,connected" extensions:"x-order=F" json:"status" swaggertype:"string"`
	// 备注
	Remark *string `extensions:"x-order=G" json:"remark"`
	// for meta update
	MetaDiff *comm.MetaDiff `json:"metaUp,omitempty" swaggerignore:"true"`

} // @name mcpsServerSet

func (*ServerSet) MetaAddKVs 

func (in *ServerSet) MetaAddKVs(args ...any) *ServerSet

type Servers 

type Servers []Server

type Status 

type Status int8

状态 用于表示连接 

const (
	StatusDisconnected Status = 0 + iota //  0 断开 初始默认
	StatusConnecting                     //  1 连接中
	StatusConnected                      //  2 已连接
)

func (*Status) Decode 

func (z *Status) Decode(s string) error

func (Status) MarshalText 

func (z Status) MarshalText() ([]byte, error)

func (Status) String 

func (z Status) String() string

func (*Status) UnmarshalText 

func (z *Status) UnmarshalText(b []byte) error

type ToolCallPayload 

type ToolCallPayload struct {
	Name      string         `json:"name"`
	Arguments map[string]any `json:"arguments"`
}

ToolCallPayload 是 MCP tools/call 的参数

type ToolDescriptor 

type ToolDescriptor struct {
	Name        string         `json:"name"`
	Description string         `json:"description,omitempty"`
	InputSchema map[string]any `json:"inputSchema"`
}

ToolDescriptor 是工具的描述符，用于 MCP 工具列表

type ToolNames 

type ToolNames []ToolDescriptor

ToolNames 是 []ToolDescriptor 的自定义类型，用于日志输出

func (ToolNames) String 

func (z ToolNames) String() string

String 返回工具名称列表，用于日志记录

type TransType 

type TransType int8

MCP 传输类型 

const (
	TransTypeStdIO      TransType = 1 + iota //  1 标准IO
	TransTypeSSE                             //  2 SSE
	TransTypeStreamable                      //  3 Streamable
	TransTypeInMemory                        //  4 内部运行
)

func (*TransType) Decode 

func (z *TransType) Decode(s string) error

func (TransType) IsRemote 

func (t TransType) IsRemote() bool

IsRemote 判断是否为远程传输类型（SSE 或 Streamable）

func (TransType) MarshalText 

func (z TransType) MarshalText() ([]byte, error)

func (TransType) String 

func (z TransType) String() string

func (*TransType) UnmarshalText 

func (z *TransType) UnmarshalText(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.