zmq_connector

README

HyperStreams Zmq Connector Library

Library

Documentation

Index

• Constants
• type ErrorCodes
  • func (r ErrorCodes) String() string
• type HsMassage
• type HsSever
  • func (h *HsSever) StartServer()
• type HsTemplate
  • func (ht *HsTemplate) Init()
  • func (ht *HsTemplate) StreamProcessor(stream *StreamConfig, cancel context.CancelFunc)
• type ProcessingFunction
• type SocketMassage
• type StreamConfig
• type StreamProcessor
• type Streams
• type StreamsHolder
  • func (h *StreamsHolder) ErrorResponse(stream uint32, function uint8, Address []byte, errorCode ErrorCodes)
  • func (h *StreamsHolder) InputProcessing(ctx context.Context)

Constants

const FirstFrame = 15

const StreamError = 13

Types

type ErrorCodes

type ErrorCodes uint8

const (
	EndpointStreamNotFound ErrorCodes = iota
)

func (ErrorCodes) String

func (r ErrorCodes) String() string

type HsMassage

type HsMassage struct {
	State    uint8
	Function uint8
	Body     []byte
}

type HsSever

type HsSever struct {
	SocketUrl string
	Streams   Streams
	// contains filtered or unexported fields
}

func (*HsSever) StartServer

func (h *HsSever) StartServer()

type HsTemplate

type HsTemplate struct {
	Pf ProcessingFunction
}

func (*HsTemplate) Init

func (ht *HsTemplate) Init()

func (*HsTemplate) StreamProcessor

func (ht *HsTemplate) StreamProcessor(
	stream *StreamConfig,
	cancel context.CancelFunc,
)

type ProcessingFunction

type ProcessingFunction func(message []byte, functionId uint8) []byte

type SocketMassage

type SocketMassage struct {
	Body    []byte
	Address []byte
}

type StreamConfig

type StreamConfig struct {
	Input  chan *HsMassage
	Output chan *HsMassage
	// contains filtered or unexported fields
}

type StreamProcessor

type StreamProcessor func(
	stream *StreamConfig,
	cancel context.CancelFunc,
)

type Streams

type Streams interface {
	// contains filtered or unexported methods
}

type StreamsHolder

type StreamsHolder struct {
	Streams        map[uint32]*StreamConfig
	Input          chan *SocketMassage
	Output         chan *SocketMassage
	MessageHandler StreamProcessor
	Meta           []byte
}

func (*StreamsHolder) ErrorResponse

func (h *StreamsHolder) ErrorResponse(stream uint32, function uint8, Address []byte, errorCode ErrorCodes)

func (*StreamsHolder) InputProcessing

func (h *StreamsHolder) InputProcessing(ctx context.Context)