vehicle

Documentation

Index

• Constants
• type BitarrayParser
  • func NewBitarrayParser(names map[uint16][]string) BitarrayParser
  • func (parser *BitarrayParser) Decode(id uint16, data io.Reader) (map[string]bool, error)
  • func (parser *BitarrayParser) Encode(id uint16, enabled map[string]bool, data io.Writer) error
• type Config
• type EmptyFrom
  • func NewEmptyFrom() EmptyFrom
  • func (rf EmptyFrom) ReadFrom(r io.Reader) ([]byte, error)
• type MessageConfig
• type NetworkConfig
  • func (networkConfig NetworkConfig) GetKeepAliveInterval() *time.Duration
  • func (networkConfig NetworkConfig) GetWriteTimeout() *time.Duration
• type ProtectionFrom
  • func NewProtectionFrom() ProtectionFrom
  • func (rf ProtectionFrom) ReadFrom(r io.Reader) ([]byte, error)
• type StateOrderReaderFrom
  • func NewStateOrderReaderFrom() StateOrderReaderFrom
  • func (rf StateOrderReaderFrom) ReadFrom(r io.Reader) ([]byte, error)
• type StateSpaceReaderFrom
  • func NewStateSpaceReaderFrom(rows int, cols int, varSize int) StateSpaceReaderFrom
  • func (rf StateSpaceReaderFrom) ReadFrom(r io.Reader) ([]byte, error)
• type Vehicle
  • func New(args VehicleConstructorArgs) Vehicle
  • func (vehicle *Vehicle) Listen(updateChan chan<- models.PacketUpdate, ...)
  • func (vehicle *Vehicle) SendOrder(order models.Order) error
• type VehicleConstructorArgs

Constants

const OrderByteSize = 2

const OrderNumByteSize = 1

const (
	UPDATE_CHAN_BUF_SIZE = 100
)

Types

type BitarrayParser

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

func NewBitarrayParser

func NewBitarrayParser(names map[uint16][]string) BitarrayParser

func (*BitarrayParser) Decode

func (parser *BitarrayParser) Decode(id uint16, data io.Reader) (map[string]bool, error)

func (*BitarrayParser) Encode

func (parser *BitarrayParser) Encode(id uint16, enabled map[string]bool, data io.Writer) error

type Config

type Config struct {
	Boards       []string             `toml:"boards,omitempty"`
	Network      NetworkConfig        `toml:"network"`
	PacketParser packet_parser.Config `toml:"packet_parser"`
	Messages     MessageConfig        `toml:"messages"`
}

type EmptyFrom

type EmptyFrom struct{}

func NewEmptyFrom

func NewEmptyFrom() EmptyFrom

func (EmptyFrom) ReadFrom

func (rf EmptyFrom) ReadFrom(r io.Reader) ([]byte, error)

type MessageConfig

type MessageConfig struct {
	InfoIdKey              string `toml:"info_id_key"`
	WarningIdKey           string `toml:"warning_id_key"`
	FaultIdKey             string `toml:"fault_id_key"`
	BlcuAckId              string `toml:"blcu_ack_id_key"`
	AddStateOrdersIdKey    string `toml:"add_state_orders_id_key"`
	RemoveStateOrdersIdKey string `toml:"remove_state_orders_id_key"`
}

type NetworkConfig

type NetworkConfig struct {
	TcpClientTag string `toml:"tcp_client_tag"`
	TcpServerTag string `toml:"tcp_server_tag"`

	UdpTag            string  `toml:"udp_tag"`
	Mtu               uint    `toml:"mtu"`
	KeepAliveProbes   int     `toml:"keep_alive_probes"`
	Interface         string  `toml:"interface"`
	KeepAliveInterval *string `toml:"keep_alive_interval,omitempty"`
	WriteTimeout      *string `toml:"timeout,omitempty"`
}

func (NetworkConfig) GetKeepAliveInterval

func (networkConfig NetworkConfig) GetKeepAliveInterval() *time.Duration

func (NetworkConfig) GetWriteTimeout

func (networkConfig NetworkConfig) GetWriteTimeout() *time.Duration

type ProtectionFrom

type ProtectionFrom struct{}

func NewProtectionFrom

func NewProtectionFrom() ProtectionFrom

func (ProtectionFrom) ReadFrom

func (rf ProtectionFrom) ReadFrom(r io.Reader) ([]byte, error)

type StateOrderReaderFrom

type StateOrderReaderFrom struct{}

func NewStateOrderReaderFrom

func NewStateOrderReaderFrom() StateOrderReaderFrom

func (StateOrderReaderFrom) ReadFrom

func (rf StateOrderReaderFrom) ReadFrom(r io.Reader) ([]byte, error)

type StateSpaceReaderFrom

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

func NewStateSpaceReaderFrom

func NewStateSpaceReaderFrom(rows int, cols int, varSize int) StateSpaceReaderFrom

func (StateSpaceReaderFrom) ReadFrom

func (rf StateSpaceReaderFrom) ReadFrom(r io.Reader) ([]byte, error)

type Vehicle

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

func New

func New(args VehicleConstructorArgs) Vehicle

func (*Vehicle) Listen

func (vehicle *Vehicle) Listen(updateChan chan<- models.PacketUpdate, transmittedOrderChan chan<- models.PacketUpdate, messageChan chan<- any, blcuAckChan chan<- struct{}, stateOrdersChan chan<- message_parser.StateOrdersAdapter, stateSpaceChan chan<- models.StateSpace)

func (*Vehicle) SendOrder

func (vehicle *Vehicle) SendOrder(order models.Order) error

type VehicleConstructorArgs

type VehicleConstructorArgs struct {
	Boards             []pod_data.Board
	Info               info.Info
	PodData            pod_data.PodData
	Config             Config
	OnConnectionChange func(string, bool)
}