relay

package
v0.0.0-...-2cf7c70 Latest Latest
Warning

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

Go to latest
Published: Aug 30, 2018 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

type Client interface {
	GetID() []byte
	GetPubKey() []byte
	Send(data []byte) error
}

type RelayService

type RelayService struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewRelayService

func NewRelayService(wallet vault.Wallet, node protocol.Noder) *RelayService

func (*RelayService) HandleMsg

func (rs *RelayService) HandleMsg(packet *message.RelayPacket) error

func (*RelayService) ReceiveRelayMsg

func (rs *RelayService) ReceiveRelayMsg(v interface{}) error

func (*RelayService) ReceiveRelayMsgNoError

func (rs *RelayService) ReceiveRelayMsgNoError(v interface{})

func (*RelayService) SendPacketToClients

func (rs *RelayService) SendPacketToClients(clients []*session.Session, packet *message.RelayPacket) error

func (*RelayService) SendPacketToNode

func (rs *RelayService) SendPacketToNode(nextHop protocol.Noder, packet *message.RelayPacket) error

func (*RelayService) SendRelayPacketsInBuffer

func (rs *RelayService) SendRelayPacketsInBuffer(clientID []byte) error

func (*RelayService) Start

func (rs *RelayService) Start() error

Jump to

Keyboard shortcuts

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