Documentation
¶
Index ¶
- type Connection
- func (c *Connection) Next(ctx context.Context) (*Message, error)
- func (c *Connection) ReceiveBufferSize() int
- func (c *Connection) SendApp(ctx context.Context, messageCommand pvdata.PVByte, payload interface{}) error
- func (c *Connection) SendCtrl(ctx context.Context, messageCommand pvdata.PVByte, payloadSize pvdata.PVInt) error
- type Message
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct {
Version pvdata.PVByte
Direction pvdata.PVUByte
// contains filtered or unexported fields
}
func New ¶
func New(conn io.ReadWriter, direction pvdata.PVUByte) *Connection
func (*Connection) ReceiveBufferSize ¶
func (c *Connection) ReceiveBufferSize() int
func (*Connection) SendApp ¶
func (c *Connection) SendApp(ctx context.Context, messageCommand pvdata.PVByte, payload interface{}) error
SendApp sends an application message on the wire. payload must be something that can be passed to pvdata.Encode; i.e. it must be either an instance of PVField or a pointer to something that can be converted to a PVField. If payload is a []byte it will be sent raw. It is safe to call SendApp from any goroutine.
Source Files
Click to show internal directories.
Click to hide internal directories.