dao

package
v0.0.0-...-83adff0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AllOnAirStream 

type AllOnAirStream struct {
	M map[string]*OnAirStreamList `json:"m,omitempty"`
}

type Dao 

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

Dao dao

func New 

func New(c *conf.Config) (dao *Dao)

New init mysql db

func (*Dao) AddCacheMultiStreamInfo 

func (d *Dao) AddCacheMultiStreamInfo(c context.Context, res map[int64]*model.StreamFullInfo) error

AddCacheMultiStreamInfo 批量增加redis

func (*Dao) AddCacheStreamFullInfo 

func (d *Dao) AddCacheStreamFullInfo(c context.Context, id int64, stream *model.StreamFullInfo) error

AddCacheStreamFullInfo 修改缓存数据

func (*Dao) AddCacheStreamRIDByName 

func (d *Dao) AddCacheStreamRIDByName(c context.Context, sname string, stream *model.StreamFullInfo) error

AddCacheStreamRIDByName 增加缓存

func (*Dao) CacheMultiStreamInfo 

func (d *Dao) CacheMultiStreamInfo(c context.Context, rids []int64) (res map[int64]*model.StreamFullInfo, err error)

CacheMultiStreamInfo 批量从redis中获取数据

func (*Dao) CacheStreamFullInfo 

func (d *Dao) CacheStreamFullInfo(c context.Context, rid int64, sname string) (res *model.StreamFullInfo, err error)

CacheStreamFullInfo 从缓存取流信息， 可传入流名， 也可以传入rid

func (*Dao) CacheStreamRIDByName 

func (d *Dao) CacheStreamRIDByName(c context.Context, sname string) (res *model.StreamFullInfo, err error)

CacheStreamRIDByName 根据流名查房间号

func (*Dao) ChangeDefaultVendor 

func (d *Dao) ChangeDefaultVendor(c context.Context, roomID int64, newVendor int64) error

ChangeDefaultVendor 切换默认上行

func (*Dao) ChangeMainStreamOptions 

func (d *Dao) ChangeMainStreamOptions(c context.Context, roomID int64, newOptions int64, options int64) error

ChangeMainStreamOptions 切换Options

func (*Dao) ClearMainStreaming 

func (d *Dao) ClearMainStreaming(c context.Context, roomID int64, newoptions int64, options int64) error

ClearMainStreaming 清理互推标记

func (*Dao) Close 

func (d *Dao) Close()

Close close the resource.

func (*Dao) CreateBackupStream 

func (d *Dao) CreateBackupStream(ctx context.Context, bs *model.BackupStream) (*model.BackupStream, error)

CreateBackupStream 创建备用流

func (*Dao) CreateNewStream 

func (d *Dao) CreateNewStream(c context.Context, stream *model.MainStream) (*model.MainStream, error)

CreateNewStream used to create new Stream record

func (*Dao) CreateOfficialStream 

func (d *Dao) CreateOfficialStream(c context.Context, infos []*model.OfficialStream) (err error)

CreateOfficialStream 创建正式流

func (*Dao) CreateUpStreamDispatch 

func (d *Dao) CreateUpStreamDispatch(c context.Context, info *model.UpStreamInfo) error

CreateUpStreamDispatch 创建一条上行调度信息

func (*Dao) DefaultUpStreamInfo 

func (d *Dao) DefaultUpStreamInfo(c context.Context, rid int64) (sname string, origin int64, err error)

func (*Dao) DeleteLastCDNFromCache 

func (d *Dao) DeleteLastCDNFromCache(c context.Context, rid int64) error

DeleteLastCDNFromCache 删除上一次到cdn

func (*Dao) DeleteStreamByRIDFromCache 

func (d *Dao) DeleteStreamByRIDFromCache(c context.Context, rid int64) (err error)

DeleteStreamByRIDFromCache 删除一个房间的的缓存信息

func (*Dao) GetBackupRoom 

func (d *Dao) GetBackupRoom(ctx context.Context) (res map[int64]int64, err error)

GetBackupRoom 临时获取所有的房间号

func (*Dao) GetBackupStreamByRoomID 

func (d *Dao) GetBackupStreamByRoomID(ctx context.Context, rid int64) (infos []*model.BackupStream, err error)

GetBackupStreamByRoomID 根据roomid获取备用流信息

func (*Dao) GetBackupStreamByStreamName 

func (d *Dao) GetBackupStreamByStreamName(c context.Context, sn string) (*model.BackupStream, error)

GetBackupStreamByStreamName 根据流名查询备用流

func (*Dao) GetChangeLogByRoomID 

func (d *Dao) GetChangeLogByRoomID(c context.Context, rid int64, limit int64) (infos []*model.StreamChangeLog, err error)

GetChangeLogByRoomID 查询日志

func (*Dao) GetChangeSrcFromCache 

func (d *Dao) GetChangeSrcFromCache(c context.Context, rid int64) (int64, error)

GetChangeSrcFromCache 查询上一次cdn

func (*Dao) GetLastCDNFromCache 

func (d *Dao) GetLastCDNFromCache(c context.Context, rid int64) (int64, error)

GetLastCDNFromCache 查询上一次cdn

func (*Dao) GetMainStreamFromDB 

func (d *Dao) GetMainStreamFromDB(c context.Context, roomID int64, streamName string) (*model.MainStream, error)

GetMainStreamFromDB 从DB中读取流信息 roomID 和 streamName 可以只传一个，传哪个就用哪个查询，否则必须两者对应

func (*Dao) GetMultiBackupStreamByRID 

func (d *Dao) GetMultiBackupStreamByRID(c context.Context, rids []int64) (infos []*model.BackupStream, err error)

GetMultiBackupStreamByRID 批量查询备用流

func (*Dao) GetMultiMainStreamFromDB 

func (d *Dao) GetMultiMainStreamFromDB(c context.Context, rids []int64) (mainStream []*model.MainStream, err error)

GetMultiMainStreamFromDB 批量从main-stream读取

func (*Dao) GetMultiOfficalStreamByRID 

func (d *Dao) GetMultiOfficalStreamByRID(c context.Context, rids []int64) (infos []*model.OfficialStream, err error)

GetMultiOfficalStreamByRID 批量获取

func (*Dao) GetOfficialStreamByName 

func (d *Dao) GetOfficialStreamByName(c context.Context, name string) (infos []*model.OfficialStream, err error)

GetOfficialStreamByName 根据流名查流信息， 可以获取多条记录

func (*Dao) GetOfficialStreamByRoomID 

func (d *Dao) GetOfficialStreamByRoomID(c context.Context, rid int64) (infos []*model.OfficialStream, err error)

GetOfficialStreamByRoomID 根据roomid查询流信息, 可以获取多条记录

func (*Dao) GetSummaryUpStreamCity 

func (d *Dao) GetSummaryUpStreamCity(c context.Context, start int64, end int64) (infos []*model.SummaryUpStreamRtmp, err error)

GetSummaryUpStreamCity 得到City统计信息

func (*Dao) GetSummaryUpStreamCountry 

func (d *Dao) GetSummaryUpStreamCountry(c context.Context, start int64, end int64) (infos []*model.SummaryUpStreamRtmp, err error)

GetSummaryUpStreamCountry 得到Country统计信息

func (*Dao) GetSummaryUpStreamISP 

func (d *Dao) GetSummaryUpStreamISP(c context.Context, start int64, end int64) (infos []*model.SummaryUpStreamRtmp, err error)

GetSummaryUpStreamISP 得到ISP统计信息

func (*Dao) GetSummaryUpStreamPlatform 

func (d *Dao) GetSummaryUpStreamPlatform(c context.Context, start int64, end int64) (infos []*model.SummaryUpStreamRtmp, err error)

GetSummaryUpStreamPlatform 得到Platform统计信息

func (*Dao) GetSummaryUpStreamRtmp 

func (d *Dao) GetSummaryUpStreamRtmp(c context.Context, start int64, end int64) (infos []*model.SummaryUpStreamRtmp, err error)

GetSummaryUpStreamRtmp 得到统计信息

func (*Dao) InsertChangeLog 

func (d *Dao) InsertChangeLog(c context.Context, change *model.StreamChangeLog) error

InsertChangeLog 插入日志

func (*Dao) LoadLiveStreamList 

func (d *Dao) LoadLiveStreamList(c context.Context, rids []int64) map[int64]bool

loadLiveStreamList 判断流是否在播

func (*Dao) MainStreamNotify 

func (d *Dao) MainStreamNotify(c context.Context, roomID, vendor int64, isOpen bool, isOrigin bool, options int64, newoptions int64) error

MainStreamNotify 开关播回调 @param roomID 房间号 @param vendor 上行 CDN 位 @param isOpen 是否是开播 true 开播 false 关播 @param isOrigin 是否是原始上行 true 是 false 转推

func (*Dao) MultiStreamInfo 

func (d *Dao) MultiStreamInfo(c context.Context, rids []int64) (res map[int64]*model.StreamFullInfo, err error)

MultiStreamInfo 批量接口

func (*Dao) NewRequst 

func (d *Dao) NewRequst(c context.Context, method string, url string, query url.Values, body []byte, headers map[string]string, resp interface{}) error

NewRequst http 请求

func (*Dao) OriginUpStreamInfo 

func (d *Dao) OriginUpStreamInfo(c context.Context, rid int64) (sname string, origin int64, err error)

OriginUpStreamInfo 原始上行流名和src

func (*Dao) OriginUpStreamInfoBySName 

func (d *Dao) OriginUpStreamInfoBySName(c context.Context, sname string) (rid int64, origin int64, err error)

OriginUpStreamInfoBySName 查询流的上行，正在推流上行和默认上行; 包含备用流

func (*Dao) Ping 

func (d *Dao) Ping(c context.Context) error

Ping dao ping

func (*Dao) RawMultiStreamInfo 

func (d *Dao) RawMultiStreamInfo(c context.Context, rids []int64) (res map[int64]*model.StreamFullInfo, err error)

RawMultiStreamInfo 批量查询流信息

func (*Dao) RawStreamFullInfo 

func (d *Dao) RawStreamFullInfo(c context.Context, id int64, sname string) (res *model.StreamFullInfo, err error)

RawStreamFullInfo 直接从数据库中查询流信息，可传入流名， 也可传入rid

func (*Dao) RawStreamRIDByName 

func (d *Dao) RawStreamRIDByName(c context.Context, sname string) (res *model.StreamFullInfo, err error)

RawStreamRIDByName 查询rid

func (*Dao) SetBackupStreamStreamingStatus 

func (d *Dao) SetBackupStreamStreamingStatus(c context.Context, p *model.StreamingNotifyParam, bs *model.BackupStream, open bool) (*model.BackupStream, error)

SetBackupStreamStreamingStatus

func (*Dao) SetOriginStreamingStatus 

func (d *Dao) SetOriginStreamingStatus(c context.Context, rid int64, src, from, to int) error

SetOriginStreamingStatus 用于设置 老版本数据结构的 推流状态

func (*Dao) StoreLiveStreamList 

func (d *Dao) StoreLiveStreamList()

StoreLiveStreamList 刷新在播列表缓存

func (*Dao) StreamFullInfo 

func (d *Dao) StreamFullInfo(c context.Context, rid int64, sname string) (res *model.StreamFullInfo, err error)

StreamFullInfo 传入rid或者sname 获取房间流信息

func (*Dao) StreamRIDByName 

func (d *Dao) StreamRIDByName(c context.Context, sname string) (int64, error)

StreamRIDByName 获取rid

func (*Dao) UpdateChangeSrcCache 

func (d *Dao) UpdateChangeSrcCache(c context.Context, rid int64, origin int64) error

UpdateChangeSrcCache 切流

func (*Dao) UpdateLastCDNCache 

func (d *Dao) UpdateLastCDNCache(c context.Context, rid int64, origin int64) error

UpdateLastCDNCache 设置last cdn

func (*Dao) UpdateOfficialStreamStatus 

func (d *Dao) UpdateOfficialStreamStatus(c context.Context, rid int64, src int8) (err error)

UpdateOfficialStreamStatus 切换cdn时，更新流状态

func (*Dao) UpdateOfficialUpRankStatus 

func (d *Dao) UpdateOfficialUpRankStatus(c context.Context, rid int64, whereSrc int8, toSrc int8) error

UpdateOfficialUpRankStatus 清理互推标准，更新up_rank

func (*Dao) UpdateRoomHotStatusCache 

func (d *Dao) UpdateRoomHotStatusCache(c context.Context, rid int64, hot int64) error

UpdateRoomHotStatusCache 更新房间冷热流状态

func (*Dao) UpdateRoomOptionsCache 

func (d *Dao) UpdateRoomOptionsCache(c context.Context, rid int64, streamname string, options int64) error

UpdateRoomOptionsCache 更新Options状态

func (*Dao) UpdateStreamStatusCache 

func (d *Dao) UpdateStreamStatusCache(c context.Context, stream *model.StreamStatus)

UpdateStreamForwardStatus 更新forward值

type OnAirStream 

type OnAirStream struct {
	StreamName string `json:"stream_name, omitempty"`
}

type OnAirStreamList 

type OnAirStreamList struct {
	List []*OnAirStream `json:"list,omitempty"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.