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

connection

package

Go to main page

Versions in this module

v1

v1.0.7

Feb 25, 2020

Changes in this version

+ type CloseRead interface

+ CloseRead func() error

+ type CloseWrite interface

+ CloseWrite func() error

+ type HalfOpenConn interface

+ CloseRead func() error

+ CloseWrite func() error

type InboundConnection

+ func (c *InboundConnection) CloseRead() error

+ func (c *InboundConnection) CloseWrite() error

v1.0.6

Oct 25, 2019

v1.0.5

Oct 20, 2019

v1.0.4

Oct 17, 2019

v1.0.3

Oct 16, 2019

Changes in this version

+ const OrderedRecvQueueSize

+ const OutboundBlockTimeoutSec

+ const OutboundRecvBuffer

+ const PacketWaitTimeoutSec

+ const RecvQueueSize

+ type ByteRingBuffer struct

+ func NewByteRingBuffer(size uint32) ByteRingBuffer

+ func (rb *ByteRingBuffer) Empty() bool

+ func (rb *ByteRingBuffer) OverWrite(data []byte)

+ func (rb *ByteRingBuffer) Read(data []byte) int

+ type Connection interface

+ GetConnectionID func() uint32

+ OrderedRelay func(connection Connection)

+ RecvBlock func(block.Block)

+ SendConnect func(address string)

+ SendDisconnect func()

+ Stop func()

+ func NewInboundConnection(sendQueue chan<- block.Block, ctx context.Context, ...) Connection

+ func NewOutboundConnection(connectionID uint32, sendQueue chan<- block.Block, ctx context.Context, ...) Connection

+ type InboundConnection struct

+ func (bc *InboundConnection) GetConnectionID() uint32

+ func (bc *InboundConnection) OrderedRelay(connection Connection)

+ func (bc *InboundConnection) RecvBlock(blk block.Block)

+ func (bc *InboundConnection) SendConnect(address string)

+ func (bc *InboundConnection) SendDisconnect()

+ func (bc *InboundConnection) Stop()

+ func (c *InboundConnection) Close() error

+ func (c *InboundConnection) LocalAddr() net.Addr

+ func (c *InboundConnection) Read(b []byte) (n int, err error)

+ func (c *InboundConnection) RemoteAddr() net.Addr

+ func (c *InboundConnection) SetDeadline(t time.Time) error

+ func (c *InboundConnection) SetReadDeadline(t time.Time) error

+ func (c *InboundConnection) SetWriteDeadline(t time.Time) error

+ func (c *InboundConnection) Write(b []byte) (n int, err error)

+ type OutboundConnection struct

+ func (bc *OutboundConnection) GetConnectionID() uint32

+ func (bc *OutboundConnection) OrderedRelay(connection Connection)

+ func (bc *OutboundConnection) SendConnect(address string)

+ func (bc *OutboundConnection) SendDisconnect()

+ func (bc *OutboundConnection) Stop()

+ func (oc *OutboundConnection) RecvBlock(blk block.Block)

+ func (oc *OutboundConnection) RecvRelay()

+ func (oc *OutboundConnection) SendRelay()

v1.0.2

Oct 14, 2019

v1.0.1

Oct 13, 2019