gosignalr

package module
v0.0.0-...-389291c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 17, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClientConnection

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

func (*ClientConnection) ClientId

func (clientConnection *ClientConnection) ClientId() string

func (*ClientConnection) Send

func (clientConnection *ClientConnection) Send(target string, arguments ...interface{})

type Context

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

func (*Context) Client

func (context *Context) Client() *HubConnection

func (*Context) Clients

func (context *Context) Clients()

func (*Context) NewStreamWriter

func (context *Context) NewStreamWriter() *StreamWriter

func (*Context) Send

func (context *Context) Send(target string, arguments ...interface{})

func (*Context) ThrowIfCancellationRequested

func (context *Context) ThrowIfCancellationRequested()

type Hub

type Hub struct {
}

func (*Hub) Initialize

func (h *Hub) Initialize()

func (*Hub) OnConnect

func (h *Hub) OnConnect(connectionID string)

func (*Hub) OnDisconnect

func (h *Hub) OnDisconnect(connectionID string)

type HubConnection

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

func (*HubConnection) ClientID

func (client *HubConnection) ClientID() string

func (*HubConnection) Send

func (client *HubConnection) Send(target string, arguments ...interface{})

type HubProtocol

type HubProtocol interface {
	Serialize(data interface{}) ([]byte, error)
	Deserialize(data []byte, v interface{}) error
}

type IHub

type IHub interface {
	Initialize()
	OnConnect(connectionID string)
	OnDisconnect(connectionID string)
}

type IHubInstanceReader

type IHubInstanceReader interface {
	// contains filtered or unexported methods
}

type IMux

type IMux interface {
	//HandleFunc(pattern string, handler func(http.ResponseWriter, *http.Request))
	//Handle(pattern string, handler http.Handler)
	Get(pattern string, h http.HandlerFunc)
	Post(pattern string, h http.HandlerFunc)
}

type Invocatory

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

type JsonHubProtocol

type JsonHubProtocol struct {
}

func NewJsonHubProtocol

func NewJsonHubProtocol() *JsonHubProtocol

func (*JsonHubProtocol) Deserialize

func (hubProtocol *JsonHubProtocol) Deserialize(data []byte, v interface{}) error

func (*JsonHubProtocol) Serialize

func (hubProtocol *JsonHubProtocol) Serialize(data interface{}) ([]byte, error)

type Server

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

func NewServer

func NewServer() *Server

func (*Server) HandleHub

func (s *Server) HandleHub(path string, hub IHub) error

func (*Server) MapHttp

func (s *Server) MapHttp(serveMux IMux)

type StreamWriter

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

func (*StreamWriter) Write

func (streamWriter *StreamWriter) Write(data interface{})

type WebsocketTransport

type WebsocketTransport struct {
}

func NewWebsocketTransport

func NewWebsocketTransport() *WebsocketTransport

func (*WebsocketTransport) Upgrade

type WebsocketTransportConnection

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

func (*WebsocketTransportConnection) Close

func (wstConn *WebsocketTransportConnection) Close() error

func (*WebsocketTransportConnection) ReadMessage

func (wstConn *WebsocketTransportConnection) ReadMessage() ([]byte, error)

func (*WebsocketTransportConnection) WriteMessage

func (wstConn *WebsocketTransportConnection) WriteMessage(message []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL