link

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 30, 2025 License: 0BSD Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CURVE = "Curve25519"

	ECPUBSIZE     = 64
	KEYSIZE       = 32
	LINK_MTU_SIZE = 3
	MTU_BYTEMASK  = 0xFFFFFF
	MODE_BYTEMASK = 0xE0

	ESTABLISHMENT_TIMEOUT_PER_HOP = 6
	KEEPALIVE_TIMEOUT_FACTOR      = 4
	STALE_GRACE                   = 2
	KEEPALIVE                     = 360
	STALE_TIME                    = 720
	TRAFFIC_TIMEOUT_FACTOR        = 6

	ACCEPT_NONE = 0x00
	ACCEPT_ALL  = 0x01
	ACCEPT_APP  = 0x02

	STATUS_PENDING   = 0x00
	STATUS_HANDSHAKE = 0x01
	STATUS_ACTIVE    = 0x02
	STATUS_STALE     = 0x03
	STATUS_CLOSED    = 0x04
	STATUS_FAILED    = 0x05

	PROVE_NONE = 0x00
	PROVE_ALL  = 0x01
	PROVE_APP  = 0x02

	MODE_AES128_CBC = 0x00
	MODE_AES256_CBC = 0x01
	MODE_DEFAULT    = MODE_AES256_CBC

	WATCHDOG_MIN_SLEEP = 0.025
	WATCHDOG_INTERVAL  = 0.1

	DEST_TYPE_LINK = 0x03

	MIN_REQUEST_DATA_LEN  = 3
	MIN_RESPONSE_DATA_LEN = 2
)

Variables

This section is empty.

Functions

This section is empty.

Types 

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

func HandleIncomingLinkRequest 

func HandleIncomingLinkRequest(pkt *packet.Packet, dest *destination.Destination, transport *transport.Transport, networkIface common.NetworkInterface) (*Link, error)
func NewLink(dest *destination.Destination, transport *transport.Transport, networkIface common.NetworkInterface, establishedCallback func(*Link), closedCallback func(*Link)) *Link

func (*Link) Establish 

func (l *Link) Establish() error

func (*Link) GenerateLinkProof 

func (l *Link) GenerateLinkProof(ownerIdentity *identity.Identity) (*packet.Packet, error)

func (*Link) GetAge 

func (l *Link) GetAge() float64

func (*Link) GetChannel 

func (l *Link) GetChannel() *channel.Channel

func (*Link) GetEstablishmentRate 

func (l *Link) GetEstablishmentRate() float64

func (*Link) GetLinkID 

func (l *Link) GetLinkID() []byte

func (*Link) GetQ 

func (l *Link) GetQ() float64

func (*Link) GetRSSI 

func (l *Link) GetRSSI() float64

func (*Link) GetRTT 

func (l *Link) GetRTT() float64

func (*Link) GetRemoteIdentity 

func (l *Link) GetRemoteIdentity() *identity.Identity

func (*Link) GetSNR 

func (l *Link) GetSNR() float64

func (*Link) GetStatus 

func (l *Link) GetStatus() byte

func (*Link) HandleIdentification 

func (l *Link) HandleIdentification(data []byte) error

func (*Link) HandleInbound 

func (l *Link) HandleInbound(pkt *packet.Packet) error

func (*Link) HandleLinkRequest 

func (l *Link) HandleLinkRequest(pkt *packet.Packet, ownerIdentity *identity.Identity) error

func (*Link) HandleProofRequest 

func (l *Link) HandleProofRequest(packet *packet.Packet) bool

func (*Link) Identify 

func (l *Link) Identify(id *identity.Identity) error

func (*Link) InactiveFor 

func (l *Link) InactiveFor() float64

func (*Link) IsActive 

func (l *Link) IsActive() bool

func (*Link) NoDataFor 

func (l *Link) NoDataFor() float64

func (*Link) NoInboundFor 

func (l *Link) NoInboundFor() float64

func (*Link) NoOutboundFor 

func (l *Link) NoOutboundFor() float64

func (*Link) RTT 

func (l *Link) RTT() float64

func (*Link) Request 

func (l *Link) Request(path string, data []byte, timeout time.Duration) (*RequestReceipt, error)

func (*Link) Resend 

func (l *Link) Resend(pkt interface{}) error

func (*Link) Send 

func (l *Link) Send(data []byte) interface{}

func (*Link) SendLinkRequest 

func (l *Link) SendLinkRequest() error

func (*Link) SendPacket 

func (l *Link) SendPacket(data []byte) error

func (*Link) SendResource 

func (l *Link) SendResource(res *resource.Resource) error

func (*Link) SetLinkClosedCallback 

func (l *Link) SetLinkClosedCallback(callback func(*Link))

func (*Link) SetPacketCallback 

func (l *Link) SetPacketCallback(callback func([]byte, *packet.Packet))

func (*Link) SetPacketDelivered 

func (l *Link) SetPacketDelivered(pkt interface{}, callback func(interface{}))

func (*Link) SetPacketTimeout 

func (l *Link) SetPacketTimeout(pkt interface{}, callback func(interface{}), timeout time.Duration)

func (*Link) SetProofCallback 

func (l *Link) SetProofCallback(callback func(*packet.Packet) bool)

func (*Link) SetProofStrategy 

func (l *Link) SetProofStrategy(strategy byte) error

func (*Link) SetRTT 

func (l *Link) SetRTT(rtt float64)

func (*Link) SetRemoteIdentifiedCallback 

func (l *Link) SetRemoteIdentifiedCallback(callback func(*Link, *identity.Identity))

func (*Link) SetResourceCallback 

func (l *Link) SetResourceCallback(callback func(interface{}) bool)

func (*Link) SetResourceConcludedCallback 

func (l *Link) SetResourceConcludedCallback(callback func(interface{}))

func (*Link) SetResourceStartedCallback 

func (l *Link) SetResourceStartedCallback(callback func(interface{}))

func (*Link) SetResourceStrategy 

func (l *Link) SetResourceStrategy(strategy byte) error

func (*Link) Start 

func (l *Link) Start()

func (*Link) Teardown 

func (l *Link) Teardown()

func (*Link) TrackPhyStats 

func (l *Link) TrackPhyStats(track bool)

func (*Link) UpdatePhyStats 

func (l *Link) UpdatePhyStats(rssi, snr, q float64)

func (*Link) Validate 

func (l *Link) Validate(signature, message []byte) bool

func (*Link) ValidateLinkProof 

func (l *Link) ValidateLinkProof(pkt *packet.Packet, networkIface common.NetworkInterface) error

type RequestReceipt 

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

func (*RequestReceipt) Concluded 

func (r *RequestReceipt) Concluded() bool

func (*RequestReceipt) GetRequestID 

func (r *RequestReceipt) GetRequestID() []byte

func (*RequestReceipt) GetResponse 

func (r *RequestReceipt) GetResponse() []byte

func (*RequestReceipt) GetResponseTime 

func (r *RequestReceipt) GetResponseTime() float64

func (*RequestReceipt) GetStatus 

func (r *RequestReceipt) GetStatus() byte

func (*RequestReceipt) SetFailedCallback 

func (r *RequestReceipt) SetFailedCallback(cb func(*RequestReceipt))

func (*RequestReceipt) SetProgressCallback 

func (r *RequestReceipt) SetProgressCallback(cb func(*RequestReceipt))

func (*RequestReceipt) SetResponseCallback 

func (r *RequestReceipt) SetResponseCallback(cb func(*RequestReceipt))

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.