streams

type Forwarder struct {
	URL    string
	Client *http.Client // defaults to HTTPClient
}

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

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

type RecorderOptions struct {
	// RadioIDs limits recording to these streams; empty means every stream
	// on the account, including ones added later.
	RadioIDs []int
	// ForwardTo, when set, receives each live play and health event as a
	// callback-shaped POST.
	ForwardTo string
	// OnPlay is called once for every play this recorder sees after its
	// start-up backfill: live plays, and plays a reconnect backfill finds.
	// A play is reported even when another recorder writing the same store
	// saved it first. It may be called from several goroutines at once.
	OnPlay func(streamstore.Play)
	// OnHealth is called for every health event.
	OnHealth func(streamstore.HealthEvent)
	// Logf receives connection problems and other notes (default: discard).
	Logf func(format string, args ...any)
	// Owned, when set, is checked with every heartbeat: an error means
	// this recorder no longer owns its profile (see Lock.Check), and Run
	// stops, logging why.
	Owned func() error
}

type Service struct {
	Path     string // where the file goes
	Content  string // file contents (UTF-8; Windows task XML is written as UTF-16)
	Activate string // the command that turns it on
	// StartsNow reports whether Activate also starts the recorder right
	// away (systemd and launchd); a Windows scheduled task first runs at
	// the next logon.
	StartsNow bool
}