workerchannel

Documentation

Index

• Constants
• func ConvertRequestData(request *RequestData) error
• func InitChannelHandlers()
• func RegisterHandler(id string, h Handler)
• func UnregisterHandler(id string)
• type Channel
  • func NewChannel(netParser netparser.INetParser, id string, jsonFormat bool) *Channel
  • func (c *Channel) Close()
  • func (c *Channel) Event(targetId int, event string)
  • func (c *Channel) OnRequest(fn func(request RequestData) ResponseData)
• type Handler
  • func GetChannelRequestHandler(id string) (Handler, error)
• type InternalData
  • func (i *InternalData) Unmarshal(data json.RawMessage) error
• type PayloadChannel
  • func NewPayloadChannel() *PayloadChannel
• type RequestData
  • func (d RequestData) String() string
• type ResponseData
  • func (d ResponseData) String() string

Constants

const (
	// netstring length for a 4194304 bytes payload.
	NS_MESSAGE_MAX_LEN = 4194308
	NS_PAYLOAD_MAX_LEN = 4194304
)

const (
	NativeJsonVersion = "3.9.0"
	NativeVersion     = "3.10.5"
)

const (
	ConsumerChannelFd        = 3 // read fd
	ProducerChannelFd        = 4 // write fd
	PayloadConsumerChannelFd = 5
	PayloadProducerChannelFd = 6
)

start from CustomerPipeStart

const (
	UNDEFINED = "undefined"
)

Functions

func ConvertRequestData

func ConvertRequestData(request *RequestData) error

func InitChannelHandlers

func InitChannelHandlers()

func RegisterHandler

func RegisterHandler(id string, h Handler)

func UnregisterHandler

func UnregisterHandler(id string)

Types

type Channel

type Channel struct {

	// handle request message
	OnRequestHandler atomic.Value // func(request RequestData) ResponseData
	// contains filtered or unexported fields
}

func NewChannel

func NewChannel(netParser netparser.INetParser, id string, jsonFormat bool) *Channel

func (*Channel) Close

func (c *Channel) Close()

func (*Channel) Event

func (c *Channel) Event(targetId int, event string)

func (*Channel) OnRequest

func (c *Channel) OnRequest(fn func(request RequestData) ResponseData)

type Handler

type Handler func(request RequestData, response *ResponseData)

func GetChannelRequestHandler

func GetChannelRequestHandler(id string) (Handler, error)

type InternalData

type InternalData struct {
	RouterId       string `json:"routerId,omitempty"`
	TransportId    string `json:"transportId,omitempty"`
	ProducerId     string `json:"producerId,omitempty"`
	ConsumerId     string `json:"consumerId,omitempty"`
	DataProducerId string `json:"dataProducerId,omitempty"`
	DataConsumerId string `json:"dataConsumerId,omitempty"`
	RtpObserverId  string `json:"rtpObserverId,omitempty"`
}

func (*InternalData) Unmarshal

func (i *InternalData) Unmarshal(data json.RawMessage) error

type PayloadChannel

type PayloadChannel struct {
}

func NewPayloadChannel

func NewPayloadChannel() *PayloadChannel

type RequestData

type RequestData struct {
	Method    string
	HandlerId string `json:"handlerId,omitempty"`
	Internal  InternalData
	Data      json.RawMessage
}

func (RequestData) String

func (d RequestData) String() string

type ResponseData

type ResponseData struct {
	Err  error
	Data json.RawMessage
}

func (ResponseData) String

func (d ResponseData) String() string