Versions in this module Expand all Collapse all v0 v0.0.2 Jul 17, 2023 v0.0.1 Jul 17, 2023 Changes in this version + type MessageProcessor struct + func (_m *MessageProcessor) MessageReceived(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope, ...) error + func (_m *MessageProcessor) Process(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope) error + type ServiceBinding struct + 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
Go to main page