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) 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) 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
- 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) AddCustomRoute(route string, authentication interfaces.Authentication, ...) error
- func (_m *ApplicationService) AddFunctionsPipelineForTopics(id string, topic []string, ...) error
- func (_m *ApplicationService) AddRoute(route string, handler func(http.ResponseWriter, *http.Request), ...) 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) 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
- type 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
- 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 NewAppFunctionContext ¶
func NewAppFunctionContext(t mockConstructorTestingTNewAppFunctionContext) *AppFunctionContext
NewAppFunctionContext creates a new instance of AppFunctionContext. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
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) 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) MetricsManager ¶
func (_m *AppFunctionContext) MetricsManager() bootstrapinterfaces.MetricsManager
MetricsManager 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) Publish ¶ added in v3.1.0
func (_m *AppFunctionContext) Publish(data interface{}, contentType string) error
Publish provides a mock function with given fields: data, contentType
func (*AppFunctionContext) PublishWithTopic ¶ added in v3.1.0
func (_m *AppFunctionContext) PublishWithTopic(topic string, data interface{}, contentType string) error
PublishWithTopic provides a mock function with given fields: topic, data, contentType
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) SecretProvider ¶
func (_m *AppFunctionContext) SecretProvider() bootstrapinterfaces.SecretProvider
SecretProvider 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 NewApplicationService ¶
func NewApplicationService(t mockConstructorTestingTNewApplicationService) *ApplicationService
NewApplicationService creates a new instance of ApplicationService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
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) AddCustomRoute ¶ added in v3.1.0
func (_m *ApplicationService) AddCustomRoute(route string, authentication interfaces.Authentication, handler func(http.ResponseWriter, *http.Request), methods ...string) error
AddCustomRoute provides a mock function with given fields: route, authentication, handler, methods
func (*ApplicationService) AddFunctionsPipelineForTopics ¶
func (_m *ApplicationService) AddFunctionsPipelineForTopics(id string, topic []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) AppContext ¶ added in v3.1.0
func (_m *ApplicationService) AppContext() context.Context
AppContext provides a mock function with given fields:
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) 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) LoadCustomConfig ¶
func (_m *ApplicationService) LoadCustomConfig(_a0 interfaces.UpdatableConfig, sectionName string) error
LoadCustomConfig provides a mock function with given fields: _a0, sectionName
func (*ApplicationService) LoggingClient ¶
func (_m *ApplicationService) LoggingClient() logger.LoggingClient
LoggingClient provides a mock function with given fields:
func (*ApplicationService) MetricsManager ¶
func (_m *ApplicationService) MetricsManager() bootstrapinterfaces.MetricsManager
MetricsManager 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) Publish ¶ added in v3.1.0
func (_m *ApplicationService) Publish(data interface{}, contentType string) error
Publish provides a mock function with given fields: data, contentType
func (*ApplicationService) PublishWithTopic ¶ added in v3.1.0
func (_m *ApplicationService) PublishWithTopic(topic string, data interface{}, contentType string) error
PublishWithTopic provides a mock function with given fields: topic, data, contentType
func (*ApplicationService) RegisterCustomStoreFactory ¶
func (_m *ApplicationService) RegisterCustomStoreFactory(name string, factory func(config.Database, config.Credentials) (interfaces.StoreClient, error)) error
RegisterCustomStoreFactory provides a mock function with given fields: name, factory
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) RemoveAllFunctionPipelines ¶
func (_m *ApplicationService) RemoveAllFunctionPipelines()
RemoveAllFunctionPipelines provides a mock function with given fields:
func (*ApplicationService) RequestTimeout ¶
func (_m *ApplicationService) RequestTimeout() time.Duration
RequestTimeout provides a mock function with given fields:
func (*ApplicationService) Run ¶
func (_m *ApplicationService) Run() error
Run provides a mock function with given fields:
func (*ApplicationService) SecretProvider ¶
func (_m *ApplicationService) SecretProvider() bootstrapinterfaces.SecretProvider
SecretProvider 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) Stop ¶
func (_m *ApplicationService) Stop()
Stop provides a mock function with given fields:
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 NewBackgroundPublisher ¶
func NewBackgroundPublisher(t mockConstructorTestingTNewBackgroundPublisher) *BackgroundPublisher
NewBackgroundPublisher creates a new instance of BackgroundPublisher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*BackgroundPublisher) Publish ¶
func (_m *BackgroundPublisher) Publish(payload []byte, context interfaces.AppFunctionContext) error
Publish provides a mock function with given fields: payload, context
type StoreClient ¶
StoreClient is an autogenerated mock type for the StoreClient type
func NewStoreClient ¶
func NewStoreClient(t mockConstructorTestingTNewStoreClient) *StoreClient
NewStoreClient creates a new instance of StoreClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*StoreClient) Disconnect ¶
func (_m *StoreClient) Disconnect() error
Disconnect provides a mock function with given fields:
func (*StoreClient) RemoveFromStore ¶
func (_m *StoreClient) RemoveFromStore(o interfaces.StoredObject) error
RemoveFromStore provides a mock function with given fields: o
func (*StoreClient) RetrieveFromStore ¶
func (_m *StoreClient) RetrieveFromStore(appServiceKey string) ([]interfaces.StoredObject, error)
RetrieveFromStore provides a mock function with given fields: appServiceKey
func (*StoreClient) Store ¶
func (_m *StoreClient) Store(o interfaces.StoredObject) (string, error)
Store provides a mock function with given fields: o
func (*StoreClient) Update ¶
func (_m *StoreClient) Update(o interfaces.StoredObject) error
Update provides a mock function with given fields: o
type Trigger ¶
Trigger is an autogenerated mock type for the Trigger type
func NewTrigger ¶
func NewTrigger(t mockConstructorTestingTNewTrigger) *Trigger
NewTrigger creates a new instance of Trigger. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
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 NewTriggerContextBuilder ¶
func NewTriggerContextBuilder(t mockConstructorTestingTNewTriggerContextBuilder) *TriggerContextBuilder
NewTriggerContextBuilder creates a new instance of TriggerContextBuilder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
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 NewTriggerMessageProcessor ¶
func NewTriggerMessageProcessor(t mockConstructorTestingTNewTriggerMessageProcessor) *TriggerMessageProcessor
NewTriggerMessageProcessor creates a new instance of TriggerMessageProcessor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TriggerMessageProcessor) Execute ¶
func (_m *TriggerMessageProcessor) Execute(ctx interfaces.AppFunctionContext, envelope types.MessageEnvelope) error
Execute provides a mock function with given fields: ctx, envelope