Versions in this module Expand all Collapse all v2 v2.0.1 Oct 5, 2021 Changes in this version + const AppServiceContextKey + const DEVICENAME + const DefaultPipelineId + const PIPELINEID + const PROFILENAME + const ProfileSuffixPlaceholder + const RECEIVEDTOPIC + const SOURCENAME + type AppFunction = func(appCxt AppFunctionContext, data interface{}) (bool, interface{}) + type AppFunctionContext interface + AddValue func(key string, value string) + ApplyValues func(format string) (string, error) + Clone func() AppFunctionContext + CommandClient func() interfaces.CommandClient + CorrelationID func() string + DeviceClient func() interfaces.DeviceClient + DeviceProfileClient func() interfaces.DeviceProfileClient + DeviceServiceClient func() interfaces.DeviceServiceClient + EventClient func() interfaces.EventClient + GetAllValues func() map[string]string + GetDeviceResource func(profileName string, resourceName string) (dtos.DeviceResource, error) + GetSecret func(path string, keys ...string) (map[string]string, error) + GetValue func(key string) (string, bool) + InputContentType func() string + LoggingClient func() logger.LoggingClient + NotificationClient func() interfaces.NotificationClient + PipelineId func() string + PushToCore func(event dtos.Event) (common.BaseWithIdResponse, error) + RemoveValue func(key string) + ResponseContentType func() string + ResponseData func() []byte + SecretsLastUpdated func() time.Time + SetResponseContentType func(string) + SetResponseData func(data []byte) + SetRetryData func(data []byte) + SubscriptionClient func() interfaces.SubscriptionClient + type ApplicationService interface + AddBackgroundPublisher func(capacity int) (BackgroundPublisher, error) + AddBackgroundPublisherWithTopic func(capacity int, topic string) (BackgroundPublisher, error) + AddFunctionsPipelineForTopics func(id string, topic []string, transforms ...AppFunction) error + AddRoute func(route string, handler func(http.ResponseWriter, *http.Request), ...) error + ApplicationSettings func() map[string]string + BuildContext func(correlationId string, contentType string) AppFunctionContext + CommandClient func() interfaces.CommandClient + DeviceClient func() interfaces.DeviceClient + DeviceProfileClient func() interfaces.DeviceProfileClient + DeviceServiceClient func() interfaces.DeviceServiceClient + EventClient func() interfaces.EventClient + GetAppSetting func(setting string) (string, error) + GetAppSettingStrings func(setting string) ([]string, error) + GetSecret func(path string, keys ...string) (map[string]string, error) + ListenForCustomConfigChanges func(configToWatch interface{}, sectionName string, ...) error + LoadConfigurableFunctionPipelines func() (map[string]FunctionPipeline, error) + LoadConfigurablePipeline func() ([]AppFunction, error) + LoadCustomConfig func(config UpdatableConfig, sectionName string) error + LoggingClient func() logger.LoggingClient + MakeItRun func() error + MakeItStop func() + NotificationClient func() interfaces.NotificationClient + RegisterCustomTriggerFactory func(name string, factory func(TriggerConfig) (Trigger, error)) error + RegistryClient func() registry.Client + SetDefaultFunctionsPipeline func(transforms ...AppFunction) error + SetFunctionsPipeline func(transforms ...AppFunction) error + StoreSecret func(path string, secretData map[string]string) error + SubscriptionClient func() interfaces.SubscriptionClient + type BackgroundMessage interface + Message func() types.MessageEnvelope + Topic func() string + type BackgroundPublisher interface + Publish func(payload []byte, context AppFunctionContext) error + type FunctionPipeline struct + Hash string + Id string + Topics []string + Transforms []AppFunction + type Trigger interface + Initialize func(wg *sync.WaitGroup, ctx context.Context, background <-chan BackgroundMessage) (bootstrap.Deferred, error) + type TriggerConfig struct + ConfigLoader TriggerConfigLoader + ContextBuilder TriggerContextBuilder + Logger logger.LoggingClient + MessageProcessor TriggerMessageProcessor + type TriggerConfigLoader func(config UpdatableConfig, sectionName string) error + type TriggerContextBuilder func(env types.MessageEnvelope) AppFunctionContext + type TriggerMessageProcessor func(ctx AppFunctionContext, envelope types.MessageEnvelope) error + type UpdatableConfig interface
Go to main page