Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

client

package

Go to main page

Versions in this module

v0

v0.7.1

Dec 26, 2025

v0.7.0

Nov 28, 2025

Changes in this version

+ func ConnectAliyunWebSocket(wsURL, apiKey string) (*websocket.Conn, error)

+ type AliyunWebSocketMessage struct

+ Header AliyunWebSocketMessageHeader

+ Payload AliyunWebSocketMessagePayload

+ type AliyunWebSocketMessageHeader struct

+ Action string

+ Attributes map[string]interface{}

+ ErrorCode string

+ ErrorMessage string

+ Event string

+ Streaming string

+ TaskID string

+ type AliyunWebSocketMessagePayload struct

+ Function string

+ Input map[string]interface{}

+ Model string

+ Output interface{}

+ Parameters map[string]interface{}

+ Task string

+ TaskGroup string

type TaskInfo

+ StartEventSent bool

type WebSocketConnection

+ InputStream chan sdkclient.BidiMessage

+ OutputStream chan sdkclient.BidiMessage

+ func (c *WebSocketConnection) HasTaskStartedEventSent(taskID uint64) bool

+ func (c *WebSocketConnection) MarkTaskStartedEventSent(taskID uint64)

+ func (c *WebSocketConnection) SendFinishTaskMessage(conn *websocket.Conn, taskID string) error

+ func (c *WebSocketConnection) SendRunTaskMessage(conn *websocket.Conn, taskID, model string) error

v0.6.0

Sep 12, 2025

v0.5.1

Aug 21, 2025

v0.5.0

Aug 18, 2025

Changes in this version

+ var ModelClientMap = make(map[string][]context.CancelFunc)

+ type Client struct

+ func NewClient(base *url.URL, http *http.Client) *Client

+ func (c *Client) Do(ctx context.Context, method, path string, reqData, respData any) error

+ func (c *Client) Stream(ctx context.Context, method, path string, data any, fn func([]byte) error) error

+ func (c *Client) StreamResponse(ctx context.Context, method, path string, reqData any, ...) (chan []byte, chan error)

+ type GRPCClient struct

+ func NewGRPCClient(target string) (*GRPCClient, error)

+ func (c *GRPCClient) Close() error

+ func (c *GRPCClient) ModelMetadata(modelName string, modelVersion string) (*grpc_client.ModelMetadataResponse, error)

+ func (c *GRPCClient) ServerLive() (*grpc_client.ServerLiveResponse, error)

+ func (c *GRPCClient) ServerReady() (*grpc_client.ServerReadyResponse, error)

+ type GRPCStreamManager struct

+ func GetGlobalGRPCStreamManager() *GRPCStreamManager

+ func (m *GRPCStreamManager) CloseAllSessions()

+ func (m *GRPCStreamManager) CloseSessionByWSConnID(wsConnID string)

+ func (m *GRPCStreamManager) CreateSession(wsConnID string, client grpc_client.GRPCInferenceServiceClient, ...) *GRPCStreamSession

+ func (m *GRPCStreamManager) GetActiveSessionCount() int

+ func (m *GRPCStreamManager) GetSessionByWSConnID(wsConnID string) *GRPCStreamSession

+ type GRPCStreamSession struct

+ Active bool

+ CancelFunc context.CancelFunc

+ Client grpc_client.GRPCInferenceServiceClient

+ Context context.Context

+ CreatedAt int64

+ Done chan struct{}

+ Model string

+ ResponseChannel chan interface{}

+ Service string

+ Stream grpc_client.GRPCInferenceService_ModelStreamInferClient

+ WSConnID string

+ type TaskInfo struct

+ EndTime int64

+ StartTime int64

+ TaskStarted bool

+ TaskType string

+ type WebSocketConnection struct

+ ActiveTasks map[uint64]bool

+ Conn *websocket.Conn

+ CreatedAt time.Time

+ Flavor string

+ ID string

+ LastTaskID uint64

+ Service string

+ SessionData *WebSocketSessionData

+ TaskID uint64

+ func NewWebSocketConnection(conn *websocket.Conn, taskID uint64, flavor, service string) *WebSocketConnection

+ func (c *WebSocketConnection) AddActiveTask(taskID uint64)

+ func (c *WebSocketConnection) ClearActiveTasks()

+ func (c *WebSocketConnection) Close()

+ func (c *WebSocketConnection) GetActiveTaskCount() int

+ func (c *WebSocketConnection) GetSTTParams() *types.SpeechToTextParams

+ func (c *WebSocketConnection) GetTaskTimes(taskID uint64) (startTime, endTime int64)

+ func (c *WebSocketConnection) GetTaskType(taskID uint64) string

+ func (c *WebSocketConnection) HasActiveTasks() bool

+ func (c *WebSocketConnection) IsTaskStarted(taskID uint64) bool

+ func (c *WebSocketConnection) RemoveActiveTask(taskID uint64)

+ func (c *WebSocketConnection) SetConnectionTaskFinished()

+ func (c *WebSocketConnection) SetConnectionTaskStatus(started bool, timestamp int64)

+ func (c *WebSocketConnection) SetTaskFinished(taskID uint64)

+ func (c *WebSocketConnection) SetTaskStatus(taskID uint64, started bool, timestamp int64)

+ func (c *WebSocketConnection) SetTaskType(taskID uint64, taskType string)

+ func (c *WebSocketConnection) WriteJSON(v interface{}) error

+ func (c *WebSocketConnection) WriteMessage(messageType int, data []byte) error

+ type WebSocketManager struct

+ func GetGlobalWebSocketManager() *WebSocketManager

+ func (m *WebSocketManager) CloseAllConnections()

+ func (m *WebSocketManager) GetActiveConnectionCount() int

+ func (m *WebSocketManager) GetAllConnections() []*WebSocketConnection

+ func (m *WebSocketManager) GetConnection(connID string) (*WebSocketConnection, bool)

+ func (m *WebSocketManager) RegisterConnection(conn *websocket.Conn, taskID uint64, flavor, service string) *WebSocketConnection

+ func (m *WebSocketManager) UnregisterConnection(connID string)

+ type WebSocketSessionData struct

+ STTParams *types.SpeechToTextParams

+ Tasks map[uint64]*TaskInfo