remotemap

Documentation

Index

• Constants
• type RemoteMap
  • func NewRemoteMap(timeout time.Duration) *RemoteMap
  • func (m *RemoteMap) Chan(addr net.Addr) chan []byte
  • func (m *RemoteMap) GetChan(addr net.Addr) (chan []byte, bool)

Constants

const QueueSize = 128

Types

type RemoteMap

type RemoteMap struct {
	// contains filtered or unexported fields
}

RemoteMap manages a mapping of live remote peers, keyed by address, to their respective send queues. Each peer has two queues: a send queue, and a receive queue. RemoteMap's functions are safe to call from multiple goroutines.

func NewRemoteMap

func NewRemoteMap(timeout time.Duration) *RemoteMap

NewRemoteMap creates a RemoteMap that expires peers after a timeout.

If the timeout is 0, peers never expire.

func (*RemoteMap) Chan

func (m *RemoteMap) Chan(addr net.Addr) chan []byte

Get Channel corresponding to addr

func (*RemoteMap) GetChan

func (m *RemoteMap) GetChan(addr net.Addr) (chan []byte, bool)

Returns the send channel corresponding to addr and indicates whether it is a new channel