ros_sensor_subscriber

Documentation

Index

• Variables
• func NewRosSensorConsumer(ctx context.Context, deps resource.Dependencies, conf resource.Config, ...) (sensor.Sensor, error)
• type RosBridgeConfig
  • func (cfg *RosBridgeConfig) Validate(path string) ([]string, error)
• type RosSensorSubscriber
  • func (r *RosSensorSubscriber) Close(ctx context.Context) error
  • func (*RosSensorSubscriber) DoCommand(ctx context.Context, cmd map[string]interface{}) (map[string]interface{}, error)
  • func (r *RosSensorSubscriber) Readings(ctx context.Context, extra map[string]interface{}) (map[string]interface{}, error)
  • func (r *RosSensorSubscriber) Reconfigure(ctx context.Context, deps resource.Dependencies, conf resource.Config) error
• type SensorConfig

Variables

var Model = resource.NewModel(utils.Namespace, "ros", "sensor-subscriber")

Functions

func NewRosSensorConsumer

func NewRosSensorConsumer(ctx context.Context, deps resource.Dependencies, conf resource.Config, logger logging.Logger) (sensor.Sensor, error)

Types

type RosBridgeConfig

type RosBridgeConfig struct {
	PrimaryUri string        `json:"primary_uri"`
	Host       string        `json:"host"`
	Sensor     *SensorConfig `json:"sensor"`
}

func (*RosBridgeConfig) Validate

func (cfg *RosBridgeConfig) Validate(path string) ([]string, error)

type RosSensorSubscriber

type RosSensorSubscriber struct {
	resource.Named
	// contains filtered or unexported fields
}

func (*RosSensorSubscriber) Close

func (r *RosSensorSubscriber) Close(ctx context.Context) error

Close implements resource.Resource.

func (*RosSensorSubscriber) DoCommand

func (*RosSensorSubscriber) DoCommand(ctx context.Context, cmd map[string]interface{}) (map[string]interface{}, error)

DoCommand implements resource.Resource.

func (*RosSensorSubscriber) Readings

func (r *RosSensorSubscriber) Readings(ctx context.Context, extra map[string]interface{}) (map[string]interface{}, error)

Readings implements resource.Sensor.

func (*RosSensorSubscriber) Reconfigure

func (r *RosSensorSubscriber) Reconfigure(ctx context.Context, deps resource.Dependencies, conf resource.Config) error

Reconfigure implements resource.Resource.

type SensorConfig

type SensorConfig struct {
	Topic string `json:"topic"`
	Type  string `json:"message_type"`
}