board

package
v0.25.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Apr 11, 2024 License: AGPL-3.0 Imports: 21 Imported by: 17

Documentation

Overview

Package board defines the interfaces that typically live on a single-board computer such as a Raspberry Pi.

Besides the board itself, some other interfaces it defines are analog readers and digital interrupts.

Package board contains a gRPC based board client.

Package board contains a gRPC based Board service server.

Index

Constants

View Source 
const ServoRollingAverageWindow = 10

ServoRollingAverageWindow is how many entries to average over for servo ticks.

View Source 
const SubtypeName = "board"

SubtypeName is a constant that identifies the component resource API string "board".

Variables

View Source 
var API = resource.APINamespaceRDK.WithComponentType(SubtypeName)

API is a variable that identifies the component resource API.

Functions

func CreateStatus 

func CreateStatus(ctx context.Context, b Board, extra map[string]interface{}) (*commonpb.BoardStatus, error)

CreateStatus constructs a new up to date status from the given board. The operation can take time and be expensive, so it can be cancelled by the given context.

func Named 

func Named(name string) resource.Name

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

func NamesFromRobot 

func NamesFromRobot(r robot.Robot) []string

NamesFromRobot is a helper for getting all board names from the given Robot.

func NewRPCServiceServer added in v0.2.36 

func NewRPCServiceServer(coll resource.APIResourceCollection[Board]) interface{}

NewRPCServiceServer constructs an board gRPC service server. It is intentionally untyped to prevent use outside of tests.

func RemoveCallbacks added in v0.24.0 

func RemoveCallbacks(b Board, interrupts []string, ch chan Tick) error

RemoveCallbacks removes the callbacks from the given interrupts.

Types

type AnalogReader 

type AnalogReader interface {
	// Read reads off the current value.
	Read(ctx context.Context, extra map[string]interface{}) (int, error)
	Close(ctx context.Context) error
}

An AnalogReader represents an analog pin reader that resides on a board.

type AnalogReaderConfig added in v0.11.0 

type AnalogReaderConfig struct {
	Name              string `json:"name"`
	Pin               string `json:"pin"`
	AverageOverMillis int    `json:"average_over_ms,omitempty"`
	SamplesPerSecond  int    `json:"samples_per_sec,omitempty"`
}

AnalogReaderConfig describes the configuration of an analog reader on a board.

func (*AnalogReaderConfig) Validate added in v0.11.0 

func (config *AnalogReaderConfig) Validate(path string) error

Validate ensures all parts of the config are valid.

type AnalogSmoother 

type AnalogSmoother struct {
	Raw               AnalogReader
	AverageOverMillis int
	SamplesPerSecond  int
	// contains filtered or unexported fields
}

An AnalogSmoother smooths the readings out from an underlying reader.

func SmoothAnalogReader 

func SmoothAnalogReader(r AnalogReader, c AnalogReaderConfig, logger logging.Logger) *AnalogSmoother

SmoothAnalogReader wraps the given reader in a smoother.

func (*AnalogSmoother) Close 

func (as *AnalogSmoother) Close(ctx context.Context) error

Close stops the smoothing routine.

func (*AnalogSmoother) Read 

func (as *AnalogSmoother) Read(ctx context.Context, extra map[string]interface{}) (int, error)

Read returns the smoothed out reading.

func (*AnalogSmoother) Start 

func (as *AnalogSmoother) Start(ctx context.Context)

Start begins the smoothing routine that reads from the underlying analog reader.

type BasicDigitalInterrupt 

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

A BasicDigitalInterrupt records how many ticks/interrupts happen and can report when they happen to interested callbacks.

func (*BasicDigitalInterrupt) AddCallback 

func (i *BasicDigitalInterrupt) AddCallback(c chan Tick)

AddCallback adds a listener for interrupts.

func (*BasicDigitalInterrupt) Close added in v0.2.36 

func (i *BasicDigitalInterrupt) Close(ctx context.Context) error

Close does nothing.

func (*BasicDigitalInterrupt) Reconfigure added in v0.2.36 

func (i *BasicDigitalInterrupt) Reconfigure(conf DigitalInterruptConfig) error

Reconfigure reconfigures this digital interrupt with a new formula.

func (*BasicDigitalInterrupt) RemoveCallback 

func (i *BasicDigitalInterrupt) RemoveCallback(c chan Tick)

RemoveCallback removes a listener for interrupts.

func (*BasicDigitalInterrupt) Tick 

func (i *BasicDigitalInterrupt) Tick(ctx context.Context, high bool, nanoseconds uint64) error

Tick records an interrupt and notifies any interested callbacks. See comment on the DigitalInterrupt interface for caveats.

func (*BasicDigitalInterrupt) Ticks 

func (i *BasicDigitalInterrupt) Ticks(ctx context.Context, num int, now uint64) error

Ticks is really just for testing.

func (*BasicDigitalInterrupt) Value 

func (i *BasicDigitalInterrupt) Value(ctx context.Context, extra map[string]interface{}) (int64, error)

Value returns the amount of ticks that have occurred.

type Board 

type Board interface {
	resource.Resource

	// AnalogReaderByName returns an analog reader by name.
	AnalogReaderByName(name string) (AnalogReader, bool)

	// DigitalInterruptByName returns a digital interrupt by name.
	DigitalInterruptByName(name string) (DigitalInterrupt, bool)

	// GPIOPinByName returns a GPIOPin by name.
	GPIOPinByName(name string) (GPIOPin, error)

	// AnalogReaderNames returns the names of all known analog readers.
	AnalogReaderNames() []string

	// DigitalInterruptNames returns the names of all known digital interrupts.
	DigitalInterruptNames() []string

	// Status returns the current status of the board. Usually you
	// should use the CreateStatus helper instead of directly calling
	// this.
	Status(ctx context.Context, extra map[string]interface{}) (*commonpb.BoardStatus, error)

	// SetPowerMode sets the board to the given power mode. If
	// provided, the board will exit the given power mode after
	// the specified duration.
	SetPowerMode(ctx context.Context, mode pb.PowerMode, duration *time.Duration) error

	// WriteAnalog writes an analog value to a pin on the board.
	WriteAnalog(ctx context.Context, pin string, value int32, extra map[string]interface{}) error

	// StreamTicks starts a stream of digital interrupt ticks.
	StreamTicks(ctx context.Context, interrupts []string, ch chan Tick, extra map[string]interface{}) error
}

A Board represents a physical general purpose board that contains various components such as analog readers, and digital interrupts.

func FromDependencies 

func FromDependencies(deps resource.Dependencies, name string) (Board, error)

FromDependencies is a helper for getting the named board from a collection of dependencies.

func FromRobot 

func FromRobot(r robot.Robot, name string) (Board, error)

FromRobot is a helper for getting the named board from the given Robot.

func NewClientFromConn 

func NewClientFromConn(
	ctx context.Context,
	conn rpc.ClientConn,
	remoteName string,
	name resource.Name,
	logger logging.Logger,
) (Board, error)

NewClientFromConn constructs a new Client from connection passed in.

type DigitalInterrupt 

type DigitalInterrupt interface {
	// Value returns the current value of the interrupt which is
	// based on the type of interrupt.
	Value(ctx context.Context, extra map[string]interface{}) (int64, error)

	// Tick is to be called either manually if the interrupt is a proxy to some real
	// hardware interrupt or for tests.
	// nanoseconds is from an arbitrary point in time, but always increasing and always needs
	// to be accurate.
	Tick(ctx context.Context, high bool, nanoseconds uint64) error

	// AddCallback adds a callback to be sent a low/high value to when a tick
	// happens.
	AddCallback(c chan Tick)

	// RemoveCallback removes a listener for interrupts.
	RemoveCallback(c chan Tick)

	Close(ctx context.Context) error
}

A DigitalInterrupt represents a configured interrupt on the board that when interrupted, calls the added callbacks.

type DigitalInterruptConfig 

type DigitalInterruptConfig struct {
	Name string `json:"name"`
	Pin  string `json:"pin"`
}

DigitalInterruptConfig describes the configuration of digital interrupt for a board.

func (*DigitalInterruptConfig) Validate 

func (config *DigitalInterruptConfig) Validate(path string) error

Validate ensures all parts of the config are valid.

type GPIOPin 

type GPIOPin interface {
	// Set sets the pin to either low or high.
	Set(ctx context.Context, high bool, extra map[string]interface{}) error

	// Get gets the high/low state of the pin.
	Get(ctx context.Context, extra map[string]interface{}) (bool, error)

	// PWM gets the pin's given duty cycle.
	PWM(ctx context.Context, extra map[string]interface{}) (float64, error)

	// SetPWM sets the pin to the given duty cycle.
	SetPWM(ctx context.Context, dutyCyclePct float64, extra map[string]interface{}) error

	// PWMFreq gets the PWM frequency of the pin.
	PWMFreq(ctx context.Context, extra map[string]interface{}) (uint, error)

	// SetPWMFreq sets the given pin to the given PWM frequency. For Raspberry Pis,
	// 0 will use a default PWM frequency of 800.
	SetPWMFreq(ctx context.Context, freqHz uint, extra map[string]interface{}) error
}

A GPIOPin represents an individual GPIO pin on a board.

type I2CConfig 

type I2CConfig struct {
	Name string `json:"name"`
	Bus  string `json:"bus"`
}

I2CConfig enumerates a specific, shareable I2C bus.

func (*I2CConfig) Validate 

func (config *I2CConfig) Validate(path string) error

Validate ensures all parts of the config are valid.

type ReconfigurableDigitalInterrupt added in v0.2.36 

type ReconfigurableDigitalInterrupt interface {
	DigitalInterrupt
	Reconfigure(cfg DigitalInterruptConfig) error
}

A ReconfigurableDigitalInterrupt is a simple reconfigurable digital interrupt that expects reconfiguration within the same type.

func CreateDigitalInterrupt 

func CreateDigitalInterrupt(cfg DigitalInterruptConfig) (ReconfigurableDigitalInterrupt, error)

CreateDigitalInterrupt is a factory method for creating a specific DigitalInterrupt based on the given config. If no type is specified, a BasicDigitalInterrupt is returned.

type SPIConfig 

type SPIConfig struct {
	Name      string `json:"name"`
	BusSelect string `json:"bus_select"` // "0" or "1" for main/aux in libpigpio
}

SPIConfig enumerates a specific, shareable SPI bus.

func (*SPIConfig) Validate 

func (config *SPIConfig) Validate(path string) error

Validate ensures all parts of the config are valid.

type Tick added in v0.2.19 

type Tick struct {
	Name             string
	High             bool
	TimestampNanosec uint64
}

Tick represents a signal received by an interrupt pin. This signal is communicated via registered channel to the various drivers. Depending on board implementation there may be a wraparound in timestamp values past 4294967295000 nanoseconds (~72 minutes) if the value was originally in microseconds as a 32-bit integer. The timestamp in nanoseconds of the tick SHOULD ONLY BE USED FOR CALCULATING THE TIME ELAPSED BETWEEN CONSECUTIVE TICKS AND NOT AS AN ABSOLUTE TIMESTAMP.

Source Files

View all Source files

Directories

Path Synopsis
Package beaglebone implements a beaglebone based board.
 Package beaglebone implements a beaglebone based board.
Package customlinux implements a board running Linux.
 Package customlinux implements a board running Linux.
Package fake implements a fake board.
 Package fake implements a fake board.
Package genericlinux implements a Linux-based board making heavy use of sysfs (https://en.wikipedia.org/wiki/Sysfs).
 Package genericlinux implements a Linux-based board making heavy use of sysfs (https://en.wikipedia.org/wiki/Sysfs).
buses
Package buses is for I2C and SPI boards that run Linux.
 Package buses is for I2C and SPI boards that run Linux.
hat
pca9685
Package pca9685 implements a PCA9685 HAT.
 Package pca9685 implements a PCA9685 HAT.
Package jetson implements a jetson-based board.
 Package jetson implements a jetson-based board.
Package mcp3008helper is shared code for hooking an MCP3008 ADC up to a board.
 Package mcp3008helper is shared code for hooking an MCP3008 ADC up to a board.
Package numato is for numato IO boards.
 Package numato is for numato IO boards.
Package odroid implements a odroid based board.
 Package odroid implements a odroid based board.
Package orangepi implements a orangepi based board.
 Package orangepi implements a orangepi based board.
pi
Package pi implements a Board and its related interfaces for a Raspberry Pi.
 Package pi implements a Board and its related interfaces for a Raspberry Pi.
common
Package picommon contains shared information for supported and non-supported pi boards.
 Package picommon contains shared information for supported and non-supported pi boards.
Package pi5 implements a raspberry pi 5 board.
 Package pi5 implements a raspberry pi 5 board.
Package register registers all relevant Boards and also API specific functions
 Package register registers all relevant Boards and also API specific functions
Package ti implements a ti based board.
 Package ti implements a ti based board.
Package upboard implements an Intel based board.
 Package upboard implements an Intel based board.

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.