server

type CalcBitrate struct {
	Bitrate int64

	Channel      *Channel
	OutputStream *OutputStream
	// contains filtered or unexported fields
}

type Channel struct {
	URL           string
	Queue         *pubsub.Queue
	Lock          *sync.RWMutex
	Conn          *rtmp.Conn
	OutputStreams []OutputStream
	WaitGroup     *sync.WaitGroup
	RxBitrate     int64
}

type OutputStream struct {
	URL       string
	Channel   chan bool
	TxBitrate float64
}

type PubSubMessage struct {
	ChannelURL      string `json:"channel_url"`
	OutputStreamURL string `json:"output_stream_url"`
	Action          string `json:"action"`
}

type Server struct {
	RedisAddr  string
	RtmpAddr   string
	FFMPEGPath string
	S3Bucket   string
	Lock       *sync.RWMutex
	Conn       *rtmp.Conn
}