clients

Documentation

Index

• func NewClients() *interfaces.WebsocketClient
• type Clients
  • func (cc *Clients) ChangeURL(ad interfaces.ClientURL, useproxy bool, pr interfaces.ClientURL)
  • func (cc *Clients) Close(id int)
  • func (cc *Clients) CloseAll()
  • func (cc *Clients) Destroy()
  • func (cc *Clients) New(opt *interfaces.WebsocketClientOption)
  • func (cc *Clients) Send(msg []byte)
  • func (cc *Clients) SendGob(msg interface{})
  • func (cc *Clients) SendGobID(idx int, msg interface{})
  • func (cc *Clients) SendID(idx int, msg []byte)
  • func (cc *Clients) SendJSON(msg interface{})
  • func (cc *Clients) SendJSONID(idx int, msg interface{})
• type SubChannel
  • func (cc *SubChannel) Close(callback func())

Functions

func NewClients

func NewClients() *interfaces.WebsocketClient

NewClients -

Types

type Clients

type Clients struct {
	AlreadyDestroy bool
	Options        *interfaces.WebsocketClientOption
	Socket         []*clients
	CurrentIndex   int
	CountThread    int
	sync.RWMutex
}

Clients -

func (*Clients) ChangeURL

func (cc *Clients) ChangeURL(ad interfaces.ClientURL, useproxy bool, pr interfaces.ClientURL)

ChangeURL -

func (*Clients) Close

func (cc *Clients) Close(id int)

Close -

func (*Clients) CloseAll

func (cc *Clients) CloseAll()

CloseAll -

func (*Clients) Destroy

func (cc *Clients) Destroy()

Destroy -

func (*Clients) New

func (cc *Clients) New(opt *interfaces.WebsocketClientOption)

New -

func (*Clients) Send

func (cc *Clients) Send(msg []byte)

Send -

func (*Clients) SendGob

func (cc *Clients) SendGob(msg interface{})

SendGob -

func (*Clients) SendGobID

func (cc *Clients) SendGobID(idx int, msg interface{})

SendGobID -

func (*Clients) SendID

func (cc *Clients) SendID(idx int, msg []byte)

SendID -

func (*Clients) SendJSON

func (cc *Clients) SendJSON(msg interface{})

SendJSON -

func (*Clients) SendJSONID

func (cc *Clients) SendJSONID(idx int, msg interface{})

SendJSONID -

type SubChannel

type SubChannel struct {
	sync.Mutex
	// contains filtered or unexported fields
}

SubChannel -

func (*SubChannel) Close

func (cc *SubChannel) Close(callback func())

Close -