mocks

Documentation

Index

• type MessageProcessor
  • func (_m *MessageProcessor) MessageReceived(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope, ...) error
  • func (_m *MessageProcessor) Process(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope) error
• type ServiceBinding
  • func (_m *ServiceBinding) BuildContext(env types.MessageEnvelope) interfaces.AppFunctionContext
  • func (_m *ServiceBinding) Config() *common.ConfigurationStruct
  • 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, envelope types.MessageEnvelope, ...) *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 (*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

type ServiceBinding

type ServiceBinding struct {
	mock.Mock
}

ServiceBinding is an autogenerated mock type for the ServiceBinding type

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) 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, envelope types.MessageEnvelope, pipeline *interfaces.FunctionPipeline) *runtime.MessageError

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

func (*ServiceBinding) SecretProvider

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

SecretProvider provides a mock function with given fields: