service

Sep 29, 2020

Changes in this version

+ const ContentQuery

+ const ContentQueryAllValue

+ const ContentQueryBaseValue

+ const ContentQueryDefault

+ const HrefKey

+ func NewHTTP(requestHandler *RequestHandler, authInterceptor kitNetHttp.Interceptor) *http.Server

+ type Config struct

+ EmitEventTimeout time.Duration

+ FQDN string

+ JwksURL string

+ OAuth manager.Config

+ ReconnectInterval time.Duration

+ ResourceDirectoryAddr string

+ func (c Config) String() string

+ type Device struct

+ Device schema.Device

+ Status Status

+ type DialCertManager = interface

+ GetClientTLSConfig func() *tls.Config

+ type ErrFunc func(err error)

+ type Event struct

+ DeviceID string

+ EventType events.EventType

+ Href string

+ Id string

+ Representation interface{}

+ type GoroutinePoolGoFunc func(func()) error

+ type GoroutinePoolHandler struct

+ func NewGoroutinePoolHandler(goroutinePoolGo GoroutinePoolGoFunc, eventsHandler Handler, errFunc ErrFunc) *GoroutinePoolHandler

+ func (ep *GoroutinePoolHandler) Handle(ctx context.Context, event Event) (err error)

+ type Handler interface

+ Handle func(ctx context.Context, iter Iter) (err error)

+ type Iter interface

+ Err func() error

+ Next func(ctx context.Context, event *Event) bool

+ type ListDevicesOfUserFunc func(ctx context.Context, correlationID, userID, accessToken string) (deviceIds []string, statusCode int, err error)

+ type ListenCertManager = interface

+ GetServerTLSConfig func() *tls.Config

+ type Representation struct

+ Href string

+ Representation interface{}

+ Status pbGRPC.Status

+ type RequestHandler struct

+ func NewRequestHandler(rdClient pbGRPC.GrpcGatewayClient, subMgr *SubscriptionManager, ...) *RequestHandler

+ func (rh *RequestHandler) GetDevices(ctx context.Context, deviceIdsFilter []string) ([]Device, error)

+ func (rh *RequestHandler) GetResourceLinks(ctx context.Context, deviceIdsFilter []string) (map[string]schema.ResourceLinks, error)

+ func (rh *RequestHandler) RetrieveDevice(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) RetrieveDeviceSubscription(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) RetrieveDeviceWithContentQuery(ctx context.Context, w http.ResponseWriter, routeVars map[string]string, ...) (int, error)

+ func (rh *RequestHandler) RetrieveDeviceWithLinks(ctx context.Context, w http.ResponseWriter, deviceID string, ...) (int, error)

+ func (rh *RequestHandler) RetrieveDeviceWithRepresentations(ctx context.Context, w http.ResponseWriter, deviceID string, ...) (int, error)

+ func (rh *RequestHandler) RetrieveDevices(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) RetrieveDevicesAll(ctx context.Context, w http.ResponseWriter, encoder responseWriterEncoderFunc) (int, error)

+ func (rh *RequestHandler) RetrieveDevicesBase(ctx context.Context, w http.ResponseWriter, encoder responseWriterEncoderFunc) (int, error)

+ func (rh *RequestHandler) RetrieveDevicesSubscription(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) RetrieveDevicesWithContentQuery(ctx context.Context, w http.ResponseWriter, routeVars map[string]string, ...) (statusCode int, err error)

+ func (rh *RequestHandler) RetrieveResource(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) RetrieveResourceBase(ctx context.Context, w http.ResponseWriter, resourceID pbGRPC.ResourceId, ...) (int, error)

+ func (rh *RequestHandler) RetrieveResourceSubscription(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) RetrieveResourceWithContentQuery(ctx context.Context, w http.ResponseWriter, routeVars map[string]string, ...) (int, error)

+ func (rh *RequestHandler) RetrieveResourcesValues(ctx context.Context, resourceIdsFilter []*pbGRPC.ResourceId, ...) (map[string][]Representation, error)

+ func (rh *RequestHandler) SubscribeToDevice(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) SubscribeToDevices(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) SubscribeToResource(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) UnsubscribeFromDevice(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) UnsubscribeFromDevices(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) UnsubscribeFromResource(w http.ResponseWriter, r *http.Request)

+ func (rh *RequestHandler) UpdateResource(w http.ResponseWriter, r *http.Request)

+ type RetrieveDeviceAllResponse struct

+ Links []Representation

+ type RetrieveDeviceContentAllResponse struct

+ Links []Representation

+ type RetrieveDeviceWithLinksResponse struct

+ Links []schema.ResourceLink

+ type Server struct

+ func New(config Config, dialCertManager DialCertManager, ...) *Server

+ func (s *Server) Serve() error

+ func (s *Server) Shutdown() error

+ type Status string

+ const Status_OFFLINE

+ const Status_ONLINE

+ type Subscription interface

+ Cancel func() (func(), error)

+ type SubscriptionData struct

+ func (s *SubscriptionData) Connect(ctx context.Context, emitEvent emitEventFunc, ...) error

+ func (s *SubscriptionData) Data() store.Subscription

+ func (s *SubscriptionData) IncrementSequenceNumber(ctx context.Context) (uint64, error)

+ func (s *SubscriptionData) Store(sub Subscription)

+ func (s *SubscriptionData) Subscription() Subscription

+ type SubscriptionManager struct

+ func NewSubscriptionManager(ctx context.Context, store store.Store, gwClient pb.GrpcGatewayClient, ...) *SubscriptionManager

+ func (s *SubscriptionManager) Connect(ID string) error

+ func (s *SubscriptionManager) DumpNotConnectedSubscriptionDatas() map[string]*SubscriptionData

+ func (s *SubscriptionManager) Load(ID, userID string) (store.Subscription, bool)

+ func (s *SubscriptionManager) LoadSubscriptions() error

+ func (s *SubscriptionManager) PullOut(ctx context.Context, ID, userID string) (store.Subscription, error)

+ func (s *SubscriptionManager) Run()

+ func (s *SubscriptionManager) Store(ctx context.Context, sub store.Subscription) error

+ type SubscriptionResponse struct

+ SubscriptionID string