Documentation
¶
Overview ¶
Copyright (c) 2023 Albert Espín albert@espin.ovh
Copyright (c) 2023 Albert Espín albert@espin.ovh
Index ¶
Constants ¶
View Source
const (
MaxDataBuffer int = 4096
)
Variables ¶
View Source
var (
ConnectionNr int = 0
)
Functions ¶
This section is empty.
Types ¶
type Injector ¶
type Injector struct { fb.BaseProcess // contains filtered or unexported fields }
func NewInjector ¶
func NewInjector(config *InjectorConfig, net *fb.Network, log logger.LoggerAdapter) *Injector
type InjectorConfig ¶
type NSQSubscriber ¶
type NSQSubscriber struct { fb.BaseProcess // contains filtered or unexported fields }
func NewNSQSubscriber ¶
func NewNSQSubscriber(config *SubscriberConfig, net *fb.Network, log logger.LoggerAdapter) *NSQSubscriber
func (*NSQSubscriber) In ¶
func (s *NSQSubscriber) In() *fb.InPort
func (*NSQSubscriber) Out ¶
func (s *NSQSubscriber) Out() *fb.OutPort
func (*NSQSubscriber) Run ¶
func (s *NSQSubscriber) Run()
type SubscriberConfig ¶
type TCPServer ¶
type TCPServer struct { fb.BaseProcess // contains filtered or unexported fields }
func NewTCPServer ¶
func NewTCPServer(config *TCPServerConfig, net *fb.Network, log logger.LoggerAdapter) *TCPServer
Click to show internal directories.
Click to hide internal directories.