websocket_server

type Adapter interface {
	HandleMessage(Client) error
	PrepareNotification(eventName string, payload interface{}) ([]byte, error)
	PrepareResponse(*RPCResponse) ([]byte, error)
	Register(method string, fn RPCFunc) error
	Unregister(method string)
}

type Backend interface {
	ParseRequest(r io.Reader) (*RPCRequest, error)
	PrepareNotification(eventName string, payload interface{}) ([]byte, error)
	PrepareResponse(*RPCResponse) ([]byte, error)
}

type Client interface {
	GetOptions() *Options
	GetConnection() net.Conn
	GetClientID() uuid.UUID
	GetMeta() *Metadata
	GetReader() io.Reader
	Send(data []byte) error
	Respond(res *RPCResponse) error
	Notify(eventName string, payload interface{}) error
	Resume() error
	CreateRunner(func(*Runner)) *Runner
	Release()
	Close()
}

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

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

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

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

type Options struct {
	Adapter        Adapter
	MaxClients     int
	OnConnected    func(Client) error
	OnDisconnected func(Client) error
	OnMessage      func(Client) error
}

type Packet struct {
	Length  int
	Payload []byte
}

type Params struct {
	fx.In

	Lifecycle  fx.Lifecycle
	Logger     *zap.Logger
	HTTPServer *http_server.HTTPServer
}

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

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

type RPCAdapterOpt func(*RPCAdapter)

type RPCError struct {
	Code    RPCErrorCode `json:"code"`
	Message string       `json:"message"`
	Data    interface{}  `json:"data,omitempty"`
}

type RPCErrorCode int32

type RPCFunc func(*Context) (interface{}, error)

type RPCRequest struct {
	ID     int64
	Method string
	Params interface{}
}

type RPCResponse struct {
	ID     int64
	Error  error
	Result interface{}
}

type RequestHandler func(*Context) error

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

type RequestTask struct {
	Ctx *Context
}

type Runner struct {
	IsRunning bool
	// contains filtered or unexported fields
}

type RunnerFunc func(*Runner)

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