signalr

Sep 12, 2023

Changes in this version

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

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

type Connection

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

+ type TransferFormatType string

+ var TransferFormatBinary TransferFormatType = "Binary"

+ var TransferFormatText TransferFormatType = "Text"

+ type TransportType string

+ var TransportServerSentEvents TransportType = "ServerSentEvents"

+ var TransportWebSockets TransportType = "WebSockets"

Mar 24, 2023

Changes in this version

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

Aug 22, 2022

Changes in this version

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

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

Nov 13, 2021

Changes in this version

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

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

+ func WithConnection(connection Connection) func(party 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 WithReceiver(receiver interface{}) func(Party) error

type Client

+ Err func() error

+ ObserveStateChanged func(chan struct{}) context.CancelFunc

+ State func() ClientState

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

+ type ClientState int

+ const ClientClosed

+ const ClientConnected

+ const ClientConnecting

+ const ClientCreated

type ConnectionBase

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

+ type RWJobResult struct

type Receiver

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

+ func (ch *Receiver) Server() Client

+ type ReceiverInterface interface

+ Init func(Client)

+ Server func() Client

Oct 17, 2021

Changes in this version

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

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

type Client

+ Context func() context.Context

Sep 18, 2021

Changes in this version

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

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

type Connection

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

+ type Doer interface

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

Sep 4, 2021

Changes in this version

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

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

+ 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)

Aug 30, 2021

Changes in this version

type Hub

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

type HubContext

+ Context func() context.Context

Aug 22, 2021

Changes in this version

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

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

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

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

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

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

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

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

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

+ func Receiver(receiver interface{}) func(Party) 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 string) func(Party) error

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

+ type Client interface

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

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

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

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

+ Start func() error

+ Stop func() error

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

+ func NewHTTPClient(ctx context.Context, address string, options ...func(Party) error) (Client, error)

+ type ClientProxy interface

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

+ type Connection interface

+ ConnectionID func() string

+ Context func() context.Context

+ SetConnectionID func(id string)

+ SetTimeout func(duration time.Duration)

+ Timeout func() time.Duration

+ type ConnectionBase struct

+ func (cb *ConnectionBase) ConnectionID() string

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

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

+ func (cb *ConnectionBase) SetTimeout(duration time.Duration)

+ func (cb *ConnectionBase) Timeout() time.Duration

+ type ConnectionWithTransferMode interface

+ SetTransferMode func(transferMode TransferMode)

+ TransferMode func() TransferMode

+ 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) 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

+ 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 Server interface

+ HubClients func() HubClients

+ MapHTTP func(mux MappableRouter, path string)

+ Serve func(conn Connection)

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

+ type StructuredLogger interface

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

+ type TransferMode int

+ const BinaryTransferMode

+ const TextTransferMode