ristgo

type PeerConfig struct {
	Address    string //Address is the address in the form: rist://@1.2.3.4:5678 where @ indicates listening
	Interface  string //Interface: optional interface which to use for multicast reception
	Psk        string //Psk: optional PSK secret
	PskKeySize int    //PskKeySize: optional PSK keysize (128 or 256)
	CName      string //CName: optional cname to be transmitted on this connection
}

type Receiver interface {
	//Start starts the rist receiver
	Start() error
	//AddPeer adds a new connection to the rist instance
	AddPeer(config *PeerConfig) (int, error)
	//RemovePeer removes a connection from the rist session
	RemovePeer(id int) error
	//ConfigureFlow sets up a Flow to read data from
	ConfigureFlow(destinationPort uint16) (ReceiverFlow, error)
	//Destroy stops the rist session and destroys all associated resources.
	Destroy()
}

type ReceiverConfig struct {
	//RistProfile RIST profile to use for this session
	RistProfile libristwrapper.RistProfile
	//LoggingCallbackFunction is an optional logging callback function
	LoggingCallbackFunction libristwrapper.LogCallbackFunc
	//StatsCallbackFunction is an optional stats callback function
	StatsCallbackFunction libristwrapper.StatsCallbackFunc
	//StatsInterval is the interval in ms at which the StatsCallbackFunction will be called
	StatsInterval int
	//RecoveryBufferSize is the size in ms of the recovery buffer
	RecoveryBufferSize int
}

type ReceiverFlow interface {
	Read(data []byte) (n int, err error)                   //Read data conforms to io.Reader
	ReadWithTimeout(timeout time.Duration) ([]byte, error) //ReadWithTimeout reads data with timeout
	DataChannel() <-chan []byte                            //DataChannel returns a data channel for reading
	Destroy() error                                        //Destroy s the ReceiverFlow
}