Documentation ¶
Index ¶
- type AppFunctionContext
- func (_m *AppFunctionContext) CommandClient() command.CommandClient
- func (_m *AppFunctionContext) CorrelationID() string
- func (_m *AppFunctionContext) EventClient() coredata.EventClient
- func (_m *AppFunctionContext) GetSecret(path string, keys ...string) (map[string]string, error)
- func (_m *AppFunctionContext) InputContentType() string
- func (_m *AppFunctionContext) LoggingClient() logger.LoggingClient
- func (_m *AppFunctionContext) NotificationsClient() notifications.NotificationsClient
- func (_m *AppFunctionContext) PushToCoreData(deviceName string, readingName string, value interface{}) (*dtos.Event, error)
- 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)
- type ApplicationService
- func (_m *ApplicationService) AddBackgroundPublisher(capacity int) interfaces.BackgroundPublisher
- func (_m *ApplicationService) AddRoute(route string, handler func(http.ResponseWriter, *http.Request), ...) error
- func (_m *ApplicationService) ApplicationSettings() map[string]string
- func (_m *ApplicationService) CommandClient() interfaces2.CommandClient
- func (_m *ApplicationService) EventClient() coredata.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) 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) NotificationsClient() notifications.NotificationsClient
- func (_m *ApplicationService) RegisterCustomTriggerFactory(name string, ...) error
- func (_m *ApplicationService) RegistryClient() registry.Client
- func (_m *ApplicationService) SetFunctionsPipeline(...) error
- func (_m *ApplicationService) StoreSecret(path string, secretData map[string]string) error
- 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) CommandClient ¶
func (_m *AppFunctionContext) CommandClient() command.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) EventClient ¶
func (_m *AppFunctionContext) EventClient() coredata.EventClient
EventClient provides a mock function with given fields:
func (*AppFunctionContext) GetSecret ¶
GetSecret provides a mock function with given fields: path, keys
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) NotificationsClient ¶
func (_m *AppFunctionContext) NotificationsClient() notifications.NotificationsClient
NotificationsClient provides a mock function with given fields:
func (*AppFunctionContext) PushToCoreData ¶
func (_m *AppFunctionContext) PushToCoreData(deviceName string, readingName string, value interface{}) (*dtos.Event, error)
PushToCoreData provides a mock function with given fields: deviceName, readingName, value
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
type ApplicationService ¶
ApplicationService is an autogenerated mock type for the ApplicationService type
func (*ApplicationService) AddBackgroundPublisher ¶
func (_m *ApplicationService) AddBackgroundPublisher(capacity int) interfaces.BackgroundPublisher
AddBackgroundPublisher provides a mock function with given fields: capacity
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) CommandClient ¶
func (_m *ApplicationService) CommandClient() interfaces2.CommandClient
CommandClient provides a mock function with given fields:
func (*ApplicationService) EventClient ¶
func (_m *ApplicationService) EventClient() coredata.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) 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) NotificationsClient ¶
func (_m *ApplicationService) NotificationsClient() notifications.NotificationsClient
NotificationsClient 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) 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
type BackgroundPublisher ¶
BackgroundPublisher is an autogenerated mock type for the BackgroundPublisher type
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