Versions in this module Expand all Collapse all v0 v0.0.2 Dec 19, 2025 v0.0.1 Dec 17, 2025 Changes in this version + type Conn interface + Close func() error + GetState func() connectivity.State + type GrpcClient interface + Invoke func(ctx context.Context, method string, args any, reply any, ...) error + NewStream func(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error) + type GrpcClientWrapper struct + func NewGrpcClientWrapper(conn Conn, config *configv1.UpstreamServiceConfig) *GrpcClientWrapper + func (w *GrpcClientWrapper) Close() error + func (w *GrpcClientWrapper) IsHealthy(ctx context.Context) bool + type HTTPClient interface + Do func(req *http.Request) (*http.Response, error) + type HTTPClientWrapper struct + func NewHTTPClientWrapper(client *http.Client, config *configv1.UpstreamServiceConfig) *HTTPClientWrapper + func (w *HTTPClientWrapper) Close() error + func (w *HTTPClientWrapper) IsHealthy(ctx context.Context) bool + type MCPClient interface + CallTool func(ctx context.Context, params *mcp.CallToolParams) (*mcp.CallToolResult, error) + type WebsocketClientWrapper struct + Conn *websocket.Conn + func (w *WebsocketClientWrapper) Close() error + func (w *WebsocketClientWrapper) IsHealthy(_ context.Context) bool
Go to main page