papipes

README

papipes

Pulseaudio client library in Golang for creating virtual sinks and sources

Usage

package main

import (
	"github.com/akosmarton/papipes"
)

func main() {
	source := papipes.Source{
		Filename: "/tmp/source.sock",
		Properties: map[string]interface{}{
			"device.description": "Virtual Input",
		},
	}
	source.Open()
	defer source.Close()

	sink := papipes.Sink{
		Filename: "/tmp/sink.sock",
		Properties: map[string]interface{}{
			"device.description": "Virtual Output",
		},
	}
	sink.Open()
	defer sink.Close()

	p := make([]byte, 0)

	source.Write(p)
	sink.Read(p)
}

Documentation

Index

• type Sink
  • func GetActiveSinks() ([]*Sink, error)
  • func (s *Sink) Close() error
  • func (s *Sink) GetProperty(key string) interface{}
  • func (s *Sink) IsOpen() bool
  • func (s *Sink) Open() error
  • func (s *Sink) Read(p []byte) (n int, err error)
  • func (s *Sink) SetProperty(key string, value interface{}) *Sink
• type Source
  • func GetActiveSources() ([]*Source, error)
  • func (s *Source) Close() error
  • func (s *Source) GetProperty(key string) interface{}
  • func (s *Source) IsOpen() bool
  • func (s *Source) Open() error
  • func (s *Source) SetProperty(key string, value interface{}) *Source
  • func (s *Source) Write(p []byte) (n int, err error)

Types

type Sink

type Sink struct {
	Filename string
	Name     string
	Format   string
	Rate     int
	Channels int
	// ChannelMap
	UseSystemClockForTiming bool
	// contains filtered or unexported fields
}

func GetActiveSinks

func GetActiveSinks() ([]*Sink, error)

func (*Sink) Close

func (s *Sink) Close() error

func (*Sink) GetProperty

func (s *Sink) GetProperty(key string) interface{}

func (*Sink) IsOpen

func (s *Sink) IsOpen() bool

func (*Sink) Open

func (s *Sink) Open() error

func (*Sink) Read

func (s *Sink) Read(p []byte) (n int, err error)

func (*Sink) SetProperty

func (s *Sink) SetProperty(key string, value interface{}) *Sink

type Source

type Source struct {
	Filename string
	Name     string
	Format   string
	Rate     int
	Channels int
	// contains filtered or unexported fields
}

func GetActiveSources

func GetActiveSources() ([]*Source, error)

func (*Source) Close

func (s *Source) Close() error

func (*Source) GetProperty

func (s *Source) GetProperty(key string) interface{}

func (*Source) IsOpen

func (s *Source) IsOpen() bool

func (*Source) Open

func (s *Source) Open() error

func (*Source) SetProperty

func (s *Source) SetProperty(key string, value interface{}) *Source

func (*Source) Write

func (s *Source) Write(p []byte) (n int, err error)