Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

core

package

Go to main page

Versions in this module

v0

v0.0.2

Oct 6, 2018

Changes in this version

type Connector

+ func (cn *Connector) String() string

type Link

+ String func() string

type Message

+ func NewMessageWithMeta(meta map[string]interface{}, payload []byte) *Message

+ func (m *Message) GetMeta(key string) (interface{}, bool)

+ func (m *Message) GetMetaAll() map[string]interface{}

+ func (m *Message) GetMetaOrDef(key string, def interface{}) (interface{}, bool)

+ func (m *Message) SetMeta(key string, val interface{})

+ func (m *Message) SetMetaAll(extMeta map[string]interface{})

+ func (m *Message) UnsetMeta(key string) (interface{}, bool)

+ func (m *Message) UnsetMetaAll() map[string]interface{}

v0.0.1

Aug 23, 2018

Changes in this version

+ const CmdPpgtBtmUp

+ const CmdPpgtTopDwn

+ var ErrMsgFailed = fmt.Errorf("Failed message send")

+ var ErrMsgInvalid = fmt.Errorf("Invalid message format/payload")

+ var ErrMsgPartialSend = fmt.Errorf("Partial message send")

+ var ErrMsgThrottled = fmt.Errorf("Message throttled")

+ var ErrMsgTimedOut = fmt.Errorf("Message send timeout")

+ var ErrMsgUnroutable = fmt.Errorf("Unroutable message")

+ type Cmd struct

+ Code CmdCode

+ Payload []byte

+ type CmdCode int8

+ const CmdCodeStart

+ const CmdCodeStop

+ type CmdPropagation uint8

+ type Connector struct

+ func NewConnector() *Connector

+ func (cn *Connector) ConnectTo(l Link) error

+ func (cn *Connector) ExecCmd(cmd *Cmd) error

+ func (cn *Connector) GetMsgCh() chan *Message

+ func (cn *Connector) LinkTo([]Link) error

+ func (cn *Connector) Recv(msg *Message) error

+ func (cn *Connector) RouteTo(map[string]Link) error

+ func (cn *Connector) Send(msg *Message) error

+ type Link interface

+ ConnectTo func(Link) error

+ ExecCmd func(*Cmd) error

+ LinkTo func([]Link) error

+ Recv func(*Message) error

+ RouteTo func(map[string]Link) error

+ Send func(*Message) error

+ type Message struct

+ Meta MsgMeta

+ Payload []byte

+ func CpMessage(m *Message) *Message

+ func NewMessage(meta MsgMeta, payload []byte) *Message

+ func NewMessageWithAckCh(meta MsgMeta, payload []byte, ackCh chan MsgStatus) *Message

+ func (m *Message) AckContinue() error

+ func (m *Message) AckDone() error

+ func (m *Message) AckFailed() error

+ func (m *Message) AckInvalid() error

+ func (m *Message) AckPartialSend() error

+ func (m *Message) AckThrottled() error

+ func (m *Message) AckTimedOut() error

+ func (m *Message) AckUnroutable() error

+ func (m *Message) BumpAttempts() error

+ func (m *Message) GetAckCh() chan MsgStatus

+ func (m *Message) GetAttempts() uint32

+ func (m *Message) IsSync() bool

+ type MsgMeta map[string]string

+ func NewMsgMeta() MsgMeta

+ type MsgStatus = uint8

+ const MsgStatusDone

+ const MsgStatusFailed

+ const MsgStatusInvalid

+ const MsgStatusNew

+ const MsgStatusPartialSend

+ const MsgStatusThrottled

+ const MsgStatusTimedOut

+ const MsgStatusUnroutable

+ type Params map[string]interface

+ type RoutingFunc func(*Message) (string, error)