service

package
v2.4.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 30, 2022 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

View Source 
const ContentQuery = "content"
View Source 
const ContentQueryAllValue = "all"
View Source 
const ContentQueryBaseValue = "base"
View Source 
const ContentQueryDefault = ContentQueryBaseValue

Variables

This section is empty.

Functions

func NewHTTP 

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

NewHTTP returns HTTP handler

Types

type APIsConfig 

type APIsConfig struct {
	HTTP HTTPConfig `yaml:"http" json:"http"`
}

func (*APIsConfig) Validate 

func (c *APIsConfig) Validate() error

type ClientsConfig 

type ClientsConfig struct {
	Eventbus               EventBusConfig                    `yaml:"eventBus" json:"eventBus"`
	GrpcGateway            GrpcGatewayConfig                 `yaml:"grpcGateway" json:"grpcGateway"`
	ResourceAggregate      ResourceAggregateConfig           `yaml:"resourceAggregate" json:"resourceAggregate"`
	Storage                StorageConfig                     `yaml:"storage" json:"storage"`
	Subscription           SubscriptionConfig                `yaml:"subscription" json:"subscription"`
	OpenTelemetryCollector http.OpenTelemetryCollectorConfig `yaml:"openTelemetryCollector" json:"openTelemetryCollector"`
}

func (*ClientsConfig) Validate 

func (c *ClientsConfig) Validate() error

type Config 

type Config struct {
	Log       log.Config    `yaml:"log" json:"log"`
	APIs      APIsConfig    `yaml:"apis" json:"apis"`
	Clients   ClientsConfig `yaml:"clients" json:"clients"`
	TaskQueue queue.Config  `yaml:"taskQueue" json:"taskQueue"`
}

Config represents application configuration

func (Config) String 

func (c Config) String() string

Return string representation of Config

func (*Config) Validate 

func (c *Config) Validate() error

type Device 

type Device struct {
	Device device.Device `json:"device"`
	Status Status        `json:"status"`
}

type EventBusConfig 

type EventBusConfig struct {
	NATS natsClient.Config `yaml:"nats" json:"nats"`
}

func (*EventBusConfig) Validate 

func (c *EventBusConfig) Validate() error

type GrpcGatewayConfig 

type GrpcGatewayConfig struct {
	Connection grpcClient.Config `yaml:"grpc" json:"grpc"`
}

func (*GrpcGatewayConfig) Validate 

func (c *GrpcGatewayConfig) Validate() error

type HTTPConfig 

type HTTPConfig struct {
	Connection    listener.Config  `yaml:",inline" json:",inline"`
	Authorization validator.Config `yaml:"authorization" json:"authorization"`
}

func (*HTTPConfig) Validate 

func (c *HTTPConfig) Validate() error

type HTTPSubscriptionConfig 

type HTTPSubscriptionConfig struct {
	ReconnectInterval time.Duration   `yaml:"reconnectInterval" json:"reconnectInterval"`
	EmitEventTimeout  time.Duration   `yaml:"emitEventTimeout" json:"emitEventTimeout"`
	TLS               cmClient.Config `yaml:"tls" json:"tls"`
}

func (*HTTPSubscriptionConfig) Validate 

func (c *HTTPSubscriptionConfig) Validate() error

type ListDevicesOfUserFunc 

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

type Representation 

type Representation struct {
	Href           string          `json:"href"`
	Representation interface{}     `json:"rep"`
	Status         commands.Status `json:"-"`
}

type RequestHandler 

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

RequestHandler for handling incoming request

func NewRequestHandler 

func NewRequestHandler(
	gwClient pbGRPC.GrpcGatewayClient,
	raClient *raClient.Client,
	subMgr *SubscriptionManager,
	emitEvent emitEventFunc,
) *RequestHandler

NewRequestHandler factory for new RequestHandler

func (*RequestHandler) GetDevices 

func (rh *RequestHandler) GetDevices(ctx context.Context, deviceIdFilter []string) ([]Device, error)
func (rh *RequestHandler) GetResourceLinks(ctx context.Context, deviceIdFilter []string) (map[string]schema.ResourceLinks, error)

func (*RequestHandler) RetrieveDevice 

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

func (*RequestHandler) RetrieveDeviceSubscription 

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

func (*RequestHandler) RetrieveDeviceWithContentQuery 

func (rh *RequestHandler) RetrieveDeviceWithContentQuery(ctx context.Context, w http.ResponseWriter, routeVars map[string]string, contentQuery string, encoder responseWriterEncoderFunc) (int, error)
func (rh *RequestHandler) RetrieveDeviceWithLinks(ctx context.Context, w http.ResponseWriter, deviceID string, encoder responseWriterEncoderFunc) (int, error)

func (*RequestHandler) RetrieveDeviceWithRepresentations 

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

func (*RequestHandler) RetrieveDevices 

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

func (*RequestHandler) RetrieveDevicesAll 

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

func (*RequestHandler) RetrieveDevicesBase 

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

func (*RequestHandler) RetrieveDevicesSubscription 

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

func (*RequestHandler) RetrieveDevicesWithContentQuery 

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

func (*RequestHandler) RetrieveResource 

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

func (*RequestHandler) RetrieveResourceBase 

func (rh *RequestHandler) RetrieveResourceBase(ctx context.Context, w http.ResponseWriter, resourceID *commands.ResourceId, encoder responseWriterEncoderFunc) (int, error)

func (*RequestHandler) RetrieveResourceSubscription 

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

func (*RequestHandler) RetrieveResourceWithContentQuery 

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

func (*RequestHandler) RetrieveResources 

func (rh *RequestHandler) RetrieveResources(ctx context.Context, resourceIdFilter []string, deviceIdFilter []string) (map[string][]Representation, error)

func (*RequestHandler) SubscribeToDevice 

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

func (*RequestHandler) SubscribeToDevices 

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

func (*RequestHandler) SubscribeToResource 

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

func (*RequestHandler) UnsubscribeFromDevice 

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

func (*RequestHandler) UnsubscribeFromDevices 

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

func (*RequestHandler) UnsubscribeFromResource 

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

func (*RequestHandler) UpdateResource 

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

type ResourceAggregateConfig 

type ResourceAggregateConfig struct {
	Connection grpcClient.Config `yaml:"grpc" json:"grpc"`
}

func (*ResourceAggregateConfig) Validate 

func (c *ResourceAggregateConfig) Validate() error

type RetrieveDeviceAllResponse 

type RetrieveDeviceAllResponse struct {
	Device
	Links []Representation `json:"links"`
}

type RetrieveDeviceContentAllResponse 

type RetrieveDeviceContentAllResponse struct {
	Device
	Links []Representation `json:"links"`
}

type RetrieveDeviceWithLinksResponse 

type RetrieveDeviceWithLinksResponse struct {
	Device
	Links []schema.ResourceLink `json:"links"`
}

type Server 

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

Server handle HTTP request

func New 

func New(ctx context.Context, config Config, fileWatcher *fsnotify.Watcher, logger log.Logger) (*Server, error)

New parses configuration and creates new Server with provided store and bus

func (*Server) Serve 

func (s *Server) Serve() error

Serve starts the service's HTTP server and blocks

func (*Server) Shutdown 

func (s *Server) Shutdown() error

Shutdown ends serving

type Status 

type Status string
const Status_OFFLINE Status = "offline"
const Status_ONLINE Status = "online"

type StorageConfig 

type StorageConfig struct {
	MongoDB mongodb.Config `yaml:"mongoDB" json:"mongoDb"`
}

func (*StorageConfig) Validate 

func (c *StorageConfig) Validate() error

type Subscription 

type Subscription interface {
	Cancel() (func(), error)
}

type SubscriptionConfig 

type SubscriptionConfig struct {
	HTTP HTTPSubscriptionConfig `yaml:"http" json:"http"`
}

func (*SubscriptionConfig) Validate 

func (c *SubscriptionConfig) Validate() error

type SubscriptionData 

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

func (*SubscriptionData) Connect 

func (s *SubscriptionData) Connect(ctx context.Context, emitEvent emitEventFunc, deleteSub func(ctx context.Context, subID, href string) (store.Subscription, error)) error

func (*SubscriptionData) Data 

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

func (*SubscriptionData) IncrementSequenceNumber 

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

func (*SubscriptionData) SetInitialized 

func (s *SubscriptionData) SetInitialized(ctx context.Context) error

func (*SubscriptionData) Store 

func (s *SubscriptionData) Store(sub Subscription)

func (*SubscriptionData) Subscription 

func (s *SubscriptionData) Subscription() Subscription

type SubscriptionManager 

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

func NewSubscriptionManager 

func NewSubscriptionManager(ctx context.Context, store store.Store, gwClient pb.GrpcGatewayClient, reconnectInterval time.Duration, emitEvent emitEventFunc) *SubscriptionManager

func (*SubscriptionManager) Connect 

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

func (*SubscriptionManager) DumpNotConnectedSubscriptionDatas 

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

func (*SubscriptionManager) Load 

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

func (*SubscriptionManager) LoadSubscriptions 

func (s *SubscriptionManager) LoadSubscriptions() error

func (*SubscriptionManager) PullOut 

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

func (*SubscriptionManager) Run 

func (s *SubscriptionManager) Run()

func (*SubscriptionManager) Store 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.