runtime

func (*GolangRuntime) ExecutePipeline ¶

func (gr *GolangRuntime) ExecutePipeline(target interface{}, contentType string, edgexcontext *appcontext.Context,
	transforms []appcontext.AppFunction, startPosition int, isRetry bool) *MessageError

func (*GolangRuntime) Initialize ¶

func (gr *GolangRuntime) Initialize(storeClient interfaces.StoreClient, secretProvider *security.SecretProvider)

Initialize sets the internal reference to the StoreClient for use when Store and Forward is enabled

func (*GolangRuntime) ProcessMessage ¶

func (gr *GolangRuntime) ProcessMessage(edgexcontext *appcontext.Context, envelope types.MessageEnvelope) *MessageError

ProcessMessage sends the contents of the message thru the functions pipeline

func (*GolangRuntime) SetTransforms ¶

func (gr *GolangRuntime) SetTransforms(transforms []appcontext.AppFunction)

SetTransforms is thread safe to set transforms

func (*GolangRuntime) StartStoreAndForward ¶

func (gr *GolangRuntime) StartStoreAndForward(
	appWg *sync.WaitGroup,
	appCtx context.Context,
	enabledWg *sync.WaitGroup,
	enabledCtx context.Context,
	serviceKey string,
	config *common.ConfigurationStruct,
	edgeXClients common.EdgeXClients)