mocks

Documentation

Index

• type MessageProcessor
  • func NewMessageProcessor(t NewMessageProcessorT) *MessageProcessor
  • func (_m *MessageProcessor) MessageReceived(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope, ...) error
  • func (_m *MessageProcessor) Process(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope) error
  • func (_m *MessageProcessor) ReceivedInvalidMessage()
• type NewMessageProcessorT
• type NewServiceBindingT
• type ServiceBinding
  • func NewServiceBinding(t NewServiceBindingT) *ServiceBinding
  • func (_m *ServiceBinding) BuildContext(env types.MessageEnvelope) interfaces.AppFunctionContext
  • func (_m *ServiceBinding) Config() *common.ConfigurationStruct
  • func (_m *ServiceBinding) DecodeMessage(appContext *appfunction.Context, envelope types.MessageEnvelope) (interface{}, *runtime.MessageError, bool)
  • func (_m *ServiceBinding) GetDefaultPipeline() *interfaces.FunctionPipeline
  • func (_m *ServiceBinding) GetMatchingPipelines(incomingTopic string) []*interfaces.FunctionPipeline
  • func (_m *ServiceBinding) LoadCustomConfig(config interfaces.UpdatableConfig, sectionName string) error
  • func (_m *ServiceBinding) LoggingClient() logger.LoggingClient
  • func (_m *ServiceBinding) ProcessMessage(appContext *appfunction.Context, data interface{}, ...) *runtime.MessageError
  • func (_m *ServiceBinding) SecretProvider() messaging.SecretDataProvider

Types

type MessageProcessor

type MessageProcessor struct {
	mock.Mock
}

MessageProcessor is an autogenerated mock type for the MessageProcessor type

func NewMessageProcessor

func NewMessageProcessor(t NewMessageProcessorT) *MessageProcessor

NewMessageProcessor creates a new instance of MessageProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MessageProcessor) MessageReceived

func (_m *MessageProcessor) MessageReceived(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope, outputHandler interfaces.PipelineResponseHandler) error

MessageReceived provides a mock function with given fields: ctx, envelope, outputHandler

func (*MessageProcessor) Process

func (_m *MessageProcessor) Process(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope) error

Process provides a mock function with given fields: ctx, envelope

func (*MessageProcessor) ReceivedInvalidMessage

func (_m *MessageProcessor) ReceivedInvalidMessage()

ReceivedInvalidMessage provides a mock function with given fields:

type NewMessageProcessorT

type NewMessageProcessorT interface {
	mock.TestingT
	Cleanup(func())
}

type NewServiceBindingT

type NewServiceBindingT interface {
	mock.TestingT
	Cleanup(func())
}

type ServiceBinding

type ServiceBinding struct {
	mock.Mock
}

ServiceBinding is an autogenerated mock type for the ServiceBinding type

func NewServiceBinding

func NewServiceBinding(t NewServiceBindingT) *ServiceBinding

NewServiceBinding creates a new instance of ServiceBinding. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ServiceBinding) BuildContext

func (_m *ServiceBinding) BuildContext(env types.MessageEnvelope) interfaces.AppFunctionContext

BuildContext provides a mock function with given fields: env

func (*ServiceBinding) Config

func (_m *ServiceBinding) Config() *common.ConfigurationStruct

Config provides a mock function with given fields:

func (*ServiceBinding) DecodeMessage

func (_m *ServiceBinding) DecodeMessage(appContext *appfunction.Context, envelope types.MessageEnvelope) (interface{}, *runtime.MessageError, bool)

DecodeMessage provides a mock function with given fields: appContext, envelope

func (*ServiceBinding) GetDefaultPipeline

func (_m *ServiceBinding) GetDefaultPipeline() *interfaces.FunctionPipeline

GetDefaultPipeline provides a mock function with given fields:

func (*ServiceBinding) GetMatchingPipelines

func (_m *ServiceBinding) GetMatchingPipelines(incomingTopic string) []*interfaces.FunctionPipeline

GetMatchingPipelines provides a mock function with given fields: incomingTopic

func (*ServiceBinding) LoadCustomConfig

func (_m *ServiceBinding) LoadCustomConfig(config interfaces.UpdatableConfig, sectionName string) error

LoadCustomConfig provides a mock function with given fields: config, sectionName

func (*ServiceBinding) LoggingClient

func (_m *ServiceBinding) LoggingClient() logger.LoggingClient

LoggingClient provides a mock function with given fields:

func (*ServiceBinding) ProcessMessage

func (_m *ServiceBinding) ProcessMessage(appContext *appfunction.Context, data interface{}, pipeline *interfaces.FunctionPipeline) *runtime.MessageError

ProcessMessage provides a mock function with given fields: appContext, data, pipeline

func (*ServiceBinding) SecretProvider

func (_m *ServiceBinding) SecretProvider() messaging.SecretDataProvider

SecretProvider provides a mock function with given fields: