Documentation ¶
Overview ¶
Code generated by mockery 2.7.4.
Index ¶
- type IDataChannel
- func (_m *IDataChannel) AddDataToIncomingMessageBuffer(streamMessage datachannel.StreamingMessage)
- func (_m *IDataChannel) AddDataToOutgoingMessageBuffer(streamMessage datachannel.StreamingMessage)
- func (_m *IDataChannel) Close(_a0 log.T) error
- func (_m *IDataChannel) GetClientVersion() string
- func (_m *IDataChannel) GetInstanceId() string
- func (_m *IDataChannel) GetRegion() string
- func (_m *IDataChannel) GetSeparateOutputPayload() bool
- func (_m *IDataChannel) Initialize(_a0 context.T, mgsService service.Service, sessionId string, clientId string, ...)
- func (_m *IDataChannel) IsActive() bool
- func (_m *IDataChannel) Open(_a0 log.T) error
- func (_m *IDataChannel) PerformHandshake(_a0 log.T, kmsKeyId string, encryptionEnabled bool, ...) error
- func (_m *IDataChannel) PrepareToCloseChannel(_a0 log.T)
- func (_m *IDataChannel) ProcessAcknowledgedMessage(_a0 log.T, acknowledgeMessageContent contracts.AcknowledgeContent)
- func (_m *IDataChannel) Reconnect(_a0 log.T) error
- 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, agentMessage contracts.AgentMessage) error
- func (_m *IDataChannel) SendAgentSessionStateMessage(_a0 log.T, sessionStatus contracts.SessionStatus) error
- func (_m *IDataChannel) SendMessage(_a0 log.T, input []byte, inputType int) error
- func (_m *IDataChannel) SendStreamDataMessage(_a0 log.T, dataType contracts.PayloadType, inputData []byte) error
- func (_m *IDataChannel) SetSeparateOutputPayload(separateOutputPayload bool)
- func (_m *IDataChannel) SetWebSocket(_a0 context.T, mgsService service.Service, sessionId string, clientId string, ...) error
- func (_m *IDataChannel) SkipHandshake(_a0 log.T)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IDataChannel ¶
IDataChannel is an autogenerated mock type for the IDataChannel type
func (*IDataChannel) AddDataToIncomingMessageBuffer ¶
func (_m *IDataChannel) AddDataToIncomingMessageBuffer(streamMessage datachannel.StreamingMessage)
AddDataToIncomingMessageBuffer provides a mock function with given fields: streamMessage
func (*IDataChannel) AddDataToOutgoingMessageBuffer ¶
func (_m *IDataChannel) AddDataToOutgoingMessageBuffer(streamMessage datachannel.StreamingMessage)
AddDataToOutgoingMessageBuffer provides a mock function with given fields: streamMessage
func (*IDataChannel) Close ¶
func (_m *IDataChannel) Close(_a0 log.T) error
Close provides a mock function with given fields: _a0
func (*IDataChannel) GetClientVersion ¶
func (_m *IDataChannel) GetClientVersion() string
GetClientVersion provides a mock function with given fields:
func (*IDataChannel) GetInstanceId ¶
func (_m *IDataChannel) GetInstanceId() string
GetInstanceId provides a mock function with given fields:
func (*IDataChannel) GetRegion ¶
func (_m *IDataChannel) GetRegion() string
GetRegion provides a mock function with given fields:
func (*IDataChannel) GetSeparateOutputPayload ¶
func (_m *IDataChannel) GetSeparateOutputPayload() bool
GetSeparateOutputPayload provides a mock function with given fields:
func (*IDataChannel) Initialize ¶
func (_m *IDataChannel) Initialize(_a0 context.T, mgsService service.Service, sessionId string, clientId string, instanceId string, role string, cancelFlag task.CancelFlag, inputStreamMessageHandler datachannel.InputStreamMessageHandler)
Initialize provides a mock function with given fields: _a0, mgsService, sessionId, clientId, instanceId, role, cancelFlag, inputStreamMessageHandler
func (*IDataChannel) IsActive ¶
func (_m *IDataChannel) IsActive() bool
IsActive provides a mock function with given fields:
func (*IDataChannel) Open ¶
func (_m *IDataChannel) Open(_a0 log.T) error
Open provides a mock function with given fields: _a0
func (*IDataChannel) PerformHandshake ¶
func (_m *IDataChannel) PerformHandshake(_a0 log.T, kmsKeyId string, encryptionEnabled bool, sessionTypeRequest contracts.SessionTypeRequest) error
PerformHandshake provides a mock function with given fields: _a0, kmsKeyId, encryptionEnabled, sessionTypeRequest
func (*IDataChannel) PrepareToCloseChannel ¶
func (_m *IDataChannel) PrepareToCloseChannel(_a0 log.T)
PrepareToCloseChannel provides a mock function with given fields: _a0
func (*IDataChannel) ProcessAcknowledgedMessage ¶
func (_m *IDataChannel) ProcessAcknowledgedMessage(_a0 log.T, acknowledgeMessageContent contracts.AcknowledgeContent)
ProcessAcknowledgedMessage provides a mock function with given fields: _a0, acknowledgeMessageContent
func (*IDataChannel) Reconnect ¶
func (_m *IDataChannel) Reconnect(_a0 log.T) error
Reconnect provides a mock function with given fields: _a0
func (*IDataChannel) RemoveDataFromIncomingMessageBuffer ¶
func (_m *IDataChannel) RemoveDataFromIncomingMessageBuffer(sequenceNumber int64)
RemoveDataFromIncomingMessageBuffer provides a mock function with given fields: sequenceNumber
func (*IDataChannel) RemoveDataFromOutgoingMessageBuffer ¶
func (_m *IDataChannel) RemoveDataFromOutgoingMessageBuffer(streamMessageElement *list.Element)
RemoveDataFromOutgoingMessageBuffer provides a mock function with given fields: streamMessageElement
func (*IDataChannel) ResendStreamDataMessageScheduler ¶
func (_m *IDataChannel) ResendStreamDataMessageScheduler(_a0 log.T) error
ResendStreamDataMessageScheduler provides a mock function with given fields: _a0
func (*IDataChannel) SendAcknowledgeMessage ¶
func (_m *IDataChannel) SendAcknowledgeMessage(_a0 log.T, agentMessage contracts.AgentMessage) error
SendAcknowledgeMessage provides a mock function with given fields: _a0, agentMessage
func (*IDataChannel) SendAgentSessionStateMessage ¶
func (_m *IDataChannel) SendAgentSessionStateMessage(_a0 log.T, sessionStatus contracts.SessionStatus) error
SendAgentSessionStateMessage provides a mock function with given fields: _a0, sessionStatus
func (*IDataChannel) SendMessage ¶
SendMessage provides a mock function with given fields: _a0, input, inputType
func (*IDataChannel) SendStreamDataMessage ¶
func (_m *IDataChannel) SendStreamDataMessage(_a0 log.T, dataType contracts.PayloadType, inputData []byte) error
SendStreamDataMessage provides a mock function with given fields: _a0, dataType, inputData
func (*IDataChannel) SetSeparateOutputPayload ¶
func (_m *IDataChannel) SetSeparateOutputPayload(separateOutputPayload bool)
SetSeparateOutputPayload provides a mock function with given fields: separateOutputPayload
func (*IDataChannel) SetWebSocket ¶
func (_m *IDataChannel) SetWebSocket(_a0 context.T, mgsService service.Service, sessionId string, clientId string, onMessageHandler func([]byte)) error
SetWebSocket provides a mock function with given fields: _a0, mgsService, sessionId, clientId, onMessageHandler
func (*IDataChannel) SkipHandshake ¶
func (_m *IDataChannel) SkipHandshake(_a0 log.T)
SkipHandshake provides a mock function with given fields: _a0