Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

signalr

package module

Go to main page

Versions in this module

v0

v0.7.2

Feb 3, 2024

v0.7.1

Dec 23, 2023

Changes in this version

+ type HttpMux struct

+ ConnectionMap map[string]Connection

+ Mx sync.RWMutex

+ func (h *HttpMux) AddConnectionID(connectionID string)

+ func (h *HttpMux) HandleGet(writer http.ResponseWriter, request *http.Request)

+ func (h *HttpMux) HandlePost(writer http.ResponseWriter, request *http.Request)

+ func (h *HttpMux) HandleServerSentEvent(writer http.ResponseWriter, request *http.Request)

+ func (h *HttpMux) HandleWebsocket(writer http.ResponseWriter, request *http.Request)

+ func (h *HttpMux) Negotiate(w http.ResponseWriter, req *http.Request)

+ func (h *HttpMux) ServeHTTP(writer http.ResponseWriter, request *http.Request)

v0.7.0

Dec 20, 2023

Changes in this version

+ var ErrClosedPipe = errors.New("io: read/write on closed pipe")

+ var ErrUnableToConnect = errors.New("neither WithConnection nor WithConnector option was given")

+ func AllowOriginPatterns(origins []string) func(Party) error

+ func ChanReceiveTimeout(timeout time.Duration) func(Party) error

+ func CtxPipe(ctx context.Context) (*PipeReader, *PipeWriter)

+ func EnableDetailedErrors(enable bool) func(Party) error

+ func HTTPTransports(transports ...TransportType) func(Party) error

+ func HandshakeTimeout(timeout time.Duration) func(Party) error

+ func HubFactory(factory func() HubInterface) func(Party) error

+ func InsecureSkipVerify(skip bool) func(Party) error

+ func KeepAliveInterval(interval time.Duration) func(Party) error

+ func Logger(logger StructuredLogger, debug bool) func(Party) error

+ func MaximumReceiveMessageSize(sizeInBytes uint) func(Party) error

+ func NewHTTPMux(server Server) *httpMux

+ func ReadWriteWithContext(ctx context.Context, doRW func() (int, error), unblockRW func()) (int, error)

+ func SimpleHubFactory(hubProto HubInterface) func(Party) error

+ func StreamBufferCapacity(capacity uint) func(Party) error

+ func TimeoutInterval(timeout time.Duration) func(Party) error

+ func TransferFormat(format TransferFormatType) func(Party) error

+ func UseHub(hub HubInterface) func(Party) error

+ func WithBackoff(backoffFactory func() backoff.BackOff) func(party Party) error

+ func WithConnection(connection Connection) func(party Party) error

+ func WithConnector(connectionFactory func() (Connection, error)) func(Party) error

+ func WithHTTPClient(client Doer) func(*httpConnection) error

+ func WithHTTPHeaders(headers func() http.Header) func(*httpConnection) error

+ func WithHTTPServeMux(serveMux *http.ServeMux) func() MappableRouter

+ func WithHttpConnection(ctx context.Context, address string, options ...func(*httpConnection) error) func(Party) error

+ func WithReceiver(receiver interface{}) func(Party) error

+ func WithTransports(transports ...TransportType) func(*httpConnection) error

+ type Client interface

+ Err func() error

+ Invoke func(method string, arguments ...interface{}) <-chan InvokeResult

+ ObserveStateChanged func(chan ClientState) context.CancelFunc

+ PullStream func(method string, arguments ...interface{}) <-chan InvokeResult

+ PushStreams func(method string, arguments ...interface{}) <-chan InvokeResult

+ Send func(method string, arguments ...interface{}) <-chan error

+ Start func()

+ State func() ClientState

+ Stop func()

+ WaitForState func(ctx context.Context, waitFor ClientState) <-chan error

+ func NewClient(ctx context.Context, options ...func(Party) error) (Client, error)

+ type ClientProxy interface

+ Send func(target string, args ...interface{})

+ type ClientState int

+ const ClientClosed

+ const ClientConnected

+ const ClientConnecting

+ const ClientCreated

+ type Connection interface

+ ConnectionID func() string

+ Context func() context.Context

+ SetConnectionID func(id string)

+ func HttpConnectionFactory(ctx context.Context, address string, options ...func(*httpConnection) error) (Connection, error)

+ func NewHTTPConnection(ctx context.Context, address string, options ...func(*httpConnection) error) (Connection, error)

+ func NewNetConnection(ctx context.Context, conn net.Conn) Connection

+ type ConnectionBase struct

+ func NewConnectionBase(ctx context.Context, connectionID string) *ConnectionBase

+ func (cb *ConnectionBase) ConnectionID() string

+ func (cb *ConnectionBase) Context() context.Context

+ func (cb *ConnectionBase) SetConnectionID(id string)

+ type ConnectionWithTransferMode interface

+ SetTransferMode func(transferMode TransferMode)

+ TransferMode func() TransferMode

+ type Doer interface

+ Do func(req *http.Request) (*http.Response, error)

+ type GroupManager interface

+ AddToGroup func(groupName string, connectionID string)

+ RemoveFromGroup func(groupName string, connectionID string)

+ type Hub struct

+ func (h *Hub) Abort()

+ func (h *Hub) Clients() HubClients

+ func (h *Hub) ConnectionID() string

+ func (h *Hub) Context() context.Context

+ func (h *Hub) Groups() GroupManager

+ func (h *Hub) Initialize(ctx HubContext)

+ func (h *Hub) Items() *sync.Map

+ func (h *Hub) Logger() (info StructuredLogger, dbg StructuredLogger)

+ func (h *Hub) OnConnected(string)

+ func (h *Hub) OnDisconnected(string)

+ type HubClients interface

+ All func() ClientProxy

+ Caller func() ClientProxy

+ Client func(connectionID string) ClientProxy

+ Group func(groupName string) ClientProxy

+ type HubContext interface

+ Abort func()

+ Clients func() HubClients

+ ConnectionID func() string

+ Context func() context.Context

+ Groups func() GroupManager

+ Items func() *sync.Map

+ Logger func() (info StructuredLogger, dbg StructuredLogger)

+ type HubInterface interface

+ Initialize func(hubContext HubContext)

+ OnConnected func(connectionID string)

+ OnDisconnected func(connectionID string)

+ type HubLifetimeManager interface

+ AddToGroup func(groupName, connectionID string)

+ InvokeAll func(target string, args []interface{})

+ InvokeClient func(connectionID string, target string, args []interface{})

+ InvokeGroup func(groupName string, target string, args []interface{})

+ OnConnected func(conn hubConnection)

+ OnDisconnected func(conn hubConnection)

+ RemoveFromGroup func(groupName, connectionID string)

+ type InvokeResult struct

+ Error error

+ Value interface{}

+ type MappableRouter interface

+ Handle func(string, http.Handler)

+ HandleFunc func(string, func(w http.ResponseWriter, r *http.Request))

+ type Party interface

+ type PipeReader struct

+ func (r *PipeReader) Close() error

+ func (r *PipeReader) CloseWithError(err error) error

+ func (r *PipeReader) Read(data []byte) (n int, err error)

+ type PipeWriter struct

+ func (w *PipeWriter) Close() error

+ func (w *PipeWriter) CloseWithError(err error) error

+ func (w *PipeWriter) Write(data []byte) (n int, err error)

+ type RWJobResult struct

+ type Receiver struct

+ func (ch *Receiver) Init(client Client)

+ func (ch *Receiver) Server() Client

+ type ReceiverInterface interface

+ Init func(Client)

+ Server func() Client

+ type Server interface

+ HubClients func() HubClients

+ MapHTTP func(routerFactory func() MappableRouter, path string)

+ Serve func(conn Connection) error

+ func NewServer(ctx context.Context, options ...func(Party) error) (Server, error)

+ type StructuredLogger interface

+ Log func(keyVals ...interface{}) error

+ type TransferFormatType string

+ var TransferFormatBinary TransferFormatType = "Binary"

+ var TransferFormatText TransferFormatType = "Text"

+ type TransferMode int

+ const BinaryTransferMode

+ const TextTransferMode

+ type TransportType string

+ var TransportServerSentEvents TransportType = "ServerSentEvents"

+ var TransportWebSockets TransportType = "WebSockets"