network

Documentation

Index

• func Runner(pipeline *goconnect.Pipeline, addrLists ...string)
• type Duplex
  • func NewDuplex(conn net.Conn) *Duplex
  • func (duplex *Duplex) Close() error
  • func (duplex *Duplex) Flush() error
• type NetMergeOrdered
  • func (n *NetMergeOrdered) InType() reflect.Type
  • func (n *NetMergeOrdered) OutType() reflect.Type
  • func (n *NetMergeOrdered) Run(input <-chan *goconnect.Element, context *goconnect.Context)
• type NetRoundRobin
  • func (n *NetRoundRobin) InType() reflect.Type
  • func (n *NetRoundRobin) OutType() reflect.Type
  • func (n *NetRoundRobin) Run(input <-chan *goconnect.Element, context *goconnect.Context)
• type Node
  • func JoinCluster(nodes ...string) []*Node
  • func NewNode(addr string, nodes []string) (*Node, error)
  • func (node *Node) GetNodeID() uint16
  • func (node *Node) GetNumPeers() uint16
  • func (node *Node) Join(nodes []string)
  • func (node *Node) MakeReceiver(stageId uint16) goconnect.Receiver
  • func (node *Node) NewSender(targetNodeId uint16, stageId uint16) goconnect.Sender
• type Server
  • func NewServer(addr string) *Server
  • func (server *Server) Close() error
  • func (server *Server) NewReceiver(handlerId uint16) *TCPReceiver
  • func (server *Server) Start() error
• type TCPReceiver
  • func (h *TCPReceiver) Ack(upstreamNodeId uint16, uniq uint64) error
  • func (h *TCPReceiver) Close() error
  • func (h *TCPReceiver) Elements() <-chan *goconnect.Element
  • func (h *TCPReceiver) ID() uint16
• type TCPSender
  • func (sender *TCPSender) Acks() <-chan uint64
  • func (sender *TCPSender) Close() error
  • func (sender *TCPSender) Eos()
  • func (sender *TCPSender) Send(e *goconnect.Element)
  • func (sender *TCPSender) SendJoin(nodeId int, server *Server, numNodes int)
  • func (sender *TCPSender) Start() error

Functions

func Runner

func Runner(pipeline *goconnect.Pipeline, addrLists ...string)

Types

type Duplex

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

func NewDuplex

func NewDuplex(conn net.Conn) *Duplex

func (*Duplex) Close

func (duplex *Duplex) Close() error

func (*Duplex) Flush

func (duplex *Duplex) Flush() error

type NetMergeOrdered

type NetMergeOrdered struct{}

func (*NetMergeOrdered) InType

func (n *NetMergeOrdered) InType() reflect.Type

func (*NetMergeOrdered) OutType

func (n *NetMergeOrdered) OutType() reflect.Type

func (*NetMergeOrdered) Run

func (n *NetMergeOrdered) Run(input <-chan *goconnect.Element, context *goconnect.Context)

type NetRoundRobin

type NetRoundRobin struct{}

func (*NetRoundRobin) InType

func (n *NetRoundRobin) InType() reflect.Type

func (*NetRoundRobin) OutType

func (n *NetRoundRobin) OutType() reflect.Type

func (*NetRoundRobin) Run

func (n *NetRoundRobin) Run(input <-chan *goconnect.Element, context *goconnect.Context)

type Node

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

func JoinCluster

func JoinCluster(nodes ...string) []*Node

func NewNode

func NewNode(addr string, nodes []string) (*Node, error)

func (*Node) GetNodeID

func (node *Node) GetNodeID() uint16

func (*Node) GetNumPeers

func (node *Node) GetNumPeers() uint16

func (*Node) Join

func (node *Node) Join(nodes []string)

func (*Node) MakeReceiver

func (node *Node) MakeReceiver(stageId uint16) goconnect.Receiver

func (*Node) NewSender

func (node *Node) NewSender(targetNodeId uint16, stageId uint16) goconnect.Sender

type Server

type Server struct {
	ID       uint16
	Addr     net.Addr
	Rand     int64
	Assigned chan bool
	// contains filtered or unexported fields
}

func NewServer

func NewServer(addr string) *Server

func (*Server) Close

func (server *Server) Close() error

func (*Server) NewReceiver

func (server *Server) NewReceiver(handlerId uint16) *TCPReceiver

func (*Server) Start

func (server *Server) Start() error

type TCPReceiver

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

func (*TCPReceiver) Ack

func (h *TCPReceiver) Ack(upstreamNodeId uint16, uniq uint64) error

func (*TCPReceiver) Close

func (h *TCPReceiver) Close() error

func (*TCPReceiver) Elements

func (h *TCPReceiver) Elements() <-chan *goconnect.Element

func (*TCPReceiver) ID

func (h *TCPReceiver) ID() uint16

type TCPSender

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

func (*TCPSender) Acks

func (sender *TCPSender) Acks() <-chan uint64

func (*TCPSender) Close

func (sender *TCPSender) Close() error

func (*TCPSender) Eos

func (sender *TCPSender) Eos()

func (*TCPSender) Send

func (sender *TCPSender) Send(e *goconnect.Element)

func (*TCPSender) SendJoin

func (sender *TCPSender) SendJoin(nodeId int, server *Server, numNodes int)

func (*TCPSender) Start

func (sender *TCPSender) Start() error