sink

type FileSink struct {
	uploader.Uploader

	*config.FileConfig
	// contains filtered or unexported fields
}

type Image struct {
	Name      string    `json:"name"`
	Timestamp time.Time `json:"timestamp"`
	Size      int64     `json:"size"`
}

type ImageManifest struct {
	Manifest `json:",inline"`

	Images []*Image `json:"images"`
}

type ImageSink struct {
	uploader.Uploader

	*config.ImageConfig
	// contains filtered or unexported fields
}

type Manifest struct {
	EgressID          string `json:"egress_id,omitempty"`
	RoomID            string `json:"room_id,omitempty"`
	RoomName          string `json:"room_name,omitempty"`
	Url               string `json:"url,omitempty"`
	StartedAt         int64  `json:"started_at,omitempty"`
	EndedAt           int64  `json:"ended_at,omitempty"`
	PublisherIdentity string `json:"publisher_identity,omitempty"`
	TrackID           string `json:"track_id,omitempty"`
	TrackKind         string `json:"track_kind,omitempty"`
	TrackSource       string `json:"track_source,omitempty"`
	AudioTrackID      string `json:"audio_track_id,omitempty"`
	VideoTrackID      string `json:"video_track_id,omitempty"`
	SegmentCount      int64  `json:"segment_count,omitempty"`
}

type SegmentSink struct {
	uploader.Uploader

	*config.SegmentConfig
	// contains filtered or unexported fields
}

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

type Sink interface {
	Start() error
	Close() error
	Cleanup()
}

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