Versions in this module Expand all Collapse all v3 v3.2.0 Dec 3, 2024 Changes in this version + const TopicLevelSeparator + const TopicSingleLevelWildcard + const TopicWildCard + func NewFunctionPipeline(id string, topics []string, transforms []interfaces.AppFunction) interfaces.FunctionPipeline + type FunctionsPipelineRuntime struct + ServiceKey string + TargetType interface{} + func NewFunctionPipelineRuntime(serviceKey string, targetType interface{}, dic *di.Container) *FunctionsPipelineRuntime + func (fpr *FunctionsPipelineRuntime) AddFunctionsPipeline(id string, topics []string, transforms []interfaces.AppFunction) error + func (fpr *FunctionsPipelineRuntime) ClearAllFunctionsPipelineTransforms() + func (fpr *FunctionsPipelineRuntime) DecodeMessage(appContext *appfunction.Context, envelope types.MessageEnvelope) (interface{}, *MessageError, bool) + func (fpr *FunctionsPipelineRuntime) ExecutePipeline(target interface{}, appContext *appfunction.Context, ...) *MessageError + func (fpr *FunctionsPipelineRuntime) GetDefaultPipeline() *interfaces.FunctionPipeline + func (fpr *FunctionsPipelineRuntime) GetMatchingPipelines(incomingTopic string) []*interfaces.FunctionPipeline + func (fpr *FunctionsPipelineRuntime) GetPipelineById(id string) *interfaces.FunctionPipeline + func (fpr *FunctionsPipelineRuntime) ProcessMessage(appContext *appfunction.Context, target interface{}, ...) *MessageError + func (fpr *FunctionsPipelineRuntime) RemoveAllFunctionPipelines() + func (fpr *FunctionsPipelineRuntime) SetDefaultFunctionsPipeline(transforms []interfaces.AppFunction) + func (fpr *FunctionsPipelineRuntime) SetFunctionsPipelineTopics(id string, topics []string) + func (fpr *FunctionsPipelineRuntime) SetFunctionsPipelineTransforms(id string, transforms []interfaces.AppFunction) + func (fpr *FunctionsPipelineRuntime) StartStoreAndForward(appWg *sync.WaitGroup, appCtx context.Context, enabledWg *sync.WaitGroup, ...) + type MessageError struct + Err error + ErrorCode int + func (merr *MessageError) Error() string Other modules containing this package git.buildlinx.io/buildlinx/edgelinx/go-libs/app-functions-sdk-go/v4
Go to main page