ws

package

Go to main page

Versions in this module

v0

v0.7.0

Jun 19, 2020

Changes in this version

+ type AuthPayload struct

+ Token string

type Client

+ Closed bool

+ LatestReceiveAt time.Time

+ Ready bool

+ func (c *Client) RegenerateUUID()

+ func (c *Client) SetReady(ready bool)

type Matcher

+ Max int

+ func (c *Matcher) GetPendingQueue() []string

+ func (c *Matcher) SetUserClientFunc(fn func(id string) *Client)

+ func (c *Matcher) SetWaiterClientFunc(fn func(id string) *Client)

type Message

+ Date string

+ Id string

+ OpID *string

+ type MessageImagePayload struct

+ Image string

+ type MessageTextPayload struct

+ Text string

type Pool

+ func (c *Pool) GetWaiterFromUserID(UserID string) (list []*Client)

+ type QueuePayload struct

+ Location uint

+ type RatePayload struct

+ Rate uint

type TypeRequestUser

+ const TypeRequestUserGetHistory

+ const TypeRequestUserMessageImage

+ const TypeRequestUserRate

+ func (c TypeRequestUser) String() string

type TypeRequestWaiter

+ const TypeRequestWaiterGetHistory

+ const TypeRequestWaiterGetHistorySession

+ const TypeRequestWaiterMessageImage

+ const TypeRequestWaiterRate

+ const TypeRequestWaiterUnReady

+ const TypeResponseWaiterAuthSuccess

+ func (c TypeRequestWaiter) String() string

type TypeResponseUser

+ const TypeResponseUserIdle

+ const TypeResponseUserMessageHistory

+ const TypeResponseUserMessageImage

+ const TypeResponseUserMessageImageSuccess

+ const TypeResponseUserMessageTextSuccess

+ const TypeResponseUserRate

+ const TypeResponseUserRateSuccess

+ func (c TypeResponseUser) String() string

type TypeResponseWaiter

+ const TypeResponseWaiterKickOut

+ const TypeResponseWaiterMessageHistory

+ const TypeResponseWaiterMessageImage

+ const TypeResponseWaiterMessageImageSuccess

+ const TypeResponseWaiterMessageTextSuccess

+ const TypeResponseWaiterRateSuccess

+ const TypeResponseWaiterRateUserSuccess

+ const TypeResponseWaiterSessionHistory

+ const TypeResponseWaiterUnready

+ func (c TypeResponseWaiter) String() string

v0.6.1

Jun 5, 2020

v0.6.0

Jun 4, 2020

Changes in this version

+ var MatcherPool = NewMatcher()

+ var UserPoll = NewPool()

+ var WaiterPoll = NewPool()

+ type Client struct

+ UUID string

+ func NewClient(conn *websocket.Conn) *Client

+ func (c *Client) Close() error

+ func (c *Client) GetProfile() *schema.ProfilePublic

+ func (c *Client) UpdateProfile(profile schema.ProfilePublic)

+ func (c *Client) WriteError(err error, data Message) error

+ func (c *Client) WriteJSON(data Message) error

+ type Matcher struct

+ Broadcast chan bool

+ func NewMatcher() *Matcher

+ func (c *Matcher) AddWaiter(waiterSocketUUID string)

+ func (c *Matcher) GetIdleWaiter() *string

+ func (c *Matcher) GetMatcher() map[string][]string

+ func (c *Matcher) GetMyUsers(waiterSocketUUID string) []string

+ func (c *Matcher) GetMyWaiter(userSocketUUID string) *string

+ func (c *Matcher) GetPendingLength() int

+ func (c *Matcher) Join(userSocketUUID string, prepend ...bool) *string

+ func (c *Matcher) Leave(userSocketUUID string)

+ func (c *Matcher) RemoveWaiter(waiterSocketUUID string)

+ func (c *Matcher) ShiftPending() *string

+ type Message struct

+ From string

+ Payload interface{}

+ To string

+ Type string

+ type Pool struct

+ Broadcast chan Message

+ func NewPool() *Pool

+ func (c *Pool) Add(client *Client)

+ func (c *Pool) Get(UUID string) *Client

+ func (c *Pool) Length() int

+ func (c *Pool) Remove(UUID string)

+ type TypeRequestUser typeForWriteMessage

+ const TypeRequestUserAuth

+ const TypeRequestUserConnect

+ const TypeRequestUserDisconnect

+ const TypeRequestUserMessageText

+ type TypeRequestWaiter typeForWriteMessage

+ const TypeRequestWaiterAuth

+ const TypeRequestWaiterDisconnect

+ const TypeRequestWaiterMessageText

+ const TypeRequestWaiterReady

+ type TypeResponseUser typeForWriteMessage

+ const TypeResponseUserAuthSuccess

+ const TypeResponseUserConnectQueue

+ const TypeResponseUserConnectSuccess

+ const TypeResponseUserDisconnected

+ const TypeResponseUserError

+ const TypeResponseUserMessageText

+ const TypeResponseUserNotConnect

+ type TypeResponseWaiter typeForWriteMessage

+ const TypeResponseWaiterDisconnected

+ const TypeResponseWaiterError

+ const TypeResponseWaiterMessageText

+ const TypeResponseWaiterNewConnection

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