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

message

package

Go to main page

Versions in this module

v0

v0.0.4

Dec 27, 2019

Changes in this version

type Broker

+ func (a *Broker) Flush() error

type Conn

+ func (a *Conn) Flush() error

v0.0.3

Dec 20, 2019

Changes in this version

+ var NoConnections = errors.New("No Connections")

v0.0.2

Dec 13, 2019

Changes in this version

type Broker

+ func (a *Broker) Stats() (sent, received uint64)

type Conn

+ func (a *Conn) Stats() (sent, received uint64)

v0.0.1

Dec 11, 2019

Changes in this version

+ const MaxConnections

+ const MaxMessageSize

+ const Protocol

+ const SendBufferSize

+ var ConnectionClosed = errors.New("Connection Closed")

+ var DuplicateMessageCode = errors.New("Duplicate Message Code")

+ var HeartbeatMessageCode uint32 = 1

+ var InvalidConfig = errors.New("Invalid Configuration")

+ var InvalidEncoding = errors.New("Invalid Encoding")

+ var InvalidMessageCode = errors.New("Invalid Message Code")

+ type Broker struct

+ Handler Handler

+ MaxConnections int

+ MaxMessageSize uint32

+ Messages []New

+ Pattern Pattern

+ Pipes []Piped

+ SendBufferSize int

+ Timeout time.Duration

+ func (a *Broker) Close() error

+ func (a *Broker) Len() int

+ func (a *Broker) Send(ctx context.Context, m interface{}, conns ...*Conn) error

+ func (a *Broker) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (a *Broker) Start(conn net.Conn, path string, encoding string) (*Conn, error)

+ type Conn struct

+ func (a *Conn) Broker() *Broker

+ func (a *Conn) Close() error

+ func (a *Conn) Context() context.Context

+ func (a *Conn) Send(ctx context.Context, message interface{}) error

+ type Encoding interface

+ MessageEncoding func() (encoding string)

+ type Handler interface

+ Handle func(*Conn, interface{}) error

+ type HandlerFunc func(*Conn, interface{}) error

+ func (a HandlerFunc) Handle(c *Conn, m interface{}) error

+ type M interface

+ MessageCode func() uint32

+ type New func() M

+ type Pattern func([]*Conn) []*Conn

+ func Publish() Pattern

+ func Queue() Pattern

+ type Pipe struct

+ type Piped interface

+ type Sender interface

+ Send func(context.Context, interface{}, ...*Conn) error

+ type SenderFunc func(context.Context, interface{}, ...*Conn) error

+ func (a SenderFunc) Send(ctx context.Context, m interface{}, conns ...*Conn) error