workerchannel

Nov 10, 2022

Changes in this version

+ const ConsumerChannelFd

+ const NativeJsonVersion

+ const NativeVersion

+ const PayloadConsumerChannelFd

+ const PayloadProducerChannelFd

+ const ProducerChannelFd

+ func ConvertRequestData(request *RequestData) error

+ func InitChannelHandlers()

+ func RegisterHandler(id string, h Handler)

+ func UnregisterHandler(id string)

+ type Handler func(request RequestData, response *ResponseData)

+ func GetChannelRequestHandler(id string) (Handler, error)

type RequestData

+ HandlerId string

Sep 4, 2022

Changes in this version

+ const UNDEFINED

Apr 8, 2022

Changes in this version

+ const NS_MESSAGE_MAX_LEN

+ const NS_PAYLOAD_MAX_LEN

+ type Channel struct

+ OnRequestHandler atomic.Value

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

+ func (c *Channel) Close()

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

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

+ type InternalData struct

+ ConsumerId string

+ DataConsumerId string

+ DataProducerId string

+ ProducerId string

+ RouterId string

+ RtpObserverId string

+ TransportId string

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

+ type PayloadChannel struct

+ func NewPayloadChannel() *PayloadChannel

+ type RequestData struct

+ Data json.RawMessage

+ Internal InternalData

+ Method string

+ func (d RequestData) String() string

+ type ResponseData struct

+ Data json.RawMessage

+ Err error

+ func (d ResponseData) String() string