Versions in this module Expand all Collapse all v2 v2.3.2 Jul 6, 2023 Changes in this version + const Algorithm + const AuthMode + const AutoReconnect + const BatchByCount + const BatchByTime + const BatchByTimeAndCount + const BatchThreshold + const BrokerAddress + const ClientID + const CompressGZIP + const CompressZLIB + const ConnectTimeout + const ContinueOnSendError + const DeviceName + const DeviceNames + const EncryptAES + const EncryptAES256 + const EncryptionKey + const ExportMethod + const ExportMethodPost + const ExportMethodPut + const FilterOut + const HeaderName + const InitVector + const IsEventData + const KeepAlive + const MediaType + const MergeOnSend + const MimeType + const Mode + const PersistOnError + const ProfileName + const ProfileNames + const Qos + const ResourceName + const ResourceNames + const ResponseContentType + const Retain + const ReturnInputData + const Rule + const SecretName + const SecretPath + const SkipVerify + const SourceNames + const Tags + const TimeInterval + const Topic + const TransformJson + const TransformType + const TransformXml + const TriggerTypeHTTP + const TriggerTypeMQTT + const TriggerTypeMessageBus + const Url + const ValueType + func NewTriggerMessageProcessor(bnd trigger.ServiceBinding, metricsManager bootstrapInterfaces.MetricsManager) *triggerMessageProcessor + func NewTriggerServiceBinding(svc *Service) trigger.ServiceBinding + type BackgroundMessage struct + Payload types.MessageEnvelope + PublishTopic string + func (bg BackgroundMessage) Message() types.MessageEnvelope + func (bg BackgroundMessage) Topic() string + type ConfigUpdateProcessor struct + func NewConfigUpdateProcessor(svc *Service) *ConfigUpdateProcessor + func (processor *ConfigUpdateProcessor) WaitForConfigUpdates(configUpdated config.UpdatedStream) + type Configurable struct + func NewConfigurable(lc logger.LoggingClient) *Configurable + func (app *Configurable) AddTags(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) Batch(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) Compress(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) Encrypt(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) FilterByDeviceName(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) FilterByProfileName(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) FilterByResourceName(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) FilterBySourceName(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) HTTPExport(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) JSONLogic(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) MQTTExport(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) PushToCore(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) SetResponseData(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) ToLineProtocol(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) Transform(parameters map[string]string) interfaces.AppFunction + func (app *Configurable) WrapIntoEvent(parameters map[string]string) interfaces.AppFunction + type Service struct + func NewService(serviceKey string, targetType interface{}, profileSuffixPlaceholder string) *Service + func (svc *Service) AddBackgroundPublisher(capacity int) (interfaces.BackgroundPublisher, error) + func (svc *Service) AddBackgroundPublisherWithTopic(capacity int, topic string) (interfaces.BackgroundPublisher, error) + func (svc *Service) AddFunctionsPipelineForTopics(id string, topics []string, transforms ...interfaces.AppFunction) error + func (svc *Service) AddRoute(route string, handler func(nethttp.ResponseWriter, *nethttp.Request), ...) error + func (svc *Service) ApplicationSettings() map[string]string + func (svc *Service) BuildContext(correlationId string, contentType string) interfaces.AppFunctionContext + func (svc *Service) CommandClient() clientInterfaces.CommandClient + func (svc *Service) DeviceClient() clientInterfaces.DeviceClient + func (svc *Service) DeviceProfileClient() clientInterfaces.DeviceProfileClient + func (svc *Service) DeviceServiceClient() clientInterfaces.DeviceServiceClient + func (svc *Service) EventClient() clientInterfaces.EventClient + func (svc *Service) GetAppSetting(setting string) (string, error) + func (svc *Service) GetAppSettingStrings(setting string) ([]string, error) + func (svc *Service) GetSecret(path string, keys ...string) (map[string]string, error) + func (svc *Service) Initialize() error + func (svc *Service) ListenForCustomConfigChanges(configToWatch interface{}, sectionName string, ...) error + func (svc *Service) LoadConfigurableFunctionPipelines() (map[string]interfaces.FunctionPipeline, error) + func (svc *Service) LoadConfigurablePipeline() ([]interfaces.AppFunction, error) + func (svc *Service) LoadCustomConfig(customConfig interfaces.UpdatableConfig, sectionName string) error + func (svc *Service) LoggingClient() logger.LoggingClient + func (svc *Service) MakeItRun() error + func (svc *Service) MakeItStop() + func (svc *Service) MetricsManager() bootstrapInterfaces.MetricsManager + func (svc *Service) NotificationClient() clientInterfaces.NotificationClient + func (svc *Service) RegisterCustomStoreFactory(name string, ...) error + func (svc *Service) RegisterCustomTriggerFactory(name string, ...) error + func (svc *Service) RegistryClient() registry.Client + func (svc *Service) RequestTimeout() time.Duration + func (svc *Service) SecretProvider() bootstrapInterfaces.SecretProvider + func (svc *Service) SetDefaultFunctionsPipeline(transforms ...interfaces.AppFunction) error + func (svc *Service) SetFunctionsPipeline(transforms ...interfaces.AppFunction) error + func (svc *Service) StoreSecret(path string, secretData map[string]string) error + func (svc *Service) SubscriptionClient() clientInterfaces.SubscriptionClient
Go to main page