runtime

Documentation

Index

• Constants
• type GolangRuntime
  • func (gr *GolangRuntime) ExecutePipeline(target interface{}, contentType string, edgexcontext *appcontext.Context, ...) *MessageError
  • func (gr *GolangRuntime) Initialize(storeClient dbInterfaces.StoreClient, secretProvider interfaces.SecretProvider)
  • func (gr *GolangRuntime) ProcessMessage(edgexcontext *appcontext.Context, envelope types.MessageEnvelope) *MessageError
  • func (gr *GolangRuntime) SetTransforms(transforms []appcontext.AppFunction)
  • func (gr *GolangRuntime) StartStoreAndForward(appWg *sync.WaitGroup, appCtx context.Context, enabledWg *sync.WaitGroup, ...)
• type MessageError

Constants

const (
	// TODO: Remove once completely switched over to V2 API DTOs
	ApiV1 = "v1"
	ApiV2 = "v2"
)

Types

type GolangRuntime

type GolangRuntime struct {
	TargetType interface{}
	ServiceKey string
	// contains filtered or unexported fields
}

GolangRuntime represents the golang runtime environment

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 dbInterfaces.StoreClient, secretProvider interfaces.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)

type MessageError

type MessageError struct {
	Err       error
	ErrorCode int
}