signalr

package module

Go to main page

Versions in this module

v1

v1.0.2

Dec 29, 2021

v1.0.1

Dec 27, 2021

Changes in this version

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

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

v1.0.0

Nov 20, 2021

Changes in this version

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

type Client

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

type ConnectionBase

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

+ type RWJobResult struct

v0

v0.4.9

Nov 20, 2021

Changes in this version

type HubInterface

+ Abort func()

v0.4.8

Nov 15, 2021

Changes in this version

type HubInterface

+ Groups func() GroupManager

v0.4.7

Nov 15, 2021

Changes in this version

type HubInterface

+ Clients func() HubClients

+ ConnectionID func() string

v0.4.6

Nov 8, 2021

v0.4.4

Nov 8, 2021

v0.4.3

Nov 8, 2021

Changes in this version

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

+ 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 ...string) 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(size uint) func(Party) error

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

+ 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

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

+ Err func() error

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

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

+ PushStateChanged func(chan<- struct{})

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

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

+ Start func()

+ State func() ClientState

+ 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

+ const ClientError

+ type Connection interface

+ ConnectionID func() string

+ Context func() context.Context

+ SetConnectionID func(id string)

+ SetTimeout func(duration time.Duration)

+ Timeout func() time.Duration

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

+ 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 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 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 TransferMode int

+ const BinaryTransferMode

+ const TextTransferMode

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