mocks

Documentation

Index

• type IDataChannel
  • func NewIDataChannel(t interface{ ... }) *IDataChannel
  • 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, region string, ...)
  • func (_m *IDataChannel) SetWsChannel(wsChannel communicator.IWebSocketChannel)

Types

type IDataChannel

type IDataChannel struct {
	mock.Mock
}

IDataChannel is an autogenerated mock type for the IDataChannel type

func NewIDataChannel

func NewIDataChannel(t interface {
	mock.TestingT
	Cleanup(func())
}) *IDataChannel

NewIDataChannel creates a new instance of IDataChannel. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

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) CalculateRetransmissionTimeout

func (_m *IDataChannel) CalculateRetransmissionTimeout(_a0 log.T, streamingMessage datachannel.StreamingMessage)

CalculateRetransmissionTimeout provides a mock function with given fields: _a0, streamingMessage

func (*IDataChannel) Close

func (_m *IDataChannel) Close(_a0 log.T) error

Close provides a mock function with given fields: _a0

func (*IDataChannel) DeregisterOutputStreamHandler

func (_m *IDataChannel) DeregisterOutputStreamHandler(handler datachannel.OutputStreamDataMessageHandler)

DeregisterOutputStreamHandler provides a mock function with given fields: handler

func (*IDataChannel) FinalizeDataChannelHandshake

func (_m *IDataChannel) FinalizeDataChannelHandshake(_a0 log.T, tokenValue string) error

FinalizeDataChannelHandshake provides a mock function with given fields: _a0, tokenValue

func (*IDataChannel) GetAgentVersion

func (_m *IDataChannel) GetAgentVersion() string

GetAgentVersion provides a mock function with given fields:

func (*IDataChannel) GetSessionProperties

func (_m *IDataChannel) GetSessionProperties() interface{}

GetSessionProperties provides a mock function with given fields:

func (*IDataChannel) GetSessionType

func (_m *IDataChannel) GetSessionType() string

GetSessionType provides a mock function with given fields:

func (*IDataChannel) GetStreamDataSequenceNumber

func (_m *IDataChannel) GetStreamDataSequenceNumber() int64

GetStreamDataSequenceNumber provides a mock function with given fields:

func (*IDataChannel) GetWsChannel

func (_m *IDataChannel) GetWsChannel() communicator.IWebSocketChannel

GetWsChannel provides a mock function with given fields:

func (*IDataChannel) Initialize

func (_m *IDataChannel) Initialize(_a0 log.T, clientId string, sessionId string, targetId string, isAwsCliUpgradeNeeded bool)

Initialize provides a mock function with given fields: _a0, clientId, sessionId, targetId, isAwsCliUpgradeNeeded

func (*IDataChannel) IsSessionTypeSet

func (_m *IDataChannel) IsSessionTypeSet() chan bool

IsSessionTypeSet provides a mock function with given fields:

func (*IDataChannel) IsStreamMessageResendTimeout

func (_m *IDataChannel) IsStreamMessageResendTimeout() chan bool

IsStreamMessageResendTimeout 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) OutputMessageHandler

func (_m *IDataChannel) OutputMessageHandler(_a0 log.T, stopHandler datachannel.Stop, sessionID string, rawMessage []byte) error

OutputMessageHandler provides a mock function with given fields: _a0, stopHandler, sessionID, rawMessage

func (*IDataChannel) ProcessAcknowledgedMessage

func (_m *IDataChannel) ProcessAcknowledgedMessage(_a0 log.T, acknowledgeMessageContent message.AcknowledgeContent) error

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) RegisterOutputStreamHandler

func (_m *IDataChannel) RegisterOutputStreamHandler(handler datachannel.OutputStreamDataMessageHandler, isSessionSpecificHandler bool)

RegisterOutputStreamHandler provides a mock function with given fields: handler, isSessionSpecificHandler

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, clientMessage message.ClientMessage) error

SendAcknowledgeMessage provides a mock function with given fields: _a0, clientMessage

func (*IDataChannel) SendFlag

func (_m *IDataChannel) SendFlag(_a0 log.T, flagType message.PayloadTypeFlag) error

SendFlag provides a mock function with given fields: _a0, flagType

func (*IDataChannel) SendInputDataMessage

func (_m *IDataChannel) SendInputDataMessage(_a0 log.T, payloadType message.PayloadType, inputData []byte) error

SendInputDataMessage provides a mock function with given fields: _a0, payloadType, inputData

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) SetAgentVersion

func (_m *IDataChannel) SetAgentVersion(agentVersion string)

SetAgentVersion provides a mock function with given fields: agentVersion

func (*IDataChannel) SetSessionType

func (_m *IDataChannel) SetSessionType(sessionType string)

SetSessionType provides a mock function with given fields: sessionType

func (*IDataChannel) SetWebsocket

func (_m *IDataChannel) SetWebsocket(_a0 log.T, streamUrl string, tokenValue string, region string, signer *v4.Signer)

SetWebsocket provides a mock function with given fields: _a0, streamUrl, tokenValue, region, signer

func (*IDataChannel) SetWsChannel

func (_m *IDataChannel) SetWsChannel(wsChannel communicator.IWebSocketChannel)

SetWsChannel provides a mock function with given fields: wsChannel