service

package

v0.0.0-...-1c3cffe Latest Latest Go to latest Published: Apr 6, 2020 License: MIT Imports: 29 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/go-ocf/resource-directory

Documentation ¶

Index ¶

func NewResourceCtx() func(context.Context) (eventstore.Model, error)
type Config
- func (c Config) String() string
type Device
type DeviceDirectory
- func NewDeviceDirectory(projection *Projection, deviceIds []string) *DeviceDirectory
- func (dd *DeviceDirectory) GetDevices(ctx context.Context, req *pbDD.GetDevicesRequest, ...) (statusCode codes.Code, err error)
type Projection
- func NewProjection(ctx context.Context, name string, store eventstore.EventStore, ...) (*Projection, error)
- func (p *Projection) GetResourceCtxs(ctx context.Context, resourceIdsFilter, typeFilter, deviceIds strings.Set) (map[string]map[string]*resourceCtx, error)
type RequestHandler
- func NewRequestHandler(authClient pbAS.AuthorizationServiceClient, projection *Projection) *RequestHandler
type ResourceDirectory
- func NewResourceDirectory(projection *Projection, deviceIds []string) *ResourceDirectory
- func (rd *ResourceDirectory) GetResourceLinks(ctx context.Context, in *pbRD.GetResourceLinksRequest, ...) (statusCode codes.Code, err error)
type ResourceShadow
- func NewResourceShadow(projection *Projection, deviceIds []string) *ResourceShadow
- func (rd *ResourceShadow) RetrieveResourcesValues(ctx context.Context, req *pbRS.RetrieveResourcesValuesRequest, ...) (statusCode codes.Code, err error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewResourceCtx ¶

func NewResourceCtx() func(context.Context) (eventstore.Model, error)

Types ¶

type Config ¶

type Config struct {
	grpc.Config

	FQDN           string `envconfig:"FQDN" default:"grpc-gateway"`
	AuthServerAddr string `envconfig:"AUTH_SERVER_ADDRESS" default:"127.0.0.1:9100"`
}

Config represent application configuration

func (Config) String ¶

func (c Config) String() string

String return string representation of Config

type Device ¶

type Device struct {
	pbDD.Device
	// contains filtered or unexported fields
}

type DeviceDirectory ¶

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

func NewDeviceDirectory ¶

func NewDeviceDirectory(projection *Projection, deviceIds []string) *DeviceDirectory

NewDeviceDirectory creates new device directory.

func (*DeviceDirectory) GetDevices ¶

func (dd *DeviceDirectory) GetDevices(ctx context.Context, req *pbDD.GetDevicesRequest, responseHandler func(*pbDD.Device) error) (statusCode codes.Code, err error)

GetDevices provides list state of devices.

type Projection ¶

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

func NewProjection ¶

func NewProjection(ctx context.Context, name string, store eventstore.EventStore, subscriber eventbus.Subscriber, expiration time.Duration) (*Projection, error)

func (*Projection) GetResourceCtxs ¶

func (p *Projection) GetResourceCtxs(ctx context.Context, resourceIdsFilter, typeFilter, deviceIds strings.Set) (map[string]map[string]*resourceCtx, error)

type RequestHandler ¶

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

RequestHandler for handling incoming request

func NewRequestHandler ¶

func NewRequestHandler(authClient pbAS.AuthorizationServiceClient, projection *Projection) *RequestHandler

NewRequestHandler factory for new RequestHandler

func (*RequestHandler) GetDevices ¶

func (r *RequestHandler) GetDevices(req *pbDD.GetDevicesRequest, srv pbDD.DeviceDirectory_GetDevicesServer) error

func (*RequestHandler) GetResourceLinks ¶

func (r *RequestHandler) GetResourceLinks(req *pbRD.GetResourceLinksRequest, srv pbRD.ResourceDirectory_GetResourceLinksServer) error

func (*RequestHandler) GetUsersDevices ¶

func (r *RequestHandler) GetUsersDevices(ctx context.Context, authCtx *pbCQRS.AuthorizationContext, deviceIdsFilter []string) ([]string, error)

func (*RequestHandler) RetrieveResourcesValues ¶

func (r *RequestHandler) RetrieveResourcesValues(req *pbRS.RetrieveResourcesValuesRequest, srv pbRS.ResourceShadow_RetrieveResourcesValuesServer) error

type ResourceDirectory ¶

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

func NewResourceDirectory ¶

func NewResourceDirectory(projection *Projection, deviceIds []string) *ResourceDirectory

func (*ResourceDirectory) GetResourceLinks ¶

func (rd *ResourceDirectory) GetResourceLinks(ctx context.Context, in *pbRD.GetResourceLinksRequest, responseHandler func(*pbRD.ResourceLink) error) (statusCode codes.Code, err error)

type ResourceShadow ¶

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

func NewResourceShadow ¶

func NewResourceShadow(projection *Projection, deviceIds []string) *ResourceShadow

func (*ResourceShadow) RetrieveResourcesValues ¶

func (rd *ResourceShadow) RetrieveResourcesValues(ctx context.Context, req *pbRS.RetrieveResourcesValuesRequest, responseHandler func(*pbRS.ResourceValue) error) (statusCode codes.Code, err error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL