Versions in this module Expand all Collapse all v2 v2.0.1 Oct 5, 2021 Changes in this version + const TopicLevelSeparator + const TopicWildCard + func NewFunctionPipeline(id string, topics []string, transforms []interfaces.AppFunction) interfaces.FunctionPipeline + type GolangRuntime struct + ServiceKey string + TargetType interface{} + func NewGolangRuntime(serviceKey string, targetType interface{}, dic *di.Container) *GolangRuntime + func (gr *GolangRuntime) AddFunctionsPipeline(id string, topics []string, transforms []interfaces.AppFunction) error + func (gr *GolangRuntime) ExecutePipeline(target interface{}, contentType string, appContext *appfunction.Context, ...) *MessageError + func (gr *GolangRuntime) GetDefaultPipeline() *interfaces.FunctionPipeline + func (gr *GolangRuntime) GetMatchingPipelines(incomingTopic string) []*interfaces.FunctionPipeline + func (gr *GolangRuntime) GetPipelineById(id string) *interfaces.FunctionPipeline + func (gr *GolangRuntime) ProcessMessage(appContext *appfunction.Context, envelope types.MessageEnvelope, ...) *MessageError + func (gr *GolangRuntime) SetDefaultFunctionsPipeline(transforms []interfaces.AppFunction) error + func (gr *GolangRuntime) StartStoreAndForward(appWg *sync.WaitGroup, appCtx context.Context, enabledWg *sync.WaitGroup, ...) + type MessageError struct + Err error + ErrorCode int
Go to main page