transport

Documentation

Index

• Constants
• type DialQueue
• type WebSocketServer
  • func NewSocketServer() *WebSocketServer
  • func (wss *WebSocketServer) Run(llm *ollama.LLM, vdb *mxvd.MXVDProxy)

Constants

const (
	ErrRpcConn              string = "gRpcConnectionLost:"
	ErrWebsocketUpgrade     string = "WebSocketUpgradeError:"
	ErrUnexpectedClose      string = "UnexpectedCloseError:"
	ErrUndefinedReadMessage string = "UndefinedReadMessageError:"
	ErrWriteMessage         string = "Write Message Error:"
	ErrUnexpectedType       string = "UnexpectedTypeError:"
	ErrJsonUnmarshal        string = "JsonUnmarshalError"
	ErrCreateRpcStream      string = "Failed to Create Rpc Stream"
	STATUS_ERROR            string = "status_error"
	STATUS_OK               string = "status_ok"
	InvalidVersion          string = "invalid version, closing websocket"
)

Types

type DialQueue

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

type WebSocketServer

type WebSocketServer struct {
	Upgrader websocket.Upgrader
	// contains filtered or unexported fields
}

func NewSocketServer

func NewSocketServer() *WebSocketServer

func (*WebSocketServer) Run

func (wss *WebSocketServer) Run(llm *ollama.LLM, vdb *mxvd.MXVDProxy)