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

protocols

package

Go to main page

Versions in this module

v0

v0.4.3

Jul 25, 2019

v0.4.2

Jun 28, 2019

v0.4.1

Jun 13, 2019

Changes in this version

+ const AccountingVersion

+ const ErrDecode

+ const ErrHandler

+ const ErrHandshake

+ const ErrInvalidMsgCode

+ const ErrInvalidMsgType

+ const ErrMsgTooLong

+ const ErrNoHandler

+ const ErrWrite

+ const Receiver

+ const Sender

+ type Accounting struct

+ func NewAccounting(balance Balance, po Prices) *Accounting

+ func (ah *Accounting) Receive(peer *Peer, size uint32, msg interface{}) error

+ func (ah *Accounting) Send(peer *Peer, size uint32, msg interface{}) error

+ type AccountingApi struct

+ func NewAccountingApi(m *AccountingMetrics) *AccountingApi

+ func (self *AccountingApi) Balance() (int64, error)

+ func (self *AccountingApi) BalanceCredit() (int64, error)

+ func (self *AccountingApi) BalanceDebit() (int64, error)

+ func (self *AccountingApi) BytesCredit() (int64, error)

+ func (self *AccountingApi) BytesDebit() (int64, error)

+ func (self *AccountingApi) MsgCredit() (int64, error)

+ func (self *AccountingApi) MsgDebit() (int64, error)

+ func (self *AccountingApi) PeerDrops() (int64, error)

+ func (self *AccountingApi) SelfDrops() (int64, error)

+ type AccountingMetrics struct

+ func NewAccountingMetrics(r metrics.Registry, d time.Duration, path string) *AccountingMetrics

+ func SetupAccountingMetrics(reportInterval time.Duration, path string) *AccountingMetrics

+ func (am *AccountingMetrics) Close()

+ type Balance interface

+ Add func(amount int64, peer *Peer) error

+ type Error struct

+ Code int

+ func (e Error) Error() (message string)

+ type Hook interface

+ Receive func(peer *Peer, size uint32, msg interface{}) error

+ Send func(peer *Peer, size uint32, msg interface{}) error

+ type Payer bool

+ type Peer struct

+ func NewPeer(p *p2p.Peer, rw p2p.MsgReadWriter, spec *Spec) *Peer

+ func (p *Peer) Drop()

+ func (p *Peer) Handshake(ctx context.Context, hs interface{}, verify func(interface{}) error) (interface{}, error)

+ func (p *Peer) HasCap(capName string) (yes bool)

+ func (p *Peer) Run(handler func(ctx context.Context, msg interface{}) error) error

+ func (p *Peer) Send(ctx context.Context, msg interface{}) error

+ type Price struct

+ Payer Payer

+ PerByte bool

+ Value uint64

+ func (p *Price) For(payer Payer, size uint32) int64

+ type Prices interface

+ Price func(interface{}) *Price

+ type Spec struct

+ Hook Hook

+ MaxMsgSize uint32

+ Messages []interface{}

+ Name string

+ Version uint

+ func (s *Spec) GetCode(msg interface{}) (uint64, bool)

+ func (s *Spec) Length() uint64

+ func (s *Spec) NewMsg(code uint64) (interface{}, bool)

+ type WrappedMsg struct

+ Context []byte

+ Payload []byte

+ Size uint32

Incompatible versions in this module

v2.5.0+incompatible

Mar 3, 2020

v2.4.0+incompatible

Dec 4, 2019

v2.3.0+incompatible

Oct 4, 2019

v2.2.5+incompatible

Aug 8, 2019

v2.2.4+incompatible

Jun 19, 2019

v2.2.3+incompatible

Apr 4, 2019

v2.2.2+incompatible

Apr 3, 2019

v2.2.1+incompatible

Jan 16, 2019

v2.2.0+incompatible

Dec 12, 2018