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

ops

package

Go to main page

Versions in this module

v0

v0.2.3

Jun 9, 2021

v0.2.2

Jun 8, 2021

v0.2.1

May 27, 2021

v0.2.0

May 24, 2021

Changes in this version

+ var ErrEmptyRead = errors.New("read zero bytes from socket")

+ var ErrIllegalRead = errors.New("illegal envelope read completion event")

+ var ErrListenerNotStarted = errors.New("failed to start listener")

type AddSubscriptionRequest

+ func (a *AddSubscriptionRequest) WriteEnvelope(w io.Writer) (int64, error)

type Msg

+ func (m *Msg) WriteEnvelope(w io.Writer) (int64, error)

type NewSubscriptionRequest

+ func (n *NewSubscriptionRequest) WriteEnvelope(w io.Writer) (int64, error)

type UnsubcriptionRequest

+ func (u *UnsubcriptionRequest) WriteEnvelope(w io.Writer) (int64, error)

v0.1.0

May 18, 2021

Changes in this version

+ var ErrConnectionTerminated = errors.New("connection already teared down")

+ var ErrEmptyTopicSet = errors.New("topic list is empty")

+ var ErrTerminateConnection = errors.New("unsupported opcode, begin connection tear down")

+ type AddSubscriptionRequest struct

+ Id uint64

+ Topics []string

+ func (a *AddSubscriptionRequest) ReadFrom(r io.Reader) (int64, error)

+ func (a *AddSubscriptionRequest) WriteTo(w io.Writer) (int64, error)

+ type CountResponse uint32

+ func (p *CountResponse) ReadFrom(r io.Reader) (int64, error)

+ func (p CountResponse) WriteTo(w io.Writer) (int64, error)

+ type Msg pubsub.Message

+ func (m *Msg) ReadFrom(r io.Reader) (int64, error)

+ func (m *Msg) WriteTo(w io.Writer) (int64, error)

+ type NewSubResponse struct

+ Id uint64

+ TopicCount uint32

+ func (n *NewSubResponse) ReadFrom(r io.Reader) (int64, error)

+ func (n *NewSubResponse) WriteTo(w io.Writer) (int64, error)

+ type NewSubscriptionRequest struct

+ Topics []string

+ func (n *NewSubscriptionRequest) ReadFrom(r io.Reader) (int64, error)

+ func (n *NewSubscriptionRequest) WriteTo(w io.Writer) (int64, error)

+ type OP uint8

+ const ADD_SUB_REQ

+ const ADD_SUB_RESP

+ const MSG_PUSH

+ const NEW_SUB_REQ

+ const NEW_SUB_RESP

+ const PUB_REQ

+ const PUB_RESP

+ const UNSUB_REQ

+ const UNSUB_RESP

+ const UNSUPPORTED

+ func (o *OP) ReadFrom(r io.Reader) (int64, error)

+ func (o OP) WriteTo(w io.Writer) (int64, error)

+ type PushedMessage pubsub.PublishedMessage

+ func (p *PushedMessage) ReadFrom(r io.Reader) (int64, error)

+ func (p *PushedMessage) WriteTo(w io.Writer) (int64, error)

+ type UnsubcriptionRequest struct

+ Id uint64

+ Topics []string

+ func (u *UnsubcriptionRequest) ReadFrom(r io.Reader) (int64, error)

+ func (u *UnsubcriptionRequest) WriteTo(w io.Writer) (int64, error)