orion

Documentation

Index

• func Split(entities []Entity) ([]fiware.EntityType, []fiware.Entity)
• func SubsMap(subs []fiware.Subscription) map[string]fiware.Subscription
• type Entity
  • func Merge(types []fiware.EntityType, values []fiware.Entity) []Entity
  • func (e Entity) Attrs() map[string]EntityAttr
  • func (e Entity) ID() string
  • func (e Entity) Type() string
• type EntityAttr
• type Orion
  • func New(orionURL string) (*Orion, error)
  • func (o *Orion) DeleteEntities(client keystone.HTTPClient, headers http.Header, ents []fiware.Entity, ...) error
  • func (o *Orion) DeleteSuscriptions(client keystone.HTTPClient, headers http.Header, subs []fiware.Subscription, ...) error
  • func (o *Orion) Entities(client keystone.HTTPClient, headers http.Header, idPattern string, ...) ([]fiware.EntityType, []fiware.Entity, error)
  • func (o *Orion) PostSuscriptions(client keystone.HTTPClient, headers http.Header, subs []fiware.Subscription, ...) error
  • func (o *Orion) Registrations(client keystone.HTTPClient, headers http.Header) ([]fiware.Registration, error)
  • func (o *Orion) Subscriptions(client keystone.HTTPClient, headers http.Header, ...) ([]fiware.Subscription, error)
  • func (o *Orion) UpdateEntities(client keystone.HTTPClient, headers http.Header, ents []Entity, batchSize int, ...) error

Functions

func Split

func Split(entities []Entity) ([]fiware.EntityType, []fiware.Entity)

Split a merged Entity into fiware.entityType and fiware.Entity

func SubsMap

func SubsMap(subs []fiware.Subscription) map[string]fiware.Subscription

Turns a list of subscriptions into a map indexed by description

Types

type Entity

type Entity map[string]json.RawMessage

Entity representa una entidad tal como la ve la API

func Merge

func Merge(types []fiware.EntityType, values []fiware.Entity) []Entity

Merge fiware EntityType with Entity to build full Entity

func (Entity) Attrs

func (e Entity) Attrs() map[string]EntityAttr

func (Entity) ID

func (e Entity) ID() string

func (Entity) Type

func (e Entity) Type() string

type EntityAttr

type EntityAttr struct {
	Type     string          `json:"type"`
	Value    json.RawMessage `json:"value"`
	Metadata json.RawMessage `json:"metadata,omitempty"`
}

type Orion

type Orion struct {
	URL                *url.URL
	AllowUnknownFields bool
}

Orion manages connection to the Context Broker

func New

func New(orionURL string) (*Orion, error)

New Orion instance

func (*Orion) DeleteEntities

func (o *Orion) DeleteEntities(client keystone.HTTPClient, headers http.Header, ents []fiware.Entity, batchSize int) error

DeleteEntities deletes a list of entities from Orion

func (*Orion) DeleteSuscriptions

func (o *Orion) DeleteSuscriptions(client keystone.HTTPClient, headers http.Header, subs []fiware.Subscription, useDescription bool) error

DeleteSuscriptions deletes a list of suscriptions from Orion

func (*Orion) Entities

func (o *Orion) Entities(client keystone.HTTPClient, headers http.Header, idPattern string, entityType string, simpleQuery string, maximum int) ([]fiware.EntityType, []fiware.Entity, error)

Entities reads the list of entities from the Context Broker

func (*Orion) PostSuscriptions

func (o *Orion) PostSuscriptions(client keystone.HTTPClient, headers http.Header, subs []fiware.Subscription, ep map[string]string, useDescription bool) error

PostSuscriptions posts a list of suscriptions to orion

func (*Orion) Registrations

func (o *Orion) Registrations(client keystone.HTTPClient, headers http.Header) ([]fiware.Registration, error)

Suscriptions reads the list of suscriptions from the Context Broker

func (*Orion) Subscriptions

func (o *Orion) Subscriptions(client keystone.HTTPClient, headers http.Header, notifEndpoints map[string]string) ([]fiware.Subscription, error)

Subscriptions reads the list of suscriptions from the Context Broker

func (*Orion) UpdateEntities

func (o *Orion) UpdateEntities(client keystone.HTTPClient, headers http.Header, ents []Entity, batchSize int, overrideMetadata bool) error

UpdateEntities updates a list of entities