Versions in this module Expand all Collapse all v1 v1.3.1 Jan 3, 2024 v1.3.0 Jan 3, 2024 Changes in this version + type IDataChannel struct + func (_m *IDataChannel) AddDataToIncomingMessageBuffer(streamMessage datachannel.StreamingMessage) + func (_m *IDataChannel) AddDataToOutgoingMessageBuffer(streamMessage datachannel.StreamingMessage) + func (_m *IDataChannel) CalculateRetransmissionTimeout(_a0 log.T, streamingMessage datachannel.StreamingMessage) + func (_m *IDataChannel) Close(_a0 log.T) error + func (_m *IDataChannel) DeregisterOutputStreamHandler(handler datachannel.OutputStreamDataMessageHandler) + func (_m *IDataChannel) FinalizeDataChannelHandshake(_a0 log.T, tokenValue string) error + func (_m *IDataChannel) GetAgentVersion() string + func (_m *IDataChannel) GetSessionProperties() interface{} + func (_m *IDataChannel) GetSessionType() string + func (_m *IDataChannel) GetStreamDataSequenceNumber() int64 + func (_m *IDataChannel) GetWsChannel() communicator.IWebSocketChannel + func (_m *IDataChannel) Initialize(_a0 log.T, clientId string, sessionId string, targetId string, ...) + func (_m *IDataChannel) IsSessionTypeSet() chan bool + func (_m *IDataChannel) IsStreamMessageResendTimeout() chan bool + func (_m *IDataChannel) Open(_a0 log.T) error + func (_m *IDataChannel) OutputMessageHandler(_a0 log.T, stopHandler datachannel.Stop, sessionID string, rawMessage []byte) error + func (_m *IDataChannel) ProcessAcknowledgedMessage(_a0 log.T, acknowledgeMessageContent message.AcknowledgeContent) error + func (_m *IDataChannel) Reconnect(_a0 log.T) error + func (_m *IDataChannel) RegisterOutputStreamHandler(handler datachannel.OutputStreamDataMessageHandler, ...) + func (_m *IDataChannel) RemoveDataFromIncomingMessageBuffer(sequenceNumber int64) + func (_m *IDataChannel) RemoveDataFromOutgoingMessageBuffer(streamMessageElement *list.Element) + func (_m *IDataChannel) ResendStreamDataMessageScheduler(_a0 log.T) error + func (_m *IDataChannel) SendAcknowledgeMessage(_a0 log.T, clientMessage message.ClientMessage) error + func (_m *IDataChannel) SendFlag(_a0 log.T, flagType message.PayloadTypeFlag) error + func (_m *IDataChannel) SendInputDataMessage(_a0 log.T, payloadType message.PayloadType, inputData []byte) error + func (_m *IDataChannel) SendMessage(_a0 log.T, input []byte, inputType int) error + func (_m *IDataChannel) SetAgentVersion(agentVersion string) + func (_m *IDataChannel) SetSessionType(sessionType string) + func (_m *IDataChannel) SetWebsocket(_a0 log.T, streamUrl string, tokenValue string) + func (_m *IDataChannel) SetWsChannel(wsChannel communicator.IWebSocketChannel)
Go to main page