loop

Documentation

Index

• Variables
• type ErrInvalidState
  • func (err *ErrInvalidState) Error() string
• type LoopState
  • func (state LoopState) String() string
• type MessageHandler
• type MessageLoop
  • func New(items PollItems) *MessageLoop
  • func (loop *MessageLoop) Close() error
  • func (loop *MessageLoop) DispatchMessage(itemIndex byte, msg [][]byte) error
  • func (loop *MessageLoop) ListenAndServe() error
• type PollItem
• type PollItems

Variables

var (
	ErrEmptyPollItems   = errors.New("Empty PollItems")
	ErrEmptyMessage     = errors.New("Empty message")
	ErrTooManyPollItems = errors.New("No mobre than 255 PollItems are supported")
)

Types

type ErrInvalidState

type ErrInvalidState struct {
	Expected LoopState
	Current  LoopState
}

func (*ErrInvalidState) Error

func (err *ErrInvalidState) Error() string

type LoopState

type LoopState byte

func (LoopState) String

func (state LoopState) String() string

type MessageHandler

type MessageHandler func(msg [][]byte)

type MessageLoop

type MessageLoop struct {
	// contains filtered or unexported fields
}

func New

func New(items PollItems) *MessageLoop

func (*MessageLoop) Close

func (loop *MessageLoop) Close() error

func (*MessageLoop) DispatchMessage

func (loop *MessageLoop) DispatchMessage(itemIndex byte, msg [][]byte) error

func (*MessageLoop) ListenAndServe

func (loop *MessageLoop) ListenAndServe() error

type PollItem

type PollItem struct {
	Socket   *zmq.Socket
	Callback MessageHandler
}

type PollItems

type PollItems []PollItem