connect

Documentation

Index

• type Forker
  • func Fork[T any](joiners ...*Joiner[T]) Forker[T]
  • func (f *Forker[OUT]) Close()
  • func (f *Forker[OUT]) Sender() chan OUT
• type Joiner
  • func NewJoiner[IN any](bufferLength int) Joiner[IN]
  • func (j *Joiner[IN]) AcquireSender() chan IN
  • func (j *Joiner[IN]) Receiver() chan IN
  • func (j *Joiner[IN]) ReleaseSender()
• type Releaser

Types

type Forker

type Forker[OUT any] struct {
	// contains filtered or unexported fields
}

Forker manages the access to a Node's output (send) channel. When a node sends to only one node, this will work as a single channel. When a node sends to N nodes, it will spawn N channels that are cloned from the original channel in a goroutine.

func Fork

func Fork[T any](joiners ...*Joiner[T]) Forker[T]

Fork provides connection to a group of output Nodes, accessible through their respective Joiner instances.

func (*Forker[OUT]) Close

func (f *Forker[OUT]) Close()

Close the input channel and, in cascade, all the forked channels

func (*Forker[OUT]) Sender

func (f *Forker[OUT]) Sender() chan OUT

Sender acquires the channel that will receive the data from the source node

type Joiner

type Joiner[IN any] struct {
	// contains filtered or unexported fields
}

Joiner provides shared access to the input channel of a node of the type IN

func NewJoiner

func NewJoiner[IN any](bufferLength int) Joiner[IN]

NewJoiner creates a joiner for a given channel type and buffer length

func (*Joiner[IN]) AcquireSender

func (j *Joiner[IN]) AcquireSender() chan IN

AcquireSender gets acces to the channel as a sender. The acquirer must finally invoke ReleaseSender to make sure that the channel is closed when all the senders released it.

func (*Joiner[IN]) Receiver

func (j *Joiner[IN]) Receiver() chan IN

Receiver gets access to the channel as a receiver

func (*Joiner[IN]) ReleaseSender

func (j *Joiner[IN]) ReleaseSender()

ReleaseSender will close the channel when all the invokers of the AcquireSender have invoked this function

type Releaser

type Releaser func()

Releaser is a function that will allow releasing a forked channel.