Versions in this module Expand all Collapse all v4 v4.0.0 Apr 3, 2025 Changes in this version + type MessageProcessor struct + func NewMessageProcessor(t mockConstructorTestingTNewMessageProcessor) *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 ServiceBinding struct + func NewServiceBinding(t mockConstructorTestingTNewServiceBinding) *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 Other modules containing this package github.com/agile-edge/app-functions-sdk-go/v3