runtime

Documentation

Index

• type GolangRuntime
  • func (gr *GolangRuntime) ExecutePipeline(target interface{}, contentType string, appContext *appfunction.Context, ...) *MessageError
  • func (gr *GolangRuntime) Initialize(dic *di.Container)
  • func (gr *GolangRuntime) ProcessMessage(appContext *appfunction.Context, envelope types.MessageEnvelope) *MessageError
  • func (gr *GolangRuntime) SetTransforms(transforms []interfaces.AppFunction)
  • func (gr *GolangRuntime) StartStoreAndForward(appWg *sync.WaitGroup, appCtx context.Context, enabledWg *sync.WaitGroup, ...)
• type MessageError

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,
	appContext *appfunction.Context,
	transforms []interfaces.AppFunction,
	startPosition int,
	isRetry bool) *MessageError

func (*GolangRuntime) Initialize

func (gr *GolangRuntime) Initialize(dic *di.Container)

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

func (*GolangRuntime) ProcessMessage

func (gr *GolangRuntime) ProcessMessage(appContext *appfunction.Context, envelope types.MessageEnvelope) *MessageError

ProcessMessage sends the contents of the message thru the functions pipeline

func (*GolangRuntime) SetTransforms

func (gr *GolangRuntime) SetTransforms(transforms []interfaces.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)

type MessageError

type MessageError struct {
	Err       error
	ErrorCode int
}