datamanager

Documentation

Overview

Package datamanager contains a gRPC based datamanager service server

Package datamanager contains a service type that can be used to capture data from a robot's components.

Package datamanager contains a gRPC based datamanager service server

Index

• Constants
• Variables
• func Named(name string) resource.Name
• func NewServer(s subtype.Service) pb.DataManagerServiceServer
• func NewUnimplementedInterfaceError(actual interface{}) error
• func WrapWithReconfigurable(s interface{}, name resource.Name) (resource.Reconfigurable, error)
• type Service
  • func NewClientFromConn(ctx context.Context, conn rpc.ClientConn, name string, logger golog.Logger) Service

Constants

const SubtypeName = resource.SubtypeName("data_manager")

SubtypeName is the name of the type of service.

Variables

var Subtype = resource.NewSubtype(
	resource.ResourceNamespaceRDK,
	resource.ResourceTypeService,
	SubtypeName,
)

Subtype is a constant that identifies the data manager service resource subtype.

Functions

func Named

func Named(name string) resource.Name

Named is a helper for getting the named datamanager's typed resource name.

func NewServer

func NewServer(s subtype.Service) pb.DataManagerServiceServer

NewServer constructs a datamanager gRPC service server.

func NewUnimplementedInterfaceError

func NewUnimplementedInterfaceError(actual interface{}) error

NewUnimplementedInterfaceError is used when there is a failed interface check.

func WrapWithReconfigurable

func WrapWithReconfigurable(s interface{}, name resource.Name) (resource.Reconfigurable, error)

WrapWithReconfigurable wraps a data_manager as a Reconfigurable.

Types

type Service

type Service interface {
	Sync(ctx context.Context, extra map[string]interface{}) error
	resource.Generic
}

Service defines what a Data Manager Service should expose to the users.

func NewClientFromConn

func NewClientFromConn(ctx context.Context, conn rpc.ClientConn, name string, logger golog.Logger) Service

NewClientFromConn constructs a new Client from connection passed in.