Documentation ¶
Index ¶
- type 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) 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
- 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
- type Trigger
- type TriggerContextBuilder
- type TriggerMessageProcessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppFunctionContext ¶
AppFunctionContext is an autogenerated mock type for the AppFunctionContext type
func (*AppFunctionContext) AddValue ¶
func (_m *AppFunctionContext) AddValue(key string, value string)
AddValue provides a mock function with given fields: key, value
func (*AppFunctionContext) ApplyValues ¶
func (_m *AppFunctionContext) ApplyValues(format string) (string, error)
ApplyValues provides a mock function with given fields: format
func (*AppFunctionContext) Clone ¶
func (_m *AppFunctionContext) Clone() interfaces.AppFunctionContext
Clone provides a mock function with given fields:
func (*AppFunctionContext) CommandClient ¶
func (_m *AppFunctionContext) CommandClient() clientsinterfaces.CommandClient
CommandClient provides a mock function with given fields:
func (*AppFunctionContext) CorrelationID ¶
func (_m *AppFunctionContext) CorrelationID() string
CorrelationID provides a mock function with given fields:
func (*AppFunctionContext) DeviceClient ¶
func (_m *AppFunctionContext) DeviceClient() clientsinterfaces.DeviceClient
DeviceClient provides a mock function with given fields:
func (*AppFunctionContext) DeviceProfileClient ¶
func (_m *AppFunctionContext) DeviceProfileClient() clientsinterfaces.DeviceProfileClient
DeviceProfileClient provides a mock function with given fields:
func (*AppFunctionContext) DeviceServiceClient ¶
func (_m *AppFunctionContext) DeviceServiceClient() clientsinterfaces.DeviceServiceClient
DeviceServiceClient provides a mock function with given fields:
func (*AppFunctionContext) EventClient ¶
func (_m *AppFunctionContext) EventClient() clientsinterfaces.EventClient
EventClient provides a mock function with given fields:
func (*AppFunctionContext) GetAllValues ¶
func (_m *AppFunctionContext) GetAllValues() map[string]string
GetAllValues provides a mock function with given fields:
func (*AppFunctionContext) GetDeviceResource ¶
func (_m *AppFunctionContext) GetDeviceResource(profileName string, resourceName string) (dtos.DeviceResource, error)
GetDeviceResource provides a mock function with given fields: profileName, resourceName
func (*AppFunctionContext) GetSecret ¶
GetSecret provides a mock function with given fields: path, keys
func (*AppFunctionContext) GetValue ¶
func (_m *AppFunctionContext) GetValue(key string) (string, bool)
GetValue provides a mock function with given fields: key
func (*AppFunctionContext) InputContentType ¶
func (_m *AppFunctionContext) InputContentType() string
InputContentType provides a mock function with given fields:
func (*AppFunctionContext) LoggingClient ¶
func (_m *AppFunctionContext) LoggingClient() logger.LoggingClient
LoggingClient provides a mock function with given fields:
func (*AppFunctionContext) NotificationClient ¶
func (_m *AppFunctionContext) NotificationClient() clientsinterfaces.NotificationClient
NotificationClient provides a mock function with given fields:
func (*AppFunctionContext) PipelineId ¶
func (_m *AppFunctionContext) PipelineId() string
PipelineId provides a mock function with given fields:
func (*AppFunctionContext) PushToCore ¶
func (_m *AppFunctionContext) PushToCore(event dtos.Event) (common.BaseWithIdResponse, error)
PushToCore provides a mock function with given fields: event
func (*AppFunctionContext) RemoveValue ¶
func (_m *AppFunctionContext) RemoveValue(key string)
RemoveValue provides a mock function with given fields: key
func (*AppFunctionContext) ResponseContentType ¶
func (_m *AppFunctionContext) ResponseContentType() string
ResponseContentType provides a mock function with given fields:
func (*AppFunctionContext) ResponseData ¶
func (_m *AppFunctionContext) ResponseData() []byte
ResponseData provides a mock function with given fields:
func (*AppFunctionContext) SecretsLastUpdated ¶
func (_m *AppFunctionContext) SecretsLastUpdated() time.Time
SecretsLastUpdated provides a mock function with given fields:
func (*AppFunctionContext) SetResponseContentType ¶
func (_m *AppFunctionContext) SetResponseContentType(_a0 string)
SetResponseContentType provides a mock function with given fields: _a0
func (*AppFunctionContext) SetResponseData ¶
func (_m *AppFunctionContext) SetResponseData(data []byte)
SetResponseData provides a mock function with given fields: data
func (*AppFunctionContext) SetRetryData ¶
func (_m *AppFunctionContext) SetRetryData(data []byte)
SetRetryData provides a mock function with given fields: data
func (*AppFunctionContext) SubscriptionClient ¶
func (_m *AppFunctionContext) SubscriptionClient() clientsinterfaces.SubscriptionClient
SubscriptionClient provides a mock function with given fields:
type ApplicationService ¶
ApplicationService is an autogenerated mock type for the ApplicationService type
func (*ApplicationService) AddBackgroundPublisher ¶
func (_m *ApplicationService) AddBackgroundPublisher(capacity int) (interfaces.BackgroundPublisher, error)
AddBackgroundPublisher provides a mock function with given fields: capacity
func (*ApplicationService) AddBackgroundPublisherWithTopic ¶
func (_m *ApplicationService) AddBackgroundPublisherWithTopic(capacity int, topic string) (interfaces.BackgroundPublisher, error)
AddBackgroundPublisherWithTopic provides a mock function with given fields: capacity, topic
func (*ApplicationService) AddFunctionsPipelineForTopics ¶
func (_m *ApplicationService) AddFunctionsPipelineForTopics(id string, topics []string, transforms ...func(interfaces.AppFunctionContext, interface{}) (bool, interface{})) error
AddFunctionsPipelineForTopics provides a mock function with given fields: id, topic, transforms
func (*ApplicationService) AddRoute ¶
func (_m *ApplicationService) AddRoute(route string, handler func(http.ResponseWriter, *http.Request), methods ...string) error
AddRoute provides a mock function with given fields: route, handler, methods
func (*ApplicationService) ApplicationSettings ¶
func (_m *ApplicationService) ApplicationSettings() map[string]string
ApplicationSettings provides a mock function with given fields:
func (*ApplicationService) BuildContext ¶
func (_m *ApplicationService) BuildContext(correlationId string, contentType string) interfaces.AppFunctionContext
BuildContext provides a mock function with given fields: correlationId, contentType
func (*ApplicationService) CommandClient ¶
func (_m *ApplicationService) CommandClient() clientsinterfaces.CommandClient
CommandClient provides a mock function with given fields:
func (*ApplicationService) DeviceClient ¶
func (_m *ApplicationService) DeviceClient() clientsinterfaces.DeviceClient
DeviceClient provides a mock function with given fields:
func (*ApplicationService) DeviceProfileClient ¶
func (_m *ApplicationService) DeviceProfileClient() clientsinterfaces.DeviceProfileClient
DeviceProfileClient provides a mock function with given fields:
func (*ApplicationService) DeviceServiceClient ¶
func (_m *ApplicationService) DeviceServiceClient() clientsinterfaces.DeviceServiceClient
DeviceServiceClient provides a mock function with given fields:
func (*ApplicationService) EventClient ¶
func (_m *ApplicationService) EventClient() clientsinterfaces.EventClient
EventClient provides a mock function with given fields:
func (*ApplicationService) GetAppSetting ¶
func (_m *ApplicationService) GetAppSetting(setting string) (string, error)
GetAppSetting provides a mock function with given fields: setting
func (*ApplicationService) GetAppSettingStrings ¶
func (_m *ApplicationService) GetAppSettingStrings(setting string) ([]string, error)
GetAppSettingStrings provides a mock function with given fields: setting
func (*ApplicationService) GetSecret ¶
GetSecret provides a mock function with given fields: path, keys
func (*ApplicationService) ListenForCustomConfigChanges ¶
func (_m *ApplicationService) ListenForCustomConfigChanges(configToWatch interface{}, sectionName string, changedCallback func(interface{})) error
ListenForCustomConfigChanges provides a mock function with given fields: configToWatch, sectionName, changedCallback
func (*ApplicationService) LoadConfigurableFunctionPipelines ¶
func (_m *ApplicationService) LoadConfigurableFunctionPipelines() (map[string]interfaces.FunctionPipeline, error)
LoadConfigurableFunctionPipelines provides a mock function with given fields:
func (*ApplicationService) LoadConfigurablePipeline ¶
func (_m *ApplicationService) LoadConfigurablePipeline() ([]func(interfaces.AppFunctionContext, interface{}) (bool, interface{}), error)
LoadConfigurablePipeline provides a mock function with given fields:
func (*ApplicationService) LoadCustomConfig ¶
func (_m *ApplicationService) LoadCustomConfig(config interfaces.UpdatableConfig, sectionName string) error
LoadCustomConfig provides a mock function with given fields: config, sectionName
func (*ApplicationService) LoggingClient ¶
func (_m *ApplicationService) LoggingClient() logger.LoggingClient
LoggingClient provides a mock function with given fields:
func (*ApplicationService) MakeItRun ¶
func (_m *ApplicationService) MakeItRun() error
MakeItRun provides a mock function with given fields:
func (*ApplicationService) MakeItStop ¶
func (_m *ApplicationService) MakeItStop()
MakeItStop provides a mock function with given fields:
func (*ApplicationService) NotificationClient ¶
func (_m *ApplicationService) NotificationClient() clientsinterfaces.NotificationClient
NotificationClient provides a mock function with given fields:
func (*ApplicationService) RegisterCustomTriggerFactory ¶
func (_m *ApplicationService) RegisterCustomTriggerFactory(name string, factory func(interfaces.TriggerConfig) (interfaces.Trigger, error)) error
RegisterCustomTriggerFactory provides a mock function with given fields: name, factory
func (*ApplicationService) RegistryClient ¶
func (_m *ApplicationService) RegistryClient() registry.Client
RegistryClient provides a mock function with given fields:
func (*ApplicationService) SetDefaultFunctionsPipeline ¶
func (_m *ApplicationService) SetDefaultFunctionsPipeline(transforms ...func(interfaces.AppFunctionContext, interface{}) (bool, interface{})) error
SetDefaultFunctionsPipeline provides a mock function with given fields: transforms
func (*ApplicationService) SetFunctionsPipeline ¶
func (_m *ApplicationService) SetFunctionsPipeline(transforms ...func(interfaces.AppFunctionContext, interface{}) (bool, interface{})) error
SetFunctionsPipeline provides a mock function with given fields: transforms
func (*ApplicationService) StoreSecret ¶
func (_m *ApplicationService) StoreSecret(path string, secretData map[string]string) error
StoreSecret provides a mock function with given fields: path, secretData
func (*ApplicationService) SubscriptionClient ¶
func (_m *ApplicationService) SubscriptionClient() clientsinterfaces.SubscriptionClient
SubscriptionClient provides a mock function with given fields:
type BackgroundPublisher ¶
BackgroundPublisher is an autogenerated mock type for the BackgroundPublisher type
func (*BackgroundPublisher) Publish ¶
func (_m *BackgroundPublisher) Publish(payload []byte, context interfaces.AppFunctionContext) error
Publish provides a mock function with given fields: payload, context
type Trigger ¶
Trigger is an autogenerated mock type for the Trigger type
func (*Trigger) Initialize ¶
func (_m *Trigger) Initialize(wg *sync.WaitGroup, ctx context.Context, background <-chan interfaces.BackgroundMessage) (bootstrap.Deferred, error)
Initialize provides a mock function with given fields: wg, ctx, background
type TriggerContextBuilder ¶
TriggerContextBuilder is an autogenerated mock type for the TriggerContextBuilder type
func (*TriggerContextBuilder) Execute ¶
func (_m *TriggerContextBuilder) Execute(env types.MessageEnvelope) interfaces.AppFunctionContext
Execute provides a mock function with given fields: env
type TriggerMessageProcessor ¶
TriggerMessageProcessor is an autogenerated mock type for the TriggerMessageProcessor type
func (*TriggerMessageProcessor) Execute ¶
func (_m *TriggerMessageProcessor) Execute(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope) error
Execute provides a mock function with given fields: ctx, envelope