client

Documentation

Index

• type ApiRemoteClient
  • func NewApiRemoteClient(sClient *fimpgo.SyncClient, instanceAddress, clientId string) *ApiRemoteClient
  • func (rc *ApiRemoteClient) ContextDeleteRecord(name string, flowId string) (string, error)
  • func (rc *ApiRemoteClient) ContextGetRecords(flowId string) ([]model.ContextRecord, error)
  • func (rc *ApiRemoteClient) ContextUpdateRecord(flowId string, rec *model.ContextRecord) (string, error)
  • func (rc *ApiRemoteClient) ControlFlow(cmd string, id string) (string, error)
  • func (rc *ApiRemoteClient) DeleteFlow(id string) (string, error)
  • func (rc *ApiRemoteClient) GetConnectorInstances() ([]conmodel.InstanceView, error)
  • func (rc *ApiRemoteClient) GetConnectorPlugins() (map[string]conmodel.Plugin, error)
  • func (rc *ApiRemoteClient) GetConnectorTemplate(templateId string) (conmodel.Instance, error)
  • func (rc *ApiRemoteClient) GetFlowDefinition(flowId string) (*model.FlowMeta, error)
  • func (rc *ApiRemoteClient) GetFlowLog(limitLines int, flowId string) ([]utils.LogEntry, error)
  • func (rc *ApiRemoteClient) GetListOfFlows() ([]flow.FlowListItem, error)
  • func (rc *ApiRemoteClient) ImportFlow(flowDef []byte) (string, error)
  • func (rc *ApiRemoteClient) ImportFlowFromUrl(url string, token string) (string, error)
  • func (rc *ApiRemoteClient) RegistryDeleteLocation(id string) (string, error)
  • func (rc *ApiRemoteClient) RegistryDeleteThing(id string) (string, error)
  • func (rc *ApiRemoteClient) RegistryGetListOfDevices(locationId string) ([]model2.DeviceExtendedView, error)
  • func (rc *ApiRemoteClient) RegistryGetListOfLocations() ([]model2.Location, error)
  • func (rc *ApiRemoteClient) RegistryGetListOfServices(serviceName, locationId, thingId, filterWithoutAlias string) ([]model2.ServiceExtendedView, error)
  • func (rc *ApiRemoteClient) RegistryGetListOfThings(locationId string) ([]model2.ThingWithLocationView, error)
  • func (rc *ApiRemoteClient) RegistryGetService(fullAddress string) (model2.ServiceExtendedView, error)
  • func (rc *ApiRemoteClient) RegistryGetThing(tech, address string) (model2.ThingExtendedView, error)
  • func (rc *ApiRemoteClient) RegistryUpdateLocation(location *model2.Location) (string, error)
  • func (rc *ApiRemoteClient) RegistryUpdateLocationBin(locationBin []byte) (string, error)
  • func (rc *ApiRemoteClient) RegistryUpdateService(service *model2.Service) (string, error)
  • func (rc *ApiRemoteClient) RegistryUpdateServiceBin(serviceBin []byte) (string, error)
  • func (rc *ApiRemoteClient) UpdateFlowBin(flowDef []byte) (string, error)

Types

type ApiRemoteClient

type ApiRemoteClient struct {
	// contains filtered or unexported fields
}

func NewApiRemoteClient

func NewApiRemoteClient(sClient *fimpgo.SyncClient, instanceAddress, clientId string) *ApiRemoteClient

func (*ApiRemoteClient) ContextDeleteRecord

func (rc *ApiRemoteClient) ContextDeleteRecord(name string, flowId string) (string, error)

func (*ApiRemoteClient) ContextGetRecords

func (rc *ApiRemoteClient) ContextGetRecords(flowId string) ([]model.ContextRecord, error)

func (*ApiRemoteClient) ContextUpdateRecord

func (rc *ApiRemoteClient) ContextUpdateRecord(flowId string, rec *model.ContextRecord) (string, error)

func (*ApiRemoteClient) ControlFlow

func (rc *ApiRemoteClient) ControlFlow(cmd string, id string) (string, error)

ControlFlow sends control command to flow manager. cmd - command to send , id - flow id

func (*ApiRemoteClient) DeleteFlow

func (rc *ApiRemoteClient) DeleteFlow(id string) (string, error)

func (*ApiRemoteClient) GetConnectorInstances

func (rc *ApiRemoteClient) GetConnectorInstances() ([]conmodel.InstanceView, error)

func (*ApiRemoteClient) GetConnectorPlugins

func (rc *ApiRemoteClient) GetConnectorPlugins() (map[string]conmodel.Plugin, error)

func (*ApiRemoteClient) GetConnectorTemplate

func (rc *ApiRemoteClient) GetConnectorTemplate(templateId string) (conmodel.Instance, error)

func (*ApiRemoteClient) GetFlowDefinition

func (rc *ApiRemoteClient) GetFlowDefinition(flowId string) (*model.FlowMeta, error)

func (*ApiRemoteClient) GetFlowLog

func (rc *ApiRemoteClient) GetFlowLog(limitLines int, flowId string) ([]utils.LogEntry, error)

func (*ApiRemoteClient) GetListOfFlows

func (rc *ApiRemoteClient) GetListOfFlows() ([]flow.FlowListItem, error)

func (*ApiRemoteClient) ImportFlow

func (rc *ApiRemoteClient) ImportFlow(flowDef []byte) (string, error)

func (*ApiRemoteClient) ImportFlowFromUrl

func (rc *ApiRemoteClient) ImportFlowFromUrl(url string, token string) (string, error)

func (*ApiRemoteClient) RegistryDeleteLocation

func (rc *ApiRemoteClient) RegistryDeleteLocation(id string) (string, error)

func (*ApiRemoteClient) RegistryDeleteThing

func (rc *ApiRemoteClient) RegistryDeleteThing(id string) (string, error)

func (*ApiRemoteClient) RegistryGetListOfDevices

func (rc *ApiRemoteClient) RegistryGetListOfDevices(locationId string) ([]model2.DeviceExtendedView, error)

func (*ApiRemoteClient) RegistryGetListOfLocations

func (rc *ApiRemoteClient) RegistryGetListOfLocations() ([]model2.Location, error)

func (*ApiRemoteClient) RegistryGetListOfServices

func (rc *ApiRemoteClient) RegistryGetListOfServices(serviceName, locationId, thingId, filterWithoutAlias string) ([]model2.ServiceExtendedView, error)

func (*ApiRemoteClient) RegistryGetListOfThings

func (rc *ApiRemoteClient) RegistryGetListOfThings(locationId string) ([]model2.ThingWithLocationView, error)

func (*ApiRemoteClient) RegistryGetService

func (rc *ApiRemoteClient) RegistryGetService(fullAddress string) (model2.ServiceExtendedView, error)

func (*ApiRemoteClient) RegistryGetThing

func (rc *ApiRemoteClient) RegistryGetThing(tech, address string) (model2.ThingExtendedView, error)

func (*ApiRemoteClient) RegistryUpdateLocation

func (rc *ApiRemoteClient) RegistryUpdateLocation(location *model2.Location) (string, error)

func (*ApiRemoteClient) RegistryUpdateLocationBin

func (rc *ApiRemoteClient) RegistryUpdateLocationBin(locationBin []byte) (string, error)

func (*ApiRemoteClient) RegistryUpdateService

func (rc *ApiRemoteClient) RegistryUpdateService(service *model2.Service) (string, error)

func (*ApiRemoteClient) RegistryUpdateServiceBin

func (rc *ApiRemoteClient) RegistryUpdateServiceBin(serviceBin []byte) (string, error)

func (*ApiRemoteClient) UpdateFlowBin

func (rc *ApiRemoteClient) UpdateFlowBin(flowDef []byte) (string, error)