input

type Injector struct {
	fb.BaseProcess
	// contains filtered or unexported fields
}

type InjectorConfig struct {
	// Process Name
	ProcessName string
	//
	Interval time.Duration
}

type NSQSubscriber struct {
	fb.BaseProcess
	// contains filtered or unexported fields
}

type SubscriberConfig struct {
	// Process Name
	ProcessName string
	// URL
	URL string
	// NSQ config
	NSQConfig *nsq.Config
	// Channel is the channel to subscribe to.
	Channel string
	// Topic
	Topic string
}

type TCPServer struct {
	fb.BaseProcess
	// contains filtered or unexported fields
}

type TCPServerConfig struct {
	// Process name
	ProcessName string
	// Address tcp bind address
	Address string
	// DeadLine time
	DeadLine time.Duration
}