Versions in this module Expand all Collapse all v0 v0.2.0 Feb 23, 2023 Changes in this version + const MaxDataBuffer + var ConnectionNr int = 0 + type Injector struct + func NewInjector(config *InjectorConfig, net *fb.Network, log logger.LoggerAdapter) *Injector + func (inj *Injector) Out() *fb.OutPort + func (inj *Injector) Run() + type InjectorConfig struct + Interval time.Duration + ProcessName string + type NSQSubscriber struct + func NewNSQSubscriber(config *SubscriberConfig, net *fb.Network, log logger.LoggerAdapter) *NSQSubscriber + func (s *NSQSubscriber) Close() error + func (s *NSQSubscriber) In() *fb.InPort + func (s *NSQSubscriber) Out() *fb.OutPort + func (s *NSQSubscriber) Run() + type SubscriberConfig struct + Channel string + NSQConfig *nsq.Config + ProcessName string + Topic string + URL string + type TCPServer struct + func NewTCPServer(config *TCPServerConfig, net *fb.Network, log logger.LoggerAdapter) *TCPServer + func (s *TCPServer) In() *fb.InPort + func (s *TCPServer) Out() *fb.OutPort + func (s *TCPServer) Run() + type TCPServerConfig struct + Address string + DeadLine time.Duration + ProcessName string