unexport

Author: jba

mcp/client.go

@@ -129,8 +129,8 @@ func (c *Client) Connect(ctx context.Context, t Transport) (cs *ClientSession, e
 		return nil, unsupportedProtocolVersionError{res.ProtocolVersion}
 	}
 	cs.initializeResult = res
-	if hc, ok := cs.mcpConn.(HTTPConnection); ok {
-		hc.SetProtocolVersion(res.ProtocolVersion)
+	if hc, ok := cs.mcpConn.(httpConnection); ok {
+		hc.setProtocolVersion(res.ProtocolVersion)
 	}
 	if err := handleNotify(ctx, cs, notificationInitialized, &InitializedParams{}); err != nil {
 		_ = cs.Close()

mcp/streamable.go

@@ -648,7 +648,7 @@ type streamableClientConn struct {
 	err error
 }
 
-func (c *streamableClientConn) SetProtocolVersion(s string) {
+func (c *streamableClientConn) setProtocolVersion(s string) {
 	c.mu.Lock()
 	defer c.mu.Unlock()
 	c.protocolVersion = s

mcp/transport.go

@@ -53,10 +53,10 @@ type Connection interface {
 	SessionID() string
 }
 
-// An HTTPConnection is a [Connection] that runs over HTTP.
-type HTTPConnection interface {
+// An httpConnection is a [Connection] that runs over HTTP.
+type httpConnection interface {
 	Connection
-	SetProtocolVersion(string)
+	setProtocolVersion(string)
 }
 
 // A StdioTransport is a [Transport] that communicates over stdin/stdout using