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

network

package

Go to main page

Versions in this module

v0

v0.0.5

Mar 4, 2019

Changes in this version

+ type Framework interface

+ Close func(*NetworkContext)

+ Configure func(*Legion) error

+ NewMessage func(*MessageContext)

+ PeerAdded func(*PeerContext)

+ PeerDisconnect func(*PeerContext)

+ Startup func(*NetworkContext)

+ ValidateMessage func(*MessageContext) bool

+ type GenericFramework struct

+ func (*GenericFramework) Close(ctx *NetworkContext)

+ func (*GenericFramework) Configure(*Legion) error

+ func (*GenericFramework) NewMessage(ctx *MessageContext)

+ func (*GenericFramework) PeerAdded(ctx *PeerContext)

+ func (*GenericFramework) PeerDisconnect(ctx *PeerContext)

+ func (*GenericFramework) Startup(ctx *NetworkContext)

+ func (*GenericFramework) ValidateMessage(ctx *MessageContext) bool

type Legion

+ func (l *Legion) Request(message *transport.Message, timeout time.Duration, address utils.LegionAddress) (*transport.Message, error)

type Peer

+ func (p *Peer) QueueReply(rpcID uint64, m *transport.Message)

+ func (p *Peer) Request(timeout time.Duration, m *transport.Message) (*transport.Message, error)

v0.0.4

Feb 15, 2019

v0.0.3

Dec 26, 2018

v0.0.2

Dec 20, 2018

v0.0.1

Dec 17, 2018

Changes in this version

+ type GenericPlugin struct

+ func (*GenericPlugin) Close(ctx *NetworkContext)

+ func (*GenericPlugin) NewMessage(ctx *MessageContext)

+ func (*GenericPlugin) PeerAdded(ctx *PeerContext)

+ func (*GenericPlugin) PeerDisconnect(ctx *PeerContext)

+ func (*GenericPlugin) PeerPromotion(ctx *PeerContext)

+ func (*GenericPlugin) Startup(ctx *NetworkContext)

+ type Legion struct

+ func NewLegion(conf *config.LegionConfig) *Legion

+ func (l *Legion) AddPeer(addresses ...utils.LegionAddress) error

+ func (l *Legion) Broadcast(message *message.Message, addresses ...utils.LegionAddress)

+ func (l *Legion) BroadcastRandom(message *message.Message, n int)

+ func (l *Legion) DeletePeer(addresses ...utils.LegionAddress) error

+ func (l *Legion) DoAllPeers(f func(p *Peer))

+ func (l *Legion) DoPromotedPeers(f func(p *Peer))

+ func (l *Legion) FireMessageEvent(eventType events.MessageEvent, message *message.Message)

+ func (l *Legion) FireNetworkEvent(eventType events.NetworkEvent)

+ func (l *Legion) FirePeerEvent(eventType events.PeerEvent, peer *Peer, isIncoming bool)

+ func (l *Legion) Listen() error

+ func (l *Legion) Me() utils.LegionAddress

+ func (l *Legion) NewMessage(messageType string, body []byte) *message.Message

+ func (l *Legion) NewMessageWithData(messageType string, body, data []byte) *message.Message

+ func (l *Legion) PeerExists(address utils.LegionAddress) bool

+ func (l *Legion) PeerPromoted(address utils.LegionAddress) bool

+ func (l *Legion) PromotePeer(addresses ...utils.LegionAddress) error

+ func (l *Legion) RegisterPlugin(plugins ...PluginInterface)

+ func (l *Legion) Started()

+ func (l *Legion) Stop() error

+ type MessageContext struct

+ Legion *Legion

+ Message *message.Message

+ Sender utils.LegionAddress

+ func (mc *MessageContext) Reply(msg *message.Message)

+ type NetworkContext struct

+ Legion *Legion

+ type Peer struct

+ func NewPeer(remote utils.LegionAddress) *Peer

+ func (p *Peer) BlockUntilDisconnected()

+ func (p *Peer) Close() error

+ func (p *Peer) CreateClient(conn net.Conn) error

+ func (p *Peer) CreateServer(conn net.Conn) error

+ func (p *Peer) IncomingMessages() chan *message.Message

+ func (p *Peer) QueueMessage(m *message.Message)

+ func (p *Peer) Remote() utils.LegionAddress

+ type PeerContext struct

+ IsIncoming bool

+ Legion *Legion

+ Peer *Peer

+ type PluginInterface interface

+ Close func(ctx *NetworkContext)

+ NewMessage func(ctx *MessageContext)

+ PeerAdded func(ctx *PeerContext)

+ PeerDisconnect func(ctx *PeerContext)

+ PeerPromotion func(ctx *PeerContext)

+ Startup func(ctx *NetworkContext)