relay

Documentation

Index

• type Client
• type RelayService
  • func NewRelayService(wallet vault.Wallet, node protocol.Noder) *RelayService
  • func (rs *RelayService) HandleMsg(packet *message.RelayPacket) error
  • func (rs *RelayService) ReceiveRelayMsg(v interface{}) error
  • func (rs *RelayService) ReceiveRelayMsgNoError(v interface{})
  • func (rs *RelayService) SendPacketToClients(clients []*session.Session, packet *message.RelayPacket) error
  • func (rs *RelayService) SendPacketToNode(nextHop protocol.Noder, packet *message.RelayPacket) error
  • func (rs *RelayService) SendRelayPacketsInBuffer(clientID []byte) error
  • func (rs *RelayService) Start() error

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