realtime

package
v1.4.18 Latest Latest
Warning

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

 Go to latest Published: May 2, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MessageTypeSubscribe      = "subscribe"
	MessageTypeUnsubscribe    = "unsubscribe"
	MessageTypeChannelMessage = "message"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Channel 

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

Channel describes a room, websocket users can subscribe and sent messages to.

func (*Channel) FindContext 

func (c *Channel) FindContext(clientId string, path string) (*Context, bool)

func (*Channel) HandleMessage 

func (c *Channel) HandleMessage(client *Client, message *Message)

HandleMessage executes the channels OnMessage method if it exists.

func (*Channel) IsSubscribed 

func (c *Channel) IsSubscribed(clientId string, path string) bool

IsSubscribed returns true if the client is connected to the channel

func (*Channel) PathMatches 

func (c *Channel) PathMatches(path string) (bool, map[string]string)

PathMatches returns true and the params of the channel subscription if the path matches the path of the Channel.

func (*Channel) Subscribe 

func (c *Channel) Subscribe(context *Context)

Subscribe executes the Channels middlewares and(if successful) adds the user to the Channel and executes the channels OnSubscribe handler.

func (*Channel) Unsubscribe 

func (c *Channel) Unsubscribe(clientId string, path string) bool

Unsubscribe removes the client from the channel and executes the OnUnsubscribe handler

func (*Channel) UnsubscribeAllPaths 

func (c *Channel) UnsubscribeAllPaths(clientId string) bool

UnsubscribeAllPaths unsubscribes a client from all paths of the channel they are connected to.

type ChannelHandlers 

type ChannelHandlers struct {
	OnSubscribe             EventHandlerFunc
	OnUnsubscribe           EventHandlerFunc
	OnMessage               MessageHandlerFunc
	SubscriptionMiddlewares []SubscriptionMiddleware
}

ChannelHandlers contains all handler functions for various events in the Channel.

type ChannelStore 

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

ChannelStore stores pointers to all Channels

func (*ChannelStore) Get 

func (s *ChannelStore) Get(path string) (bool, *Channel, map[string]string)

func (*ChannelStore) OnMessage 

func (s *ChannelStore) OnMessage(client *Client, message *Message)

func (*ChannelStore) Register 

func (s *ChannelStore) Register(path string, handlers ChannelHandlers) *Channel

func (*ChannelStore) Subscribe 

func (s *ChannelStore) Subscribe(client *Client, channelPath string) bool

func (*ChannelStore) Unsubscribe 

func (s *ChannelStore) Unsubscribe(clientId string, channelPath string) bool

func (*ChannelStore) UnsubscribeAll 

func (s *ChannelStore) UnsubscribeAll(clientId string)

type ChannelSubscribers 

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

func (*ChannelSubscribers) Add 

func (subs *ChannelSubscribers) Add(context *Context)

func (*ChannelSubscribers) GetContext 

func (subs *ChannelSubscribers) GetContext(clientId string, path string) (*Context, bool)

func (*ChannelSubscribers) IsSubscribed 

func (subs *ChannelSubscribers) IsSubscribed(clientId string, path string) bool

func (*ChannelSubscribers) Remove 

func (subs *ChannelSubscribers) Remove(clientId string, path string)

func (*ChannelSubscribers) RemoveAllPaths 

func (subs *ChannelSubscribers) RemoveAllPaths(clientId string) []*Context

type Client 

type Client struct {
	Id string
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(sendMessage MessageSendFunc, properties map[string]interface{}) *Client

func (*Client) Get 

func (client *Client) Get(key string) (value interface{}, exists bool)

func (*Client) Send 

func (client *Client) Send(message []byte) error

func (*Client) Set 

func (client *Client) Set(key string, value interface{})

type ClientStore 

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

func (*ClientStore) Exists 

func (c *ClientStore) Exists(id string) bool

func (*ClientStore) Get 

func (c *ClientStore) Get(id string) *Client

func (*ClientStore) Join 

func (c *ClientStore) Join(client *Client)

func (*ClientStore) NextId 

func (c *ClientStore) NextId() string

func (*ClientStore) Remove 

func (c *ClientStore) Remove(id string)

type ConnectHookFunc 

type ConnectHookFunc func(*Client)

type Connector 

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

func NewConnector 

func NewConnector(requestHandler RequestHandlerFunc) *Connector

func (*Connector) Join 

func (c *Connector) Join(sendMessage MessageSendFunc, properties map[string]interface{}) *Client

Join To be triggered if a client connects via ws

func (*Connector) Leave 

func (c *Connector) Leave(clientId string)

func (*Connector) Message 

func (c *Connector) Message(clientId string, data []byte)

type Context 

type Context struct {
	Client   *Client
	FullPath string
	// contains filtered or unexported fields
}

func (*Context) Get 

func (context *Context) Get(key string) (value interface{}, exists bool)

func (*Context) Param 

func (context *Context) Param(key string) string

func (*Context) Send 

func (context *Context) Send(payload []byte) error

func (*Context) SendError 

func (context *Context) SendError(error *Error) error

func (*Context) Set 

func (context *Context) Set(key string, value interface{})

func (*Context) SetParams 

func (context *Context) SetParams(params map[string]string)

type DisconnectHookFunc 

type DisconnectHookFunc func(*Client)

type Error 

type Error struct {
	Code        int    `json:"code"`
	Description string `json:"description"`
}

func NewError 

func NewError(code int, description string) *Error

type EventHandlerFunc 

type EventHandlerFunc func(s *Context)

EventHandlerFunc is a function that is executed when subscribing or unsubscribing to the Channel.

type Hooks 

type Hooks struct {
	OnConnect    ConnectHookFunc
	OnDisconnect DisconnectHookFunc
	OnMessage    MessageHookFunc
}

type Message 

type Message struct {
	Type    string          `json:"type"`
	Channel string          `json:"channel"`
	Payload json.RawMessage `json:"payload"`
}

type MessageHandlerFunc 

type MessageHandlerFunc func(s *Context, message *Message)

MessageHandlerFunc is a function that executes when a message is sent to the Channel.

type MessageHookFunc 

type MessageHookFunc func(*Client, []byte)

type MessageSendFunc 

type MessageSendFunc func(message []byte) error

type Realtime 

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

func New 

func New(connector *Connector) *Realtime

New Creates a new Realtime instance

func (*Realtime) HandleRequest 

func (r *Realtime) HandleRequest(writer http.ResponseWriter, request *http.Request, properties map[string]interface{}) error

HandleRequest handles a new websocket request, adds the properties to the new client

func (*Realtime) IsConnected 

func (r *Realtime) IsConnected(clientId string) bool

func (*Realtime) IsSubscribed 

func (r *Realtime) IsSubscribed(channelPath string, clientId string) bool

IsSubscribed checks whether a client is subscribed to a certain channelPath or not

func (*Realtime) RegisterChannel 

func (r *Realtime) RegisterChannel(channelName string, handlers ChannelHandlers) *Channel

RegisterChannel registers a new channel

func (*Realtime) Send 

func (r *Realtime) Send(channelPath string, clientId string, payload []byte) error

type RequestHandlerFunc 

type RequestHandlerFunc func(writer http.ResponseWriter, request *http.Request, properties map[string]interface{}) error

type SubscriptionMiddleware 

type SubscriptionMiddleware func(s *Context) *Error

SubscriptionMiddleware is a function that is executed when a client connects to a Channel. If the middleware returns a non nil Error, the subscription won't be finished.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.