canbus

Documentation

Index

• Constants
• type CanBus
• type CanFrameParser
• type NetworkIf
  • func NewIface(iface string) *NetworkIf
  • func (i *NetworkIf) Connect(wg *sync.WaitGroup) (<-chan *can.Frame, error)
  • func (i *NetworkIf) Disconnect() error
  • func (i *NetworkIf) Send(message *can.Frame) error
• type Serial
  • func NewSerial(port string, baudrate int) *Serial
  • func NewSerialCustomParser(port string, baudrate int, parser CanFrameParser) *Serial
  • func (s *Serial) Connect(wg *sync.WaitGroup) (<-chan *can.Frame, error)
  • func (s *Serial) Disconnect() error
  • func (s *Serial) Send(message *can.Frame) error
• type TcpClient
  • func NewTcpClient(address string, port uint16) *TcpClient
  • func NewTcpClientCustomParser(address string, port uint16, parser CanFrameParser) *TcpClient
  • func (c *TcpClient) Connect(wg *sync.WaitGroup) (<-chan *can.Frame, error)
  • func (c *TcpClient) Disconnect() error
  • func (c *TcpClient) Send(message *can.Frame) error

Constants

const (
	SerialCanDefaultPort     = "/dev/ttyS1234"
	SerialCanDefaultBaudrate = 25000

	SerialCanParity   = serial.NoParity
	SerialCanDataBits = 8
	SerialCanStopBits = serial.OneStopBit
)

const (
	CanInterfaceDefaultName = "can0"
)

const CanbusBufferSize = 2048

const (
	TCP_CAN_DEFAULT_PORT = 9001
)

const (
	TcpCanNetworkType = "tcp"
)

Types

type CanBus

type CanBus interface {
	Connect(wg *sync.WaitGroup) (<-chan *can.Frame, error)
	Disconnect() error
	Send(message *can.Frame) error
}

type CanFrameParser

type CanFrameParser interface {
	Unmarshal(in []byte) *can.Frame
	Marshal(*can.Frame) []byte
}

type NetworkIf

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

func NewIface

func NewIface(iface string) *NetworkIf

func (*NetworkIf) Connect

func (i *NetworkIf) Connect(wg *sync.WaitGroup) (<-chan *can.Frame, error)

func (*NetworkIf) Disconnect

func (i *NetworkIf) Disconnect() error

func (*NetworkIf) Send

func (i *NetworkIf) Send(message *can.Frame) error

type Serial

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

func NewSerial

func NewSerial(port string, baudrate int) *Serial

func NewSerialCustomParser

func NewSerialCustomParser(port string, baudrate int, parser CanFrameParser) *Serial

func (*Serial) Connect

func (s *Serial) Connect(wg *sync.WaitGroup) (<-chan *can.Frame, error)

func (*Serial) Disconnect

func (s *Serial) Disconnect() error

func (*Serial) Send

func (s *Serial) Send(message *can.Frame) error

type TcpClient

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

func NewTcpClient

func NewTcpClient(address string, port uint16) *TcpClient

func NewTcpClientCustomParser

func NewTcpClientCustomParser(address string, port uint16,
	parser CanFrameParser) *TcpClient

func (*TcpClient) Connect

func (c *TcpClient) Connect(wg *sync.WaitGroup) (<-chan *can.Frame, error)

func (*TcpClient) Disconnect

func (c *TcpClient) Disconnect() error

func (*TcpClient) Send

func (c *TcpClient) Send(message *can.Frame) error