Versions in this module Expand all Collapse all v0 v0.0.2 Jul 17, 2023 v0.0.1 Jul 17, 2023 Changes in this version + type AppFunctionContext struct + 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) GetSecret(path string, keys ...string) (map[string]string, error) + func (_m *AppFunctionContext) GetValue(key string) (string, bool) + func (_m *AppFunctionContext) InputContentType() string + func (_m *AppFunctionContext) LoggingClient() logger.LoggingClient + func (_m *AppFunctionContext) NotificationClient() clientsinterfaces.NotificationClient + func (_m *AppFunctionContext) PipelineId() string + func (_m *AppFunctionContext) PushToCore(event dtos.Event) (common.BaseWithIdResponse, error) + func (_m *AppFunctionContext) RemoveValue(key string) + func (_m *AppFunctionContext) ResponseContentType() string + func (_m *AppFunctionContext) ResponseData() []byte + func (_m *AppFunctionContext) SecretsLastUpdated() time.Time + func (_m *AppFunctionContext) SetResponseContentType(_a0 string) + func (_m *AppFunctionContext) SetResponseData(data []byte) + func (_m *AppFunctionContext) SetRetryData(data []byte) + func (_m *AppFunctionContext) SubscriptionClient() clientsinterfaces.SubscriptionClient + type ApplicationService struct + func (_m *ApplicationService) AddBackgroundPublisher(capacity int) (interfaces.BackgroundPublisher, error) + func (_m *ApplicationService) AddBackgroundPublisherWithTopic(capacity int, topic string) (interfaces.BackgroundPublisher, error) + func (_m *ApplicationService) AddFunctionsPipelineForTopics(id string, topics []string, ...) error + func (_m *ApplicationService) AddRoute(route string, handler func(http.ResponseWriter, *http.Request), ...) error + 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) GetSecret(path string, keys ...string) (map[string]string, error) + func (_m *ApplicationService) ListenForCustomConfigChanges(configToWatch interface{}, sectionName string, ...) error + func (_m *ApplicationService) LoadConfigurableFunctionPipelines() (map[string]interfaces.FunctionPipeline, error) + func (_m *ApplicationService) LoadConfigurablePipeline() ([]func(interfaces.AppFunctionContext, interface{}) (bool, interface{}), error) + func (_m *ApplicationService) LoadCustomConfig(config interfaces.UpdatableConfig, sectionName string) error + func (_m *ApplicationService) LoggingClient() logger.LoggingClient + func (_m *ApplicationService) MakeItRun() error + func (_m *ApplicationService) MakeItStop() + func (_m *ApplicationService) NotificationClient() clientsinterfaces.NotificationClient + func (_m *ApplicationService) RegisterCustomTriggerFactory(name string, ...) error + func (_m *ApplicationService) RegistryClient() registry.Client + func (_m *ApplicationService) SetDefaultFunctionsPipeline(...) error + func (_m *ApplicationService) SetFunctionsPipeline(...) error + func (_m *ApplicationService) StoreSecret(path string, secretData map[string]string) error + func (_m *ApplicationService) SubscriptionClient() clientsinterfaces.SubscriptionClient + type BackgroundPublisher struct + func (_m *BackgroundPublisher) Publish(payload []byte, context interfaces.AppFunctionContext) error + type Trigger struct + func (_m *Trigger) Initialize(wg *sync.WaitGroup, ctx context.Context, ...) (bootstrap.Deferred, error) + type TriggerContextBuilder struct + func (_m *TriggerContextBuilder) Execute(env types.MessageEnvelope) interfaces.AppFunctionContext + type TriggerMessageProcessor struct + func (_m *TriggerMessageProcessor) Execute(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope) error
Go to main page