proxy

type AddStreamProxyInput struct {
	App    string `json:"app"`    // 应用名
	Stream string `json:"stream"` // 流 id
	// MediaServerID             string `json:"media_server_id"`              // 媒体服务器 id
	SourceURL                 string `json:"source_url"`                   // 原始 url
	TimeoutS                  int    `json:"timeout_s"`                    // 超时时间(秒)
	Transport                 int    `json:"transport"`                    // rtsp 拉流方式(0:udp;1:tcp)
	Enabled                   bool   `json:"enabled"`                      // 是否启用
	EnabledAudio              bool   `json:"enabled_audio"`                // 是否启用音频
	EnabledRemoveNoneReader   bool   `json:"enabled_remove_none_reader"`   // 是否无人观看时删除
	EnabledDisabledNoneReader bool   `json:"enabled_disabled_none_reader"` // 是否无人观看时禁用
	StreamKey                 string `json:"stream_key"`                   // 拉流代理时 zlm 返回的 key，用于停止拉流代理
	Pulling                   bool   `json:"pulling"`                      // 拉流状态
}

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

type EditStreamProxyInput struct {
	App                       string `json:"app"`                          // 应用名
	Stream                    string `json:"stream"`                       // 流 id
	MediaServerID             string `json:"media_server_id"`              // 媒体服务器 id
	SourceURL                 string `json:"source_url"`                   // 原始 url
	TimeoutS                  int    `json:"timeout_s"`                    // 超时时间(秒)
	Transport                 int    `json:"transport"`                    // rtsp 拉流方式(0:udp;1:tcp)
	Enabled                   bool   `json:"enabled"`                      // 是否启用
	EnabledAudio              bool   `json:"enabled_audio"`                // 是否启用音频
	EnabledRemoveNoneReader   bool   `json:"enabled_remove_none_reader"`   // 是否无人观看时删除
	EnabledDisabledNoneReader bool   `json:"enabled_disabled_none_reader"` // 是否无人观看时禁用
	StreamKey                 string `json:"stream_key"`                   // 拉流代理时 zlm 返回的 key，用于停止拉流代理
	Pulling                   bool   `json:"pulling"`                      // 拉流状态
}

type FindStreamProxyInput struct {
	web.PagerFilter
	App                       string `form:"app"`                          // 应用名
	Stream                    string `form:"stream"`                       // 流 id
	MediaServerID             string `form:"media_server_id"`              // 媒体服务器 id
	SourceURL                 string `form:"source_url"`                   // 原始 url
	TimeoutS                  int    `form:"timeout_s"`                    // 超时时间(秒)
	Transport                 int    `form:"transport"`                    // rtsp 拉流方式(0:udp;1:tcp)
	Enabled                   bool   `form:"enabled"`                      // 是否启用
	EnabledAudio              bool   `form:"enabled_audio"`                // 是否启用音频
	EnabledRemoveNoneReader   bool   `form:"enabled_remove_none_reader"`   // 是否无人观看时删除
	EnabledDisabledNoneReader bool   `form:"enabled_disabled_none_reader"` // 是否无人观看时禁用
	StreamKey                 string `form:"stream_key"`                   // 拉流代理时 zlm 返回的 key，用于停止拉流代理
	Pulling                   bool   `form:"pulling"`                      // 拉流状态
}

type Storer interface {
	StreamProxy() StreamProxyStorer
}

type StreamProxy struct {
	ID                      string   `gorm:"primaryKey" json:"id"`
	CreatedAt               orm.Time `gorm:"column:created_at;notNull;default:CURRENT_TIMESTAMP;comment:创建时间" json:"created_at"`                   // 创建时间
	UpdatedAt               orm.Time `gorm:"column:updated_at;notNull;default:CURRENT_TIMESTAMP;comment:更新时间" json:"updated_at"`                   // 更新时间
	App                     string   `gorm:"column:app;uniqueIndex:idx_stream_proxys_app_stream;notNull;default:'';comment:应用名" json:"app"`        // 应用名
	Stream                  string   `gorm:"column:stream;uniqueIndex:idx_stream_proxys_app_stream;notNull;default:'';comment:流 id" json:"stream"` // 流 id
	MediaServerID           string   `gorm:"column:media_server_id;notNull;default:'';comment:媒体服务器 id" json:"media_server_id"`                    // 媒体服务器 id
	SourceURL               string   `gorm:"column:source_url;notNull;default:'';comment:原始 url" json:"source_url"`                                // 原始 url
	TimeoutS                int      `gorm:"column:timeout_s;notNull;default:0;comment:超时时间(秒)" json:"timeout_s"`                                  // 超时时间(秒)
	Transport               int      `gorm:"column:transport;notNull;default:0;comment:rtsp 拉流方式(0:tcp，1:udp，2:组播)" json:"transport"`              // rtsp 拉流方式
	Enabled                 bool     `gorm:"column:enabled;notNull;default:FALSE;comment:是否启用" json:"enabled"`                                     // 是否启用
	EnabledAudio            bool     `gorm:"column:enabled_audio;notNull;default:FALSE;comment:是否启用音频" json:"enabled_audio"`                       // 是否启用音频
	EnabledRemoveNoneReader bool     ``                                                                                                            // 是否无人观看时删除
	/* 132-byte string literal not displayed */
	EnabledDisabledNoneReader bool `` // 是否无人观看时禁用
	/* 136-byte string literal not displayed */
	StreamKey string `` // 拉流代理时 zlm 返回的 key，用于停止拉流代理
	/* 130-byte string literal not displayed */
	Pulling bool `gorm:"column:pulling;notNull;default:FALSE;comment:拉流状态" json:"pulling"` // 拉流状态
}

type StreamProxyStorer interface {
	Find(context.Context, *[]*StreamProxy, orm.Pager, ...orm.QueryOption) (int64, error)
	Get(context.Context, *StreamProxy, ...orm.QueryOption) error
	Add(context.Context, *StreamProxy) error
	Edit(context.Context, *StreamProxy, func(*StreamProxy), ...orm.QueryOption) error
	Del(context.Context, *StreamProxy, ...orm.QueryOption) error
}