Versions in this module Expand all Collapse all v0 v0.0.1 Aug 19, 2019 Changes in this version + func Runner(pipeline *goconnect.Pipeline, addrLists ...string) + type Duplex struct + func NewDuplex(conn net.Conn) *Duplex + func (duplex *Duplex) Close() error + func (duplex *Duplex) Flush() error + type NetMergeOrdered struct + 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 struct + 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 struct + 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 struct + Addr net.Addr + Assigned chan bool + ID uint16 + Rand int64 + func NewServer(addr string) *Server + func (server *Server) Close() error + func (server *Server) NewReceiver(handlerId uint16) *TCPReceiver + func (server *Server) Start() error + type TCPReceiver struct + 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 struct + 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
Go to main page