remotemap

package

v0.7.10 Latest Latest Go to latest Published: Nov 13, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/refraction-networking/conjure

Links

Open Source Insights

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 ¶

View Source

const QueueSize = 128

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

remotemap.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL