source

Documentation

Index

• type Source
  • func New(globalConfig *config.Config, Config *config.SourceConfig, errFunc func(error), ...) *Source
  • func (s *Source) AddMessage(msg *receiver.Message) error
  • func (s *Source) AddReceiver(r *receiver.Receiver)
  • func (s *Source) Listen(wg *sync.WaitGroup) error
  • func (s *Source) Stop()

Types

type Source

type Source struct {
	IP net.IP

	Config *config.SourceConfig
	// contains filtered or unexported fields
}

func New

func New(globalConfig *config.Config, Config *config.SourceConfig, errFunc func(error), logFunc func(string)) *Source

func (*Source) AddMessage

func (s *Source) AddMessage(msg *receiver.Message) error

func (*Source) AddReceiver

func (s *Source) AddReceiver(r *receiver.Receiver)

func (*Source) Listen

func (s *Source) Listen(wg *sync.WaitGroup) error

func (*Source) Stop

func (s *Source) Stop()