Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gocent

package module

Go to main page

Versions in this module

v2

v2.2.0

Feb 15, 2021

Changes in this version

type Config

+ GetAddr func() (string, error)

v2.1.0

Feb 22, 2020

Changes in this version

type Client

+ func (c *Client) HistoryRemove(ctx context.Context, channel string) error

type Pipe

+ func (p *Pipe) AddHistoryRemove(channel string) error

v2.0.2

Nov 5, 2018

v2.0.1

Nov 5, 2018

v2.0.0

Nov 4, 2018

Changes in this version

+ var DefaultHTTPClient = &http.Client

+ var ErrMalformedResponse = errors.New("malformed response returned from server")

+ var ErrPipeEmpty = errors.New("no commands in pipe")

+ type ChannelsResult struct

+ Channels []string

+ type Client struct

+ func New(c Config) *Client

+ func (c *Client) Broadcast(ctx context.Context, channels []string, data []byte) error

+ func (c *Client) Channels(ctx context.Context) (ChannelsResult, error)

+ func (c *Client) Disconnect(ctx context.Context, user string) error

+ func (c *Client) History(ctx context.Context, channel string) (HistoryResult, error)

+ func (c *Client) Info(ctx context.Context) (InfoResult, error)

+ func (c *Client) Pipe() *Pipe

+ func (c *Client) Presence(ctx context.Context, channel string) (PresenceResult, error)

+ func (c *Client) PresenceStats(ctx context.Context, channel string) (PresenceStatsResult, error)

+ func (c *Client) Publish(ctx context.Context, channel string, data []byte) error

+ func (c *Client) SendPipe(ctx context.Context, pipe *Pipe) ([]Reply, error)

+ func (c *Client) SetHTTPClient(httpClient *http.Client)

+ func (c *Client) Unsubscribe(ctx context.Context, channel, user string) error

+ type ClientInfo struct

+ ChanInfo json.RawMessage

+ Client string

+ ConnInfo json.RawMessage

+ User string

+ type Command struct

+ Method string

+ Params map[string]interface{}

+ type Config struct

+ Addr string

+ HTTPClient *http.Client

+ Key string

+ type ErrStatusCode struct

+ Code int

+ func (e ErrStatusCode) Error() string

+ type Error struct

+ Code int

+ Message string

+ func (e Error) Error() string

+ type HistoryResult struct

+ Publications []Publication

+ type InfoResult struct

+ Nodes []NodeInfo

+ type NodeInfo struct

+ Name string

+ NumChannels int

+ NumClients int

+ NumUsers int

+ UID string

+ Uptime int

+ Version string

+ type Pipe struct

+ func (p *Pipe) AddBroadcast(channels []string, data []byte) error

+ func (p *Pipe) AddChannels() error

+ func (p *Pipe) AddDisconnect(user string) error

+ func (p *Pipe) AddHistory(channel string) error

+ func (p *Pipe) AddInfo() error

+ func (p *Pipe) AddPresence(channel string) error

+ func (p *Pipe) AddPresenceStats(channel string) error

+ func (p *Pipe) AddPublish(channel string, data []byte) error

+ func (p *Pipe) AddUnsubscribe(channel string, user string) error

+ func (p *Pipe) Reset()

+ type PresenceResult struct

+ Presence map[string]ClientInfo

+ type PresenceStatsResult struct

+ NumClients int32

+ NumUsers int32

+ type Publication struct

+ Channel string

+ Client string

+ Data json.RawMessage

+ Info *ClientInfo

+ UID string

+ type Reply struct

+ Error *Error

+ Result json.RawMessage

Other modules containing this package

gopkg.in/centrifugal/gocent.v1