mocks

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)

Types

type IDataChannel

type IDataChannel struct {
	mock.Mock
}

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

func (_m *IDataChannel) SendMessage(_a0 log.T, input []byte, inputType int) error

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