remote

Documentation

Index

• type Neighbour
  • func NewNeighbour(id, address, pk string) *Neighbour
  • func (n *Neighbour) GetAddress() string
  • func (n *Neighbour) GetConnLock() *sync.RWMutex
  • func (n *Neighbour) GetEncoder() codec.Encoder
  • func (n *Neighbour) GetID() string
  • func (n *Neighbour) GetPK() string
  • func (n *Neighbour) GetType() string
  • func (n *Neighbour) IsAlive() bool
  • func (n *Neighbour) MarshalAndSend(message message.Message)
  • func (n *Neighbour) Send(buf []byte)
  • func (n *Neighbour) SetConnAndEncoderAndSignalAlive(conn *net.TCPConn)
  • func (n *Neighbour) WaitUntilAlive()
• type Node
  • func NewNode(address string) *Node
  • func (n *Node) GetAddress() string
  • func (n *Node) GetEncoder() codec.Encoder
  • func (n *Node) GetType() string
  • func (n *Node) IsAlive() bool
  • func (n *Node) SetConnAndEncoderAndSignalAlive(conn *net.TCPConn)
  • func (n *Node) WaitUntilAlive()
• type Remote

Types

type Neighbour

type Neighbour struct {
	util.Neighbour
	Encoder            *codec.BinaryEncoder
	WaitUntilAliveChan chan int // Dummy channel that we use to block other processes until the connection becomes live
	ConnLock           *sync.RWMutex
}

func NewNeighbour

func NewNeighbour(id, address, pk string) *Neighbour

func (*Neighbour) GetAddress

func (n *Neighbour) GetAddress() string

func (*Neighbour) GetConnLock

func (n *Neighbour) GetConnLock() *sync.RWMutex

func (*Neighbour) GetEncoder

func (n *Neighbour) GetEncoder() codec.Encoder

GetEncoder will block until connection is alive

func (*Neighbour) GetID

func (n *Neighbour) GetID() string

func (*Neighbour) GetPK

func (n *Neighbour) GetPK() string

func (*Neighbour) GetType

func (n *Neighbour) GetType() string

func (*Neighbour) IsAlive

func (n *Neighbour) IsAlive() bool

func (*Neighbour) MarshalAndSend

func (n *Neighbour) MarshalAndSend(message message.Message)

func (*Neighbour) Send

func (n *Neighbour) Send(buf []byte)

func (*Neighbour) SetConnAndEncoderAndSignalAlive

func (n *Neighbour) SetConnAndEncoderAndSignalAlive(conn *net.TCPConn)

func (*Neighbour) WaitUntilAlive

func (n *Neighbour) WaitUntilAlive()

type Node

type Node struct {
	Address            string
	Encoder            *codec.BinaryEncoder
	WaitUntilAliveChan chan int
}

func NewNode

func NewNode(address string) *Node

func (*Node) GetAddress

func (n *Node) GetAddress() string

func (*Node) GetEncoder

func (n *Node) GetEncoder() codec.Encoder

GetEncoder will block until connection is alive

func (*Node) GetType

func (n *Node) GetType() string

func (*Node) IsAlive

func (n *Node) IsAlive() bool

func (*Node) SetConnAndEncoderAndSignalAlive

func (n *Node) SetConnAndEncoderAndSignalAlive(conn *net.TCPConn)

func (*Node) WaitUntilAlive

func (n *Node) WaitUntilAlive()

type Remote

type Remote interface {
	GetAddress() string
	GetEncoder() codec.Encoder
	SetConnAndEncoderAndSignalAlive(conn *net.TCPConn)
	GetType() string
}