reply

Mar 30, 2024

Changes in this version

+ var ErrBufTooLarge = errors.New("ErrBufTooLarge")

+ var ErrCantResync = perrors.New("decode")

+ var ErrMisBox = perrors.New("decode", "ErrMisBox")

+ var ErrMisTraks = errors.New("ErrMisTraks")

+ var ErrUnkownBox = perrors.New("ErrUnkownBox")

type Fmp4Decoder

+ func NewFmp4Decoder() *Fmp4Decoder

type M4SStream

+ func (t *M4SStream) MarshalJSON() ([]byte, error)

Jan 21, 2024

Changes in this version

type M4SStream

+ func (t *M4SStream) Cut()

+ func (t *M4SStream) GetSavePath() string

+ func (t *M4SStream) GetStreamType() string

Jan 4, 2024

Changes in this version

type Fmp4Decoder

+ AVTDiff float64

Jun 23, 2023

Changes in this version

+ var TTS_setting_string = map[string]string

Apr 26, 2023

Changes in this version

+ type SaveDanmuToDB struct

Apr 24, 2023

Changes in this version

+ type SaveDanmuToSqlite3 struct

+ func (t *SaveDanmuToSqlite3) Init(c *c.Common)

+ func (t *SaveDanmuToSqlite3) SaveToSqlite3(item Danmu_item)

Apr 9, 2023

Changes in this version

+ func StreamOCut(roomid int, title ...string)

type M4SStream

+ func (t *M4SStream) PusherToFile(contextC context.Context, filepath string, startFunc func(*M4SStream) error, ...) error

+ func (t *M4SStream) PusherToHttp(w http.ResponseWriter, r *http.Request, startFunc func(*M4SStream) error, ...) error

Mar 29, 2023

Changes in this version

+ var SaveToJson saveToJson

Mar 20, 2023

Changes in this version

+ type DanmuReLiveTriger struct

+ func (t *DanmuReLiveTriger) Check(uid, msg string)

+ func (t *DanmuReLiveTriger) Init(c *c.Common)

Feb 9, 2023

Changes in this version

+ func Search_stream_tag(buf []byte) (front_buf []byte, keyframe [][]byte, last_available_offset int, err error)

type Fmp4Decoder

+ func (t *Fmp4Decoder) Search_stream_fmp4(buf []byte, keyframes *slice.Buf[byte]) (cu int, err error)

Feb 2, 2023

Changes in this version

+ func StreamOStart(roomid int)

Oct 31, 2022

Changes in this version

+ var Recoder = websocket.Recorder

+ var StreamWs = websocket.New_server()

+ func PlayRecDanmu(filePath string) (*websocket.Server, func())

+ func SendStreamWs(item Danmu_item)

+ func StartRecDanmu(filePath string)

+ func StopRecDanmu()

+ func StreamOCommon(roomid int) (array []c.Common)

+ func StreamOStatus(roomid int) bool

+ func StreamOStop(roomid int)

+ type Communicate struct

+ Buf *psync.Map

+ func (t *Communicate) Count() int

+ func (t *Communicate) Reset()

+ func (t *Communicate) Store(k interface{})

+ type Danmu_item struct

+ type Fmp4Decoder struct

+ func (t *Fmp4Decoder) Init_fmp4(buf []byte) error

+ func (t *Fmp4Decoder) Seach_stream_fmp4(buf []byte) (keyframes [][]byte, last_avilable_offset int, err error)

+ type M4SStream struct

+ Callback_start func(*M4SStream)

+ Callback_startRec func(*M4SStream)

+ Callback_stop func(*M4SStream)

+ Callback_stopRec func(*M4SStream)

+ Current_save_path string

+ Status *signal.Signal

+ Stream_msg *msgq.Msgq

+ func (t *M4SStream) Common() c.Common

+ func (t *M4SStream) LoadConfig(common c.Common, l *log.Log_interface)

+ func (t *M4SStream) Pusher(w http.ResponseWriter, r *http.Request)

+ func (t *M4SStream) Start() bool

+ func (t *M4SStream) Stop()

+ type M4SStream_Config struct

+ type SavestreamO struct

+ IsRec bool

+ Roomid int

May 15, 2021

Changes in this version

+ func Keyframe_timebase(buf [][]byte, last_keyframe_timestamp int) (keyframe_timestamp int, err error)

+ func Merge_stream(keyframe_lists [][][]byte, last_keyframe_timestramp int) (keyframe_timestamp int, merge_buf []byte, merged int)

+ func Savestream_wait()

+ func Savestreamf()

+ func Seach_keyframe_tag(buf []byte) (front_buf []byte, keyframe [][]byte, err error)

+ func Seach_stream_tag(buf []byte) (front_buf []byte, keyframe [][]byte, err error)

+ func Stream(path string, front_buf *[]byte, streamChan chan []byte, cancel chan struct{}) error

+ func TimeStramp_Check(path string) error

+ type Savestream struct

Apr 3, 2021

Changes in this version

+ func AutoSend_silver_gift()

+ func Entry_danmu()

+ func Keep_medal_light()

+ func Save_to_json(Loc int, Context []interface{})

Jan 25, 2021

Changes in this version

+ var K_v = make(map[string]interface{})

+ func TTS(uid, msg string)

+ type Autoskip_item struct

+ Exprie uint

+ Num uint

type Danmuji

+ Buf map[string]string

Nov 22, 2020

Changes in this version

+ var AllF = map[string]bool

+ var Ass_T = 7

+ var Ass_font = 50

+ var Ass_height = 720

+ var Ass_loc = 7

+ var Ass_width = 1280

+ var Danmu_mq = mq.New()

+ var Heart_map = map[string]func(replyF, string)

+ var Msg_map = map[string]func(replyF, string)

+ var ShowRev_old float64

+ var ShowRev_start bool

+ func Ass_f(file string, st time.Time)

+ func Assf(s string)

+ func Autobanf(s string) bool

+ func Autoskipf(s string, maxNum, muteSecond int) int

+ func Danmuji_auto(sleep int)

+ func Danmujif(s string)

+ func Gui_show(m ...string)

+ func Heart(b []byte)

+ func IsOn(s string) bool

+ func Itos(i []interface{}) string

+ func Jiezouf(s []string) bool

+ func Lessdanmuf(s string, bufsize int) float32

+ func Msg(b []byte)

+ func Msg_senddanmu(msg string)

+ func Msg_showdanmu(auth interface{}, m ...string)

+ func Obs_R(on bool)

+ func Obsf(on bool)

+ func Reply(b []byte)

+ func Saveflv_wait()

+ func Saveflvf()

+ func Shortdanmuf(s string) string

+ func ShowRevf()

+ type Ass struct

+ type Autoban struct

+ Banbuf []string

+ type Autoskip struct

+ type Danmu_mq_t struct

+ type Danmuji struct

+ Inuse_auto bool

+ type Jiezou struct

+ type Lessdanmu struct

+ type Obs struct

+ Prog string

+ type Saveflv struct

+ type Shortdanmu struct