Versions in this module Expand all Collapse all v4 v4.0.0 Apr 3, 2025 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 EncryptAES256 + const EncryptionKey + const ExportMethod + const ExportMethodPost + const ExportMethodPut + const FilterOut + const HeaderName + const HttpRequestHeaders + const InitVector + const IsEventData + const KeepAlive + const MaxReconnectInterval + const MediaType + const MergeOnSend + const MimeType + const Mode + const PersistOnError + const PreConnect + const PreConnectRetryCount + const PreConnectRetryCountDefault + const PreConnectRetryInterval + const PreConnectRetryIntervalDefault + const ProfileName + const ProfileNames + const Qos + const ResourceName + const ResourceNames + const ResponseContentType + const Retain + const ReturnInputData + const Rule + const SecretName + const SecretValueKey + const SkipVerify + const SourceNames + const Tags + const TimeInterval + const Topic + const TransformJson + const TransformRoma + const TransformType + const TransformXml + const TriggerTypeHTTP + const TriggerTypeMQTT + const TriggerTypeMessageBus + const Url + const ValueType + const WillEnabled + const WillPayload + const WillQos + const WillRetained + const WillTopic + 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, sp bootstrapInterfaces.SecretProvider) *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) 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) AddCustomRoute(route string, authentication interfaces.Authentication, ...) error + func (svc *Service) AddFunctionsPipelineForTopics(id string, topics []string, transforms ...interfaces.AppFunction) error + func (svc *Service) AppContext() context.Context + 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) Initialize() error + func (svc *Service) ListenForCustomConfigChanges(configToWatch interface{}, sectionName string, ...) error + func (svc *Service) LoadConfigurableFunctionPipelines() (map[string]interfaces.FunctionPipeline, error) + func (svc *Service) LoadCustomConfig(customConfig interfaces.UpdatableConfig, sectionName string) error + func (svc *Service) LoggingClient() logger.LoggingClient + func (svc *Service) MetricsManager() bootstrapInterfaces.MetricsManager + func (svc *Service) NotificationClient() clientInterfaces.NotificationClient + func (svc *Service) Publish(data any, contentType string) error + func (svc *Service) PublishWithTopic(topic string, data any, contentType string) error + func (svc *Service) ReadingClient() clientInterfaces.ReadingClient + func (svc *Service) RegisterCustomStoreFactory(name string, ...) error + func (svc *Service) RegisterCustomTriggerFactory(name string, ...) error + func (svc *Service) RegistryClient() registry.Client + func (svc *Service) RemoveAllFunctionPipelines() + func (svc *Service) RequestTimeout() time.Duration + func (svc *Service) Run() error + func (svc *Service) SecretProvider() bootstrapInterfaces.SecretProvider + func (svc *Service) SetDefaultFunctionsPipeline(transforms ...interfaces.AppFunction) error + func (svc *Service) Stop() + func (svc *Service) SubscriptionClient() clientInterfaces.SubscriptionClient Other modules containing this package github.com/agile-edge/app-functions-sdk-go/v3
Go to main page