Documentation
¶
Index ¶
- func GetJson(token string, url string, out interface{}) (err error)
- type AspectNodeQuery
- type BpmnResource
- type CharacteristicsWrapper
- type Config
- type Dependencies
- type DeviceDependency
- type EventDependency
- type Function
- type HistoryResult
- type HistorySeries
- type ImportTypeCriteria
- type ImportTypeWithCriteria
- type Interface
- type Lib
- func (this *Lib) CheckEventStates(token string, ids []string) (result map[string]bool, err error)
- func (this *Lib) CompleteDeviceHistory(token auth.Token, duration string, devices []map[string]interface{}) (result []map[string]interface{}, err error)
- func (this *Lib) CompleteGatewayHistory(token auth.Token, duration string, gateways []map[string]interface{}) (result []map[string]interface{}, err error)
- func (this *Lib) Config() Config
- func (this *Lib) FindDevices(token auth.Token, limit int, offset int) (devices []map[string]interface{}, err error)
- func (this *Lib) GetAspectNodes(ids []string, token auth.Token) ([]model.AspectNode, error)
- func (this *Lib) GetAspectNodesWithMeasuringFunction(token auth.Token) ([]model.AspectNode, error)
- func (this *Lib) GetDeviceClassUses(token auth.Token) (result interface{}, err error)
- func (this *Lib) GetDeviceLogHistory(token auth.Token, deviceIds []string, duration string) (result map[string]HistorySeries, err error)
- func (this *Lib) GetDeviceLogStates(token auth.Token, deviceIds []string) (result map[string]bool, err error)
- func (this *Lib) GetExtendedProcessList(token auth.Token, query url.Values) (result []map[string]interface{}, err error)
- func (this *Lib) GetGatewayLogHistory(token auth.Token, ids []string, duration string) (result map[string]HistorySeries, err error)
- func (this *Lib) GetGatewayLogStates(token auth.Token, ids []string) (result map[string]bool, err error)
- func (this *Lib) GetImportTypes(token auth.Token) (importTypes []ImportTypeWithCriteria, err error, code int)
- func (this *Lib) GetImportTypesWithAspect(token auth.Token, aspectIds []string) (importTypes []ImportTypeWithCriteria, err error, code int)
- func (this *Lib) GetLogHistory(token auth.Token, kind string, ids []string, duration string) (result map[string]HistorySeries, err error)
- func (this *Lib) GetLogedges(token auth.Token, kind string, ids []string, duration string) (result map[string]interface{}, err error)
- func (this *Lib) GetLogstarts(token auth.Token, kind string, ids []string) (result map[string]interface{}, err error)
- func (this *Lib) GetMeasuringFunctions(token auth.Token, functionIds []string) (functions []Function, err error, code int)
- func (this *Lib) GetMeasuringFunctionsForAspect(token auth.Token, aspectId string) (functions []Function, err error, code int)
- func (this *Lib) GetProcessDependencyList(token auth.Token, processIds []string) (result []Dependencies, err error)
- func (this *Lib) GetProcessDeploymentList(token auth.Token, query url.Values) (result []map[string]interface{}, err error)
- func (this *Lib) ListAllGateways(token auth.Token) (result []map[string]interface{}, err error)
- func (this *Lib) ListGateways(token auth.Token, limit int64, offset int64) (result []map[string]interface{}, err error)
- func (this *Lib) SetOnlineState(token auth.Token, dependencies []Dependencies) (result []Dependencies, err error)
- type OfflineReason
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AspectNodeQuery ¶
type AspectNodeQuery struct {
Ids []string `json:"ids"`
}
type BpmnResource ¶
type BpmnResource struct { Id string `json:"id" bson:"id"` // contains filtered or unexported fields }
type CharacteristicsWrapper ¶
type CharacteristicsWrapper struct {
Raw model.Characteristic `json:"raw"`
}
type Config ¶
type Config struct { ServerPort string `json:"server_port"` IotUrl string `json:"iot_url"` ImportRepoUrl string `json:"import_repo_url"` ConnectionLogUrl string `json:"connection_log_url"` CamundaWrapperUrl string `json:"camunda_wrapper_url"` ProcessDeploymentUrl string `json:"process_deployment_url"` EventManagerUrl string `json:"event_manager_url"` HttpClientTimeout string `json:"http_client_timeout"` }
func LoadConfig ¶
type Dependencies ¶
type Dependencies struct { DeploymentId string `json:"deployment_id" bson:"deployment_id"` Owner string `json:"owner" bson:"owner"` Devices []DeviceDependency `json:"devices" bson:"devices"` Events []EventDependency `json:"events" bson:"events"` Online bool `json:"-"` }
type DeviceDependency ¶
type DeviceDependency struct { DeviceId string `json:"device_id" bson:"device_id"` Name string `json:"name" bson:"name"` BpmnResources []BpmnResource `json:"bpmn_resources" bson:"bpmn_resources"` Online bool `json:"-"` }
type EventDependency ¶
type EventDependency struct { EventId string `json:"event_id" bson:"event_id"` BpmnResources []BpmnResource `json:"bpmn_resources" bson:"bpmn_resources"` Online bool `json:"-"` }
type HistoryResult ¶
type HistoryResult struct {
Series []HistorySeries `json:"Series"`
}
type HistorySeries ¶
type ImportTypeCriteria ¶ added in v0.0.11
type ImportTypeWithCriteria ¶ added in v0.0.11
type ImportTypeWithCriteria struct { model.ImportType Criteria []ImportTypeCriteria }
type Interface ¶
type Interface interface { Config() Config ListGateways(token auth.Token, limit int64, offset int64) (result []map[string]interface{}, err error) GetExtendedProcessList(token auth.Token, query url.Values) (result []map[string]interface{}, err error) CompleteDeviceHistory(token auth.Token, duration string, devices []map[string]interface{}) (result []map[string]interface{}, err error) CompleteGatewayHistory(token auth.Token, duration string, devices []map[string]interface{}) (result []map[string]interface{}, err error) ListAllGateways(token auth.Token) (result []map[string]interface{}, err error) FindDevices(token auth.Token, limit int, offset int) ([]map[string]interface{}, error) GetMeasuringFunctionsForAspect(token auth.Token, aspectId string) (functions []Function, err error, code int) GetMeasuringFunctions(token auth.Token, functionIds []string) (functions []Function, err error, code int) GetImportTypesWithAspect(token auth.Token, aspectIds []string) (importTypes []ImportTypeWithCriteria, err error, code int) GetAspectNodes(ids []string, token auth.Token) ([]model.AspectNode, error) GetAspectNodesWithMeasuringFunction(token auth.Token) ([]model.AspectNode, error) GetImportTypes(token auth.Token) (importTypes []ImportTypeWithCriteria, err error, code int) GetDeviceClassUses(token auth.Token) (result interface{}, err error) }
type Lib ¶
type Lib struct {
// contains filtered or unexported fields
}
func (*Lib) CheckEventStates ¶
func (*Lib) CompleteDeviceHistory ¶
func (*Lib) CompleteGatewayHistory ¶
func (*Lib) FindDevices ¶
func (*Lib) GetAspectNodes ¶
func (*Lib) GetAspectNodesWithMeasuringFunction ¶
func (*Lib) GetDeviceClassUses ¶
func (*Lib) GetDeviceLogHistory ¶
func (*Lib) GetDeviceLogStates ¶
func (*Lib) GetExtendedProcessList ¶
func (*Lib) GetGatewayLogHistory ¶
func (*Lib) GetGatewayLogStates ¶
func (*Lib) GetImportTypes ¶
func (*Lib) GetImportTypesWithAspect ¶
func (*Lib) GetLogHistory ¶
func (*Lib) GetLogedges ¶
func (*Lib) GetLogstarts ¶
func (*Lib) GetMeasuringFunctions ¶
func (*Lib) GetMeasuringFunctionsForAspect ¶
func (*Lib) GetProcessDependencyList ¶
func (*Lib) GetProcessDeploymentList ¶
func (*Lib) ListAllGateways ¶
func (*Lib) ListGateways ¶
func (*Lib) SetOnlineState ¶
func (this *Lib) SetOnlineState(token auth.Token, dependencies []Dependencies) (result []Dependencies, err error)
type OfflineReason ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.