osc

Documentation

Overview

Package osc provides a package for sending and receiving OpenSoundControl messages. The package is implemented in pure Go.

Index

• func PrintMessage(msg *Message)
• type Bundle
  • func NewBundle(time time.Time) *Bundle
  • func (b *Bundle) Append(pck Packet) error
  • func (b *Bundle) MarshalBinary() ([]byte, error)
• type Client
  • func NewClient(ip string, port int) *Client
  • func (c *Client) IP() string
  • func (c *Client) Port() int
  • func (c *Client) Send(packet Packet) error
  • func (c *Client) SetIP(ip string)
  • func (c *Client) SetLocalAddr(ip string, port int) error
  • func (c *Client) SetPort(port int)
• type Dispatcher
• type Handler
• type HandlerFunc
  • func (f HandlerFunc) HandleMessage(msg *Message)
• type Message
  • func NewMessage(addr string, args ...interface{}) *Message
  • func ParseMessage(reader *bufio.Reader) (*Message, error)
  • func ParseMessageRaw(raw []byte) (*Message, error)
  • func (msg *Message) Append(args ...interface{})
  • func (msg *Message) Clear()
  • func (msg *Message) ClearData()
  • func (msg *Message) CountArguments() int
  • func (msg *Message) Equals(m *Message) bool
  • func (msg *Message) MarshalBinary() ([]byte, error)
  • func (msg *Message) Match(addr string) bool
  • func (msg *Message) String() string
  • func (msg *Message) TypeTags() (string, error)
• type Packet
  • func ParsePacket(msg string) (Packet, error)
• type Server
  • func (s *Server) CloseConnection() error
  • func (s *Server) ListenAndServe() error
  • func (s *Server) ReceivePacket(c net.PacketConn) (Packet, error)
  • func (s *Server) Serve(c net.PacketConn) error
• type StandardDispatcher
  • func NewStandardDispatcher() *StandardDispatcher
  • func (s *StandardDispatcher) AddMsgHandler(addr string, handler HandlerFunc) error
  • func (s *StandardDispatcher) Dispatch(packet Packet)
• type Timetag
  • func NewTimetag(ts time.Time) *Timetag
  • func NewTimetagFromTimetag(timetag uint64) *Timetag
  • func (t *Timetag) ExpiresIn() time.Duration
  • func (t *Timetag) FractionalSecond() uint32
  • func (t *Timetag) MarshalBinary() ([]byte, error)
  • func (t *Timetag) SecondsSinceEpoch() uint32
  • func (t *Timetag) SetTime(time time.Time)
  • func (t *Timetag) Time() time.Time
  • func (t *Timetag) TimeTag() uint64

Functions

func PrintMessage

func PrintMessage(msg *Message)

PrintMessage pretty prints an OSC message to the standard output.

Types

type Bundle

type Bundle struct {
	Timetag  Timetag
	Messages []*Message
	Bundles  []*Bundle
}

Bundle represents an OSC bundle. It consists of the OSC-string "#bundle" followed by an OSC Time Tag, followed by zero or more OSC bundle/message elements. The OSC-timetag is a 64-bit fixed point time tag. See http://opensoundcontrol.org/spec-1_0 for more information.

func NewBundle

func NewBundle(time time.Time) *Bundle

NewBundle returns an OSC Bundle. Use this function to create a new OSC Bundle.

func (*Bundle) Append

func (b *Bundle) Append(pck Packet) error

Append appends an OSC bundle or OSC message to the bundle.

func (*Bundle) MarshalBinary

func (b *Bundle) MarshalBinary() ([]byte, error)

MarshalBinary serializes the OSC bundle to a byte array with the following format: 1. Bundle string: '#bundle' 2. OSC timetag 3. Length of first OSC bundle element 4. First bundle element 5. Length of n OSC bundle element 6. n bundle element

type Client

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

Client enables you to send OSC packets. It sends OSC messages and bundles to the given IP address and port.

func NewClient

func NewClient(ip string, port int) *Client

NewClient creates a new OSC client. The Client is used to send OSC messages and OSC bundles over an UDP network connection. The `ip` argument specifies the IP address and `port` defines the target port where the messages and bundles will be send to.

func (*Client) IP

func (c *Client) IP() string

IP returns the IP address.

func (*Client) Port

func (c *Client) Port() int

Port returns the port.

func (*Client) Send

func (c *Client) Send(packet Packet) error

Send sends an OSC Bundle or an OSC Message.

func (*Client) SetIP

func (c *Client) SetIP(ip string)

SetIP sets a new IP address.

func (*Client) SetLocalAddr

func (c *Client) SetLocalAddr(ip string, port int) error

SetLocalAddr sets the local address.

func (*Client) SetPort

func (c *Client) SetPort(port int)

SetPort sets a new port.

type Dispatcher

type Dispatcher interface {
	Dispatch(packet Packet)
}

Dispatcher is an interface for an OSC message dispatcher. A dispatcher is responsible for dispatching received OSC messages.

type Handler

type Handler interface {
	HandleMessage(msg *Message)
}

Handler is an interface for message handlers. Every handler implementation for an OSC message must implement this interface.

type HandlerFunc

type HandlerFunc func(msg *Message)

HandlerFunc implements the Handler interface. Type definition for an OSC handler function.

func (HandlerFunc) HandleMessage

func (f HandlerFunc) HandleMessage(msg *Message)

HandleMessage calls itself with the given OSC Message. Implements the Handler interface.

type Message

type Message struct {
	Address   string
	Arguments []interface{}
}

Message represents a single OSC message. An OSC message consists of an OSC address pattern and zero or more arguments.

func NewMessage

func NewMessage(addr string, args ...interface{}) *Message

NewMessage returns a new Message. The address parameter is the OSC address.

func ParseMessage

func ParseMessage(reader *bufio.Reader) (*Message, error)

func ParseMessageRaw

func ParseMessageRaw(raw []byte) (*Message, error)

func (*Message) Append

func (msg *Message) Append(args ...interface{})

Append appends the given arguments to the arguments list.

func (*Message) Clear

func (msg *Message) Clear()

Clear clears the OSC address and all arguments.

func (*Message) ClearData

func (msg *Message) ClearData()

ClearData removes all arguments from the OSC Message.

func (*Message) CountArguments

func (msg *Message) CountArguments() int

CountArguments returns the number of arguments.

func (*Message) Equals

func (msg *Message) Equals(m *Message) bool

Equals returns true if the given OSC Message `m` is equal to the current OSC Message. It checks if the OSC address and the arguments are equal. Returns true if the current object and `m` are equal.

func (*Message) MarshalBinary

func (msg *Message) MarshalBinary() ([]byte, error)

MarshalBinary serializes the OSC message to a byte buffer. The byte buffer has the following format: 1. OSC Address Pattern 2. OSC Type Tag String 3. OSC Arguments

func (*Message) Match

func (msg *Message) Match(addr string) bool

Match returns true, if the OSC address pattern of the OSC Message matches the given address. The match is case sensitive!

func (*Message) String

func (msg *Message) String() string

String implements the fmt.Stringer interface.

func (*Message) TypeTags

func (msg *Message) TypeTags() (string, error)

TypeTags returns the type tag string.

type Packet

type Packet interface {
	encoding.BinaryMarshaler
}

Packet is the interface for Message and Bundle.

func ParsePacket

func ParsePacket(msg string) (Packet, error)

ParsePacket parses the given msg string and returns a Packet

type Server

type Server struct {
	Addr        string
	Dispatcher  Dispatcher
	ReadTimeout time.Duration
	// contains filtered or unexported fields
}

Server represents an OSC server. The server listens on Address and Port for incoming OSC packets and bundles.

func (*Server) CloseConnection

func (s *Server) CloseConnection() error

CloseConnection forcibly closes a server's connection.

This causes a "use of closed network connection" error the next time the server attempts to read from the connection.

func (*Server) ListenAndServe

func (s *Server) ListenAndServe() error

ListenAndServe retrieves incoming OSC packets and dispatches the retrieved OSC packets.

func (*Server) ReceivePacket

func (s *Server) ReceivePacket(c net.PacketConn) (Packet, error)

ReceivePacket listens for incoming OSC packets and returns the packet if one is received.

func (*Server) Serve

func (s *Server) Serve(c net.PacketConn) error

Serve retrieves incoming OSC packets from the given connection and dispatches retrieved OSC packets. If something goes wrong an error is returned.

type StandardDispatcher

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

StandardDispatcher is a dispatcher for OSC packets. It handles the dispatching of received OSC packets to Handlers for their given address.

func NewStandardDispatcher

func NewStandardDispatcher() *StandardDispatcher

NewStandardDispatcher returns an StandardDispatcher.

func (*StandardDispatcher) AddMsgHandler

func (s *StandardDispatcher) AddMsgHandler(addr string, handler HandlerFunc) error

AddMsgHandler adds a new message handler for the given OSC address.

func (*StandardDispatcher) Dispatch

func (s *StandardDispatcher) Dispatch(packet Packet)

Dispatch dispatches OSC packets. Implements the Dispatcher interface.

type Timetag

type Timetag struct {
	MinValue uint64 // Minimum value of an OSC Time Tag. Is always 1.
	// contains filtered or unexported fields
}

Timetag represents an OSC Time Tag. An OSC Time Tag is defined as follows: Time tags are represented by a 64 bit fixed point number. The first 32 bits specify the number of seconds since midnight on January 1, 1900, and the last 32 bits specify fractional parts of a second to a precision of about 200 picoseconds. This is the representation used by Internet NTP timestamps.

func NewTimetag

func NewTimetag(ts time.Time) *Timetag

NewTimetag returns a new OSC time tag object.

func NewTimetagFromTimetag

func NewTimetagFromTimetag(timetag uint64) *Timetag

NewTimetagFromTimetag creates a new Timetag from the given `timetag`.

func (*Timetag) ExpiresIn

func (t *Timetag) ExpiresIn() time.Duration

ExpiresIn calculates the number of seconds until the current time is the same as the value of the time tag. It returns zero if the value of the time tag is in the past.

func (*Timetag) FractionalSecond

func (t *Timetag) FractionalSecond() uint32

FractionalSecond returns the last 32 bits of the OSC time tag. Specifies the fractional part of a second.

func (*Timetag) MarshalBinary

func (t *Timetag) MarshalBinary() ([]byte, error)

MarshalBinary converts the OSC time tag to a byte array.

func (*Timetag) SecondsSinceEpoch

func (t *Timetag) SecondsSinceEpoch() uint32

SecondsSinceEpoch returns the first 32 bits (the number of seconds since the midnight 1900) from the OSC time tag.

func (*Timetag) SetTime

func (t *Timetag) SetTime(time time.Time)

SetTime sets the value of the OSC time tag.

func (*Timetag) Time

func (t *Timetag) Time() time.Time

Time returns the time.

func (*Timetag) TimeTag

func (t *Timetag) TimeTag() uint64

TimeTag returns the time tag value