trigger

Documentation

Index

• type MessageProcessor
• type ServiceBinding

Types

type MessageProcessor

type MessageProcessor interface {
	// Process provides runtime orchestration to pass the envelope / context to the pipeline.
	// Deprecated: will throw if multiple pipelines are configured for a message.  Use MessageReceived.
	Process(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope) error
	// MessageReceived provides runtime orchestration to pass the envelope / context to configured pipeline(s)
	MessageReceived(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope, outputHandler interfaces.PipelineResponseHandler) error
}

type ServiceBinding

type ServiceBinding interface {
	// ProcessMessage provides access to the runtime's ProcessMessage function
	ProcessMessage(appContext *appfunction.Context, envelope types.MessageEnvelope, pipeline *interfaces.FunctionPipeline) *runtime.MessageError
	// GetMatchingPipelines provides access to the runtime's GetMatchingPipelines function
	GetMatchingPipelines(incomingTopic string) []*interfaces.FunctionPipeline
	// BuildContext creates a context for a given message envelope
	BuildContext(env types.MessageEnvelope) interfaces.AppFunctionContext
	// SecretProvider provides access to this service's secret provider for the trigger
	SecretProvider() messaging.SecretDataProvider
	// Config provides access to this service's configuration for the trigger
	Config() *common.ConfigurationStruct
	// LoggingClient provides access to this service's logging clietn for the trigger
	LoggingClient() logger.LoggingClient
	// LoadCustomConfig provides access to the service's LoadCustomConfig function
	LoadCustomConfig(config interfaces.UpdatableConfig, sectionName string) error
}