Documentation
¶
Index ¶
- type RawSocketeer
- func (s *RawSocketeer) AddPayload(payload []byte) bool
- func (s *RawSocketeer) DeInit() error
- func (s *RawSocketeer) Init() error
- func (s *RawSocketeer) Options() config.SocketeerOptions
- func (s *RawSocketeer) RunListener()
- func (s *RawSocketeer) RunWriter()
- func (s *RawSocketeer) SetReceiver(receiverFunc func(msg message.Message) bool)
- func (s *RawSocketeer) StopListener() error
- func (s *RawSocketeer) StopWriter() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RawSocketeer ¶
func NewRawSocketeer ¶
func NewRawSocketeer(o *config.SocketeerOptions, logFunc func(string) bool, errFunc func(error) bool) *RawSocketeer
func (*RawSocketeer) AddPayload ¶
func (s *RawSocketeer) AddPayload(payload []byte) bool
func (*RawSocketeer) DeInit ¶
func (s *RawSocketeer) DeInit() error
func (*RawSocketeer) Init ¶
func (s *RawSocketeer) Init() error
func (*RawSocketeer) Options ¶
func (s *RawSocketeer) Options() config.SocketeerOptions
func (*RawSocketeer) RunListener ¶
func (s *RawSocketeer) RunListener()
func (*RawSocketeer) RunWriter ¶
func (s *RawSocketeer) RunWriter()
func (*RawSocketeer) SetReceiver ¶
func (s *RawSocketeer) SetReceiver(receiverFunc func(msg message.Message) bool)
func (*RawSocketeer) StopListener ¶
func (s *RawSocketeer) StopListener() error
func (*RawSocketeer) StopWriter ¶
func (s *RawSocketeer) StopWriter() error
Click to show internal directories.
Click to hide internal directories.