plex

README

Plex

plexd

User-space UDP broker to replace IP multicasts where they are not supported by forwarding packets to subscribers manually. For example, let's say you have a video stream and you want to deliver it in real-time via RTP to your friends - just use Plex!

Building

Go to cmd/plexd directory and build with go build. Take a look at example config at examples/config.toml.

License

This code is under MIT license. See LICENSE for more information

Copyright (C) 2020 Hexawolf (hexawolf at hexanet dot dev)

Documentation

Overview

plex - User-space UDP broker to replace IP multicasts Copyright (C) 2020 Hexawolf <hexawolf@hexanet.dev> See LICENSE file for more info

Index

• Constants
• type Plex
  • func NewPlex(bsize uint16, logger *log.Logger) (mp Plex, err error)
  • func (mp *Plex) Close() (err error)
  • func (mp *Plex) Exists(name string) (sub bool, pub bool)
  • func (mp *Plex) ListenUDP(laddr string) (err error)
  • func (mp *Plex) Subscribe(name string, sub io.WriteCloser, pub io.ReadCloser)
  • func (mp *Plex) SubscribeUDP(_raddr string) (err error)
  • func (mp *Plex) Unsubscribe(name string)

Constants

const UDP = "udp"

Types

type Plex

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

func NewPlex

func NewPlex(bsize uint16, logger *log.Logger) (mp Plex, err error)

NewPlex creates a new UDP multicast instance, binding a listener to supplied local address (_laddr) and allocating buffer with given size (_bsize).

func (*Plex) Close

func (mp *Plex) Close() (err error)

func (*Plex) Exists

func (mp *Plex) Exists(name string) (sub bool, pub bool)

func (*Plex) ListenUDP

func (mp *Plex) ListenUDP(laddr string) (err error)

func (*Plex) Subscribe

func (mp *Plex) Subscribe(name string, sub io.WriteCloser, pub io.ReadCloser)

func (*Plex) SubscribeUDP

func (mp *Plex) SubscribeUDP(_raddr string) (err error)

func (*Plex) Unsubscribe

func (mp *Plex) Unsubscribe(name string)