streamsuite

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

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

type Stream struct {
	UUID      string
	Channel   *models.LineupChannel
	StreamURL string

	Transport   StreamTransport
	StartTime   *time.Time
	PromLabels  []string
	StopNow     chan bool `json:"-"`
	LastWroteAt *time.Time
	// contains filtered or unexported fields
}

type StreamTransport interface {
	Type() string
	Headers() http.Header
	Start(ctx context.Context, streamURL string) (io.ReadCloser, error)
	Stop() error
}