runtime

Documentation

Index

• type GolangRuntime
  • func (gr *GolangRuntime) ProcessMessage(edgexcontext *appcontext.Context, envelope types.MessageEnvelope) *MessageError
  • func (gr *GolangRuntime) SetTransforms(transforms []appcontext.AppFunction)
• type MessageError

Types

type GolangRuntime

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

GolangRuntime represents the golang runtime environment

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

type MessageError

type MessageError struct {
	Err       error
	ErrorCode int
}