Versions in this module Expand all Collapse all v4 v4.0.0 Apr 3, 2025 Changes in this version + type AppFunctionContext struct + func NewAppFunctionContext(t mockConstructorTestingTNewAppFunctionContext) *AppFunctionContext + func (_m *AppFunctionContext) AddValue(key string, value string) + func (_m *AppFunctionContext) ApplyValues(format string) (string, error) + func (_m *AppFunctionContext) Clone() interfaces.AppFunctionContext + func (_m *AppFunctionContext) CommandClient() clientsinterfaces.CommandClient + func (_m *AppFunctionContext) CorrelationID() string + func (_m *AppFunctionContext) DeviceClient() clientsinterfaces.DeviceClient + func (_m *AppFunctionContext) DeviceProfileClient() clientsinterfaces.DeviceProfileClient + func (_m *AppFunctionContext) DeviceServiceClient() clientsinterfaces.DeviceServiceClient + func (_m *AppFunctionContext) EventClient() clientsinterfaces.EventClient + func (_m *AppFunctionContext) GetAllValues() map[string]string + func (_m *AppFunctionContext) GetDeviceResource(profileName string, resourceName string) (dtos.DeviceResource, error) + func (_m *AppFunctionContext) GetValue(key string) (string, bool) + func (_m *AppFunctionContext) InputContentType() string + func (_m *AppFunctionContext) LoggingClient() logger.LoggingClient + func (_m *AppFunctionContext) MetricsManager() bootstrapinterfaces.MetricsManager + func (_m *AppFunctionContext) NotificationClient() clientsinterfaces.NotificationClient + func (_m *AppFunctionContext) PipelineId() string + func (_m *AppFunctionContext) Publish(data interface{}, contentType string) error + func (_m *AppFunctionContext) PublishWithTopic(topic string, data interface{}, contentType string) error + func (_m *AppFunctionContext) ReadingClient() clientsinterfaces.ReadingClient + func (_m *AppFunctionContext) RemoveValue(key string) + func (_m *AppFunctionContext) ResponseContentType() string + func (_m *AppFunctionContext) ResponseData() []byte + func (_m *AppFunctionContext) SecretProvider() bootstrapinterfaces.SecretProvider + func (_m *AppFunctionContext) SetResponseContentType(_a0 string) + func (_m *AppFunctionContext) SetResponseData(data []byte) + func (_m *AppFunctionContext) SetRetryData(data []byte) + func (_m *AppFunctionContext) SubscriptionClient() clientsinterfaces.SubscriptionClient + func (_m *AppFunctionContext) TriggerRetryFailedData() + type ApplicationService struct + func NewApplicationService(t interface{ ... }) *ApplicationService + func (_m *ApplicationService) AddBackgroundPublisher(capacity int) (interfaces.BackgroundPublisher, error) + func (_m *ApplicationService) AddBackgroundPublisherWithTopic(capacity int, topic string) (interfaces.BackgroundPublisher, error) + func (_m *ApplicationService) AddCustomRoute(route string, authentication interfaces.Authentication, ...) error + func (_m *ApplicationService) AddFunctionsPipelineForTopics(id string, topic []string, ...) error + func (_m *ApplicationService) AppContext() context.Context + func (_m *ApplicationService) ApplicationSettings() map[string]string + func (_m *ApplicationService) BuildContext(correlationId string, contentType string) interfaces.AppFunctionContext + func (_m *ApplicationService) CommandClient() clientsinterfaces.CommandClient + func (_m *ApplicationService) DeviceClient() clientsinterfaces.DeviceClient + func (_m *ApplicationService) DeviceProfileClient() clientsinterfaces.DeviceProfileClient + func (_m *ApplicationService) DeviceServiceClient() clientsinterfaces.DeviceServiceClient + func (_m *ApplicationService) EventClient() clientsinterfaces.EventClient + func (_m *ApplicationService) GetAppSetting(setting string) (string, error) + func (_m *ApplicationService) GetAppSettingStrings(setting string) ([]string, error) + func (_m *ApplicationService) ListenForCustomConfigChanges(configToWatch interface{}, sectionName string, ...) error + func (_m *ApplicationService) LoadConfigurableFunctionPipelines() (map[string]interfaces.FunctionPipeline, error) + func (_m *ApplicationService) LoadCustomConfig(_a0 interfaces.UpdatableConfig, sectionName string) error + func (_m *ApplicationService) LoggingClient() logger.LoggingClient + func (_m *ApplicationService) MetricsManager() bootstrapinterfaces.MetricsManager + func (_m *ApplicationService) NotificationClient() clientsinterfaces.NotificationClient + func (_m *ApplicationService) Publish(data interface{}, contentType string) error + func (_m *ApplicationService) PublishWithTopic(topic string, data interface{}, contentType string) error + func (_m *ApplicationService) ReadingClient() clientsinterfaces.ReadingClient + func (_m *ApplicationService) RegisterCustomStoreFactory(name string, ...) error + func (_m *ApplicationService) RegisterCustomTriggerFactory(name string, ...) error + func (_m *ApplicationService) RegistryClient() registry.Client + func (_m *ApplicationService) RemoveAllFunctionPipelines() + func (_m *ApplicationService) RequestTimeout() time.Duration + func (_m *ApplicationService) Run() error + func (_m *ApplicationService) SecretProvider() bootstrapinterfaces.SecretProvider + func (_m *ApplicationService) SetDefaultFunctionsPipeline(...) error + func (_m *ApplicationService) Stop() + func (_m *ApplicationService) SubscriptionClient() clientsinterfaces.SubscriptionClient + type BackgroundPublisher struct + func NewBackgroundPublisher(t mockConstructorTestingTNewBackgroundPublisher) *BackgroundPublisher + func (_m *BackgroundPublisher) Publish(payload []byte, context interfaces.AppFunctionContext) error + type StoreClient struct + func NewStoreClient(t mockConstructorTestingTNewStoreClient) *StoreClient + func (_m *StoreClient) Disconnect() error + func (_m *StoreClient) RemoveFromStore(o interfaces.StoredObject) error + func (_m *StoreClient) RetrieveFromStore(appServiceKey string) ([]interfaces.StoredObject, error) + func (_m *StoreClient) Store(o interfaces.StoredObject) (string, error) + func (_m *StoreClient) Update(o interfaces.StoredObject) error + type Trigger struct + func NewTrigger(t mockConstructorTestingTNewTrigger) *Trigger + func (_m *Trigger) Initialize(wg *sync.WaitGroup, ctx context.Context, ...) (bootstrap.Deferred, error) + type TriggerContextBuilder struct + func NewTriggerContextBuilder(t mockConstructorTestingTNewTriggerContextBuilder) *TriggerContextBuilder + func (_m *TriggerContextBuilder) Execute(env types.MessageEnvelope) interfaces.AppFunctionContext + type TriggerMessageProcessor struct + func NewTriggerMessageProcessor(t mockConstructorTestingTNewTriggerMessageProcessor) *TriggerMessageProcessor + func (_m *TriggerMessageProcessor) Execute(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope) error Other modules containing this package github.com/agile-edge/app-functions-sdk-go/v3
Go to main page