base

package

Go to main page

Versions in this module

v0

v0.37.4

Apr 18, 2024

Changes in this version

+ const AudioCodecOpus

+ const RtmpSoundFormatOpus

+ var AddCors2HlsFlag = true

+ func AddCorsHeaders2HlsIfNeeded(w http.ResponseWriter)

+ func ReadWsPayload(r *bufio.Reader) ([]byte, error)

type AvPacketPt

+ const AvPacketPtOpus

v0.36.7

Jul 13, 2023

Changes in this version

+ type PeriodRecord struct

+ func NewPeriodRecord(bufSize int) PeriodRecord

+ func (p *PeriodRecord) Add(unixSec int64, v uint32)

+ func (p *PeriodRecord) Clear()

+ type RecordPerSec struct

+ UnixSec int64

+ V uint32

type StatGroup

+ Fps []RecordPerSec

+ func (s *StatGroup) GetFpsFrom(p *PeriodRecord, nowUnixSec int64)

v0.35.41

Apr 15, 2023

Changes in this version

+ var CorsHeaders = ...

+ func AddCorsHeaders(w http.ResponseWriter)

v0.35.4

Apr 11, 2023

Changes in this version

+ const RtmpExFrameTypeKeyFrame

+ const RtmpExPacketTypeCodedFrames

+ const RtmpExPacketTypeCodedFramesX

+ const RtmpExPacketTypeSequenceEnd

+ const RtmpExPacketTypeSequenceStart

+ var ErrRtspUnsupportedTransport = errors.New("lal.rtsp: unsupported Transport")

type RtmpMsg

+ func (msg RtmpMsg) Cts() uint32

+ func (msg RtmpMsg) GetEnchanedHevcNaluIndex() int

+ func (msg RtmpMsg) IsEnchanedHevcNalu() bool

+ func (msg RtmpMsg) IsEnhanced() bool

v0.34.3

Mar 27, 2023

Changes in this version

+ const AudioCodecG711A

+ const AudioCodecG711U

+ const DespPageNotFound

+ const ErrorCodePageNotFound

+ const HttpWebUiVersion

+ const RtmpSoundFormatG711A

+ const RtmpSoundFormatG711U

+ var ApiNotFoundResp = ApiRespBasic

+ func DefaultTlsConfigClient() *tls.Config

+ func DefaultTlsConfigServer(certFile, keyFile string) (*tls.Config, error)

+ type ApiCtrlKickSessionResp struct

+ type ApiCtrlStartRelayPullResp struct

+ Data struct{ ... }

+ type ApiCtrlStartRtpPubResp struct

+ Data struct{ ... }

+ type ApiCtrlStopRelayPullResp struct

+ Data struct{ ... }

+ type ApiRespBasic struct

+ Desp string

+ ErrorCode int

+ type ApiStatAllGroupResp struct

+ Data struct{ ... }

+ type ApiStatGroupResp struct

+ Data *StatGroup

+ type ApiStatLalInfoResp struct

+ Data LalInfo

type AvPacketPt

+ const AvPacketPtG711A

+ const AvPacketPtG711U

type LalInfo

+ WebUiVersion string

type RtmpMsg

+ func (msg RtmpMsg) AudioCodecId() uint8

v0.33.0

Jan 30, 2023

Changes in this version

+ const DumpTypeCustomizePubAudioSpecificConfigData

+ const DumpTypeCustomizePubData

+ const DumpTypeDefault

+ const DumpTypeInnerFileHeaderData

+ const DumpTypePsRtpData

+ const DumpTypeRtspRtpData

+ const DumpTypeRtspSdpData

+ const SessionProtocolHls

+ const SessionProtocolHlsStr

+ const SessionTypeHlsSub

+ const UkPreHlsSubSession

+ var ErrHlsSessionNotFound = errors.New("lal.hls: hls session not found")

+ func GenUkHlsSubSession() string

+ func UnixMilli(t time.Time) int64

type DumpFile

+ func (d *DumpFile) WriteAvPacket(packet AvPacket, typ uint32) error

+ func (d *DumpFile) WriteWithType(b []byte, typ uint32) error

type DumpFileMessage

+ Reserve uint32

v0.32.0

Nov 10, 2022

Changes in this version

+ const DefaultRtspsPort

+ var ErrDisposedInStream = errors.New("lal.logic: in stream already disposed")

v0.31.1

Oct 7, 2022

v0.31.0

Oct 7, 2022

Changes in this version

+ const AvPacketStreamAudioFormatAdtsAac

+ const ErrorCodeListenUdpPortFail

+ const SessionProtocolPs

+ const SessionProtocolPsStr

+ const SessionTypePsPub

+ const UkPrePsPubSession

+ var ErrGb28181 = errors.New("lal.gb28181: fxxk")

+ func GenUkPsPubSession() string

+ type ApiCtrlKickSessionReq struct

+ SessionId string

+ StreamName string

type ApiCtrlStartRelayPullReq

+ DebugDumpPacket string

+ type ApiCtrlStartRtpPub struct

+ Data struct{ ... }

+ type ApiCtrlStartRtpPubReq struct

+ DebugDumpPacket string

+ IsTcpFlag int

+ Port int

+ StreamName string

+ TimeoutMs int

+ type DumpFile struct

+ func NewDumpFile() *DumpFile

+ func (d *DumpFile) Close() error

+ func (d *DumpFile) OpenToRead(filename string) (err error)

+ func (d *DumpFile) OpenToWrite(filename string) (err error)

+ func (d *DumpFile) ReadOneMessage() (m DumpFileMessage, err error)

+ func (d *DumpFile) Write(b []byte) error

+ type DumpFileMessage struct

+ Body []byte

+ Len uint32

+ Timestamp uint32

+ Typ uint32

+ Ver uint32

+ func (m *DumpFileMessage) DebugString() string

+ type IStatable interface

+ GetStat func() connection.Stat

+ type OnAvPacketFunc func(packet *AvPacket)

type RtmpMsg

+ func (msg RtmpMsg) DebugString() string

type SessionEventCommonInfo

+ ReadBytesSum uint64

+ WroteBytesSum uint64

type StatGroup

+ AppName string

type StatSession

+ BitrateKbits int

+ ReadBitrateKbits int

+ WriteBitrateKbits int

v0.30.1

Jun 15, 2022

v0.30.0

Jun 15, 2022

Changes in this version

+ const AutoStopPullAfterNoOutMsImmediately

+ const AutoStopPullAfterNoOutMsNever

+ const ConfVersion

+ const DefaultRtmpsPort

+ const ErrorCodeStartRelayPullFail

+ const PullRetryNumForever

+ const PullRetryNumNever

+ const RtspModeTcp

+ const RtspModeUdp

+ const SessionBaseTypePub

+ const SessionBaseTypePubStr

+ const SessionBaseTypePubSub

+ const SessionBaseTypePubSubStr

+ const SessionBaseTypePull

+ const SessionBaseTypePullStr

+ const SessionBaseTypePush

+ const SessionBaseTypePushStr

+ const SessionBaseTypeSub

+ const SessionBaseTypeSubStr

+ const SessionProtocolCustomize

+ const SessionProtocolCustomizeStr

+ const SessionProtocolFlv

+ const SessionProtocolFlvStr

+ const SessionProtocolRtmp

+ const SessionProtocolRtmpStr

+ const SessionProtocolRtsp

+ const SessionProtocolRtspStr

+ const SessionProtocolTs

+ const SessionProtocolTsStr

+ const SessionTypeCustomizePub

+ const SessionTypeFlvPull

+ const SessionTypeFlvSub

+ const SessionTypeRtmpPull

+ const SessionTypeRtmpPush

+ const SessionTypeRtmpServerSession

+ const SessionTypeRtspPub

+ const SessionTypeRtspPull

+ const SessionTypeRtspPush

+ const SessionTypeRtspSub

+ const SessionTypeTsSub

+ var LalRtspRealm string

+ func GetWd() string

+ type ApiCtrlKickSession struct

+ SessionId string

+ StreamName string

+ type ApiCtrlStartRelayPull struct

+ Data struct{ ... }

+ type ApiCtrlStartRelayPullReq struct

+ AutoStopPullAfterNoOutMs int

+ PullRetryNum int

+ PullTimeoutMs int

+ RtspMode int

+ StreamName string

+ Url string

+ type ApiCtrlStopRelayPull struct

+ Data struct{ ... }

type AvPacket

+ Pts int64

+ type BasicHttpSubSession struct

+ func NewBasicHttpSubSession(option BasicHttpSubSessionOption) *BasicHttpSubSession

+ func (session *BasicHttpSubSession) AppName() string

+ func (session *BasicHttpSubSession) Dispose() error

+ func (session *BasicHttpSubSession) GetStat() StatSession

+ func (session *BasicHttpSubSession) IsAlive() (readAlive, writeAlive bool)

+ func (session *BasicHttpSubSession) RawQuery() string

+ func (session *BasicHttpSubSession) RunLoop() error

+ func (session *BasicHttpSubSession) StreamName() string

+ func (session *BasicHttpSubSession) UniqueKey() string

+ func (session *BasicHttpSubSession) UpdateStat(intervalSec uint32)

+ func (session *BasicHttpSubSession) Url() string

+ func (session *BasicHttpSubSession) Write(b []byte)

+ func (session *BasicHttpSubSession) WriteHttpResponseHeader(b []byte)

+ type BasicHttpSubSessionOption struct

+ Conn net.Conn

+ ConnModOption connection.ModOption

+ IsWebSocket bool

+ SessionType SessionType

+ UrlCtx UrlContext

+ WebSocketKey string

+ type BasicSessionStat struct

+ func NewBasicSessionStat(sessionType SessionType, remoteAddr string) BasicSessionStat

+ func (s *BasicSessionStat) AddReadBytes(n int)

+ func (s *BasicSessionStat) AddWriteBytes(n int)

+ func (s *BasicSessionStat) BaseType() string

+ func (s *BasicSessionStat) GetStat() StatSession

+ func (s *BasicSessionStat) GetStatWithConn(conn connection.Connection) StatSession

+ func (s *BasicSessionStat) IsAlive() (readAlive, writeAlive bool)

+ func (s *BasicSessionStat) IsAliveWitchConn(conn connection.Connection) (readAlive, writeAlive bool)

+ func (s *BasicSessionStat) SetBaseType(baseType string)

+ func (s *BasicSessionStat) SetRemoteAddr(addr string)

+ func (s *BasicSessionStat) UniqueKey() string

+ func (s *BasicSessionStat) UpdateStat(intervalSec uint32)

+ func (s *BasicSessionStat) UpdateStatWitchConn(conn connection.Connection, intervalSec uint32)

+ type EventCommonInfo struct

+ ServerId string

+ type HlsMakeTsInfo struct

+ Cwd string

+ Duration float64

+ Event string

+ Id int

+ LiveM3u8File string

+ RecordM3u8File string

+ StreamName string

+ TsFile string

+ type ISession interface

type PubStartInfo

+ func Session2PubStartInfo(session ISession) PubStartInfo

type PubStopInfo

+ func Session2PubStopInfo(session ISession) PubStopInfo

+ type PullStartInfo struct

+ func Session2PullStartInfo(session ISession) PullStartInfo

+ type PullStopInfo struct

+ func Session2PullStopInfo(session ISession) PullStopInfo

type RtmpMsg

+ func (msg RtmpMsg) VideoCodecId() uint8

type SessionEventCommonInfo

+ BaseType string

+ type SessionType int

type StatPub

+ func Session2StatPub(session ISession) StatPub

type StatPull

+ func Session2StatPull(session ISession) StatPull

type StatSession

+ BaseType string

type StatSub

+ func Session2StatSub(session ISession) StatSub

type SubStartInfo

+ func Session2SubStartInfo(session ISession) SubStartInfo

type SubStopInfo

+ func Session2SubStopInfo(session ISession) SubStopInfo

v0.29.1

May 3, 2022

v0.29.0

May 3, 2022

Changes in this version

+ const AvPacketStreamAudioFormatRawAac

+ const AvPacketStreamAudioFormatUnknown

+ const AvPacketStreamVideoFormatAnnexb

+ const AvPacketStreamVideoFormatAvcc

+ const AvPacketStreamVideoFormatUnknown

+ const UkPreCustomizePubSessionContext

+ var DefaultApsOption = AvPacketStreamOption

+ func GenUkCustomizePubSession() string

type AvPacket

+ func (packet *AvPacket) DebugString() string

+ func (packet *AvPacket) IsAudio() bool

+ func (packet *AvPacket) IsVideo() bool

+ type AvPacketStreamAudioFormat int

+ type AvPacketStreamOption struct

+ AudioFormat AvPacketStreamAudioFormat

+ VideoFormat AvPacketStreamVideoFormat

+ type AvPacketStreamVideoFormat int

+ type IAvPacketStream interface

+ FeedAudioSpecificConfig func(asc []byte)

+ FeedAvPacket func(packet AvPacket)

+ WithOption func(modOption func(option *AvPacketStreamOption))

v0.28.0

Mar 27, 2022

Changes in this version

+ const UkPreRtmp2MpegtsRemuxer

+ var Log = nazalog.GetGlobalLogger()

+ func GenUkRtmp2MpegtsRemuxer() string

+ func LogoutStartInfo()

+ func ReadableNowTime() string

+ type LogDump struct

+ func NewLogDump(log nazalog.Logger, debugMaxNum int) LogDump

+ func (ld *LogDump) Outf(format string, v ...interface{})

+ func (ld *LogDump) ShouldDump() bool

type RtmpMsg

+ func (msg RtmpMsg) Dts() uint32

+ func (msg RtmpMsg) Pts() uint32

v0.27.1

Jan 23, 2022

v0.27.0

Jan 23, 2022

Changes in this version

+ const RtmpUserControlPingRequest

+ const RtmpUserControlPingResponse

+ var ErrAmfInvalidType = errors.New("lal.rtmp: invalid amf0 type")

+ var ErrAmfNotExist = errors.New("lal.rtmp: not exist")

+ var ErrAmfTooShort = errors.New("lal.rtmp: too short to unmarshal amf0 data")

+ var ErrAvc = errors.New("lal.avc: fxxk")

+ var ErrDupInStream = errors.New("lal.logic: in stream already exist at group")

+ var ErrFileNotExist = errors.New("lal: file not exist")

+ var ErrHevc = errors.New("lal.hevc: fxxk")

+ var ErrHls = errors.New("lal.hls: fxxk")

+ var ErrInvalidUrl = errors.New("lal.base: invalid url")

+ var ErrMultiRegisterForPattern = errors.New("lal.base: http server multiple registrations for pattern")

+ var ErrRtmpShortBuffer = errors.New("lal.rtmp: buffer too short")

+ var ErrRtmpUnexpectedMsg = errors.New("lal.rtmp: unexpected msg")

+ var ErrRtpRtcpShortBuffer = errors.New("lal.rtprtcp: buffer too short")

+ var ErrRtsp = errors.New("lal.rtsp: fxxk")

+ var ErrRtspClosedByObserver = errors.New("lal.rtsp: close by observer")

+ var ErrSamplingFrequencyIndex = errors.New("lal.aac: invalid sampling frequency index")

+ var ErrSdp = errors.New("lal.sdp: fxxk")

+ var ErrShortBuffer = errors.New("lal: buffer too short")

+ var ErrSimpleAuthFailed = errors.New("lal.logic: simple auth failed since url param lal_secret invalid")

+ var ErrSimpleAuthParamNotFound = errors.New("lal.logic: simple auth failed since url param lal_secret not found")

+ func NewErrAmfInvalidType(b byte) error

+ func NewErrRtmpShortBuffer(need, actual int, msg string) error

+ func ParseHttpRequest(req *http.Request) string

type UrlContext

+ func (u *UrlContext) GetFileType() string

+ func (u *UrlContext) GetFilenameWithoutType() string

v0.26.0

Oct 24, 2021

Changes in this version

+ func RunSignalHandler(cb func()) — darwin/amd64, linux/amd64, windows/amd64

+ type Buffer struct

+ func NewBuffer(initCap int) *Buffer

+ func (b *Buffer) Bytes() []byte

+ func (b *Buffer) Cap() int

+ func (b *Buffer) Flush(n int)

+ func (b *Buffer) Grow(n int)

+ func (b *Buffer) Len() int

+ func (b *Buffer) Read(p []byte) (n int, err error)

+ func (b *Buffer) ReserveBytes(n int) []byte

+ func (b *Buffer) Reset()

+ func (b *Buffer) Skip(n int)

+ func (b *Buffer) Truncate(n int)

+ func (b *Buffer) WritableBytes() []byte

+ func (b *Buffer) Write(p []byte) (n int, err error)

+ type MergeWriter struct

+ func NewMergeWriter(onWritev OnWritev, size int) *MergeWriter

+ func (w *MergeWriter) Flush()

+ func (w *MergeWriter) Write(b []byte)

+ type OnWritev func(bs net.Buffers)

v0.25.0

Aug 28, 2021

Changes in this version

+ func IsUseClosedConnectionError(err error) bool

v0.24.0

Jul 31, 2021

Changes in this version

+ var LalPackSdp string

v0.23.0

Jun 6, 2021

Changes in this version

+ const AudioCodecAac

+ const DefaultHttpPort

+ const DefaultHttpsPort

+ const DefaultRtmpPort

+ const DefaultRtspPort

+ const HttpApiVersion

+ const HttpNotifyVersion

+ const LalVersion

+ const NetworkTcp

+ const ProtocolHttpflv

+ const ProtocolHttpts

+ const ProtocolRtmp

+ const ProtocolRtsp

+ const RtmpAacPacketTypeRaw

+ const RtmpAacPacketTypeSeqHeader

+ const RtmpAvcInterFrame

+ const RtmpAvcKeyFrame

+ const RtmpAvcPacketTypeNalu

+ const RtmpAvcPacketTypeSeqHeader

+ const RtmpCodecIdAvc

+ const RtmpCodecIdHevc

+ const RtmpFrameTypeInter

+ const RtmpFrameTypeKey

+ const RtmpHevcInterFrame

+ const RtmpHevcKeyFrame

+ const RtmpHevcPacketTypeNalu

+ const RtmpHevcPacketTypeSeqHeader

+ const RtmpSoundFormatAac

+ const RtmpTypeIdAck

+ const RtmpTypeIdAggregateMessage

+ const RtmpTypeIdAudio

+ const RtmpTypeIdBandwidth

+ const RtmpTypeIdCommandMessageAmf0

+ const RtmpTypeIdCommandMessageAmf3

+ const RtmpTypeIdMetadata

+ const RtmpTypeIdSetChunkSize

+ const RtmpTypeIdUserControl

+ const RtmpTypeIdVideo

+ const RtmpTypeIdWinAckSize

+ const RtmpUserControlRecorded

+ const RtmpUserControlStreamBegin

+ const RtpPacketTypeAac

+ const RtpPacketTypeAvcOrHevc

+ const RtpPacketTypeHevc

+ const UkPreFlvPullSession

+ const UkPreFlvSubSession

+ const UkPreGroup

+ const UkPreHlsMuxer

+ const UkPreRtmpPullSession

+ const UkPreRtmpPushSession

+ const UkPreRtmpServerSession

+ const UkPreRtspPubSession

+ const UkPreRtspPullSession

+ const UkPreRtspPushSession

+ const UkPreRtspServerCommandSession

+ const UkPreRtspSubSession

+ const UkPreStreamer

+ const UkPreTsSubSession

+ const VideoCodecAvc

+ const VideoCodecHevc

+ const WsMagicStr

+ var ErrAddrEmpty = errors.New("lal.base: http server addr empty")

+ var ErrMultiRegistForPattern = errors.New("lal.base: http server multiple registrations for pattern")

+ var ErrUrl = errors.New("lal.url: fxxk")

+ var LalDocSite = "https://pengrl.com/lal"

+ var LalFullInfo = LalLibraryName + " " + LalVersion + " (" + LalGithubRepo + ")"

+ var LalGithubRepo = "github.com/q191201771/lal"

+ var LalGithubSite = "https://github.com/q191201771/lal"

+ var LalHlsM3u8Server string

+ var LalHlsTsServer string

+ var LalHttpApiServer string

+ var LalHttpflvPullSessionUa string

+ var LalHttpflvSubSessionServer string

+ var LalHttptsSubSessionServer string

+ var LalLibraryName = "lal"

+ var LalRtmpBuildMetadataEncoder string

+ var LalRtmpConnectResultVersion string

+ var LalRtmpHandshakeWaterMark string

+ var LalRtmpPushSessionConnectVersion string

+ var LalRtspOptionsResponseServer string

+ var LalRtspPullSessionUa string

+ var LalVersionComma string

+ var LalVersionDot string

+ var Logger = nazalog.GetGlobalLogger()

+ func GenUkFlvPullSession() string

+ func GenUkFlvSubSession() string

+ func GenUkGroup() string

+ func GenUkHlsMuxer() string

+ func GenUkRtmpPullSession() string

+ func GenUkRtmpPushSession() string

+ func GenUkRtmpServerSession() string

+ func GenUkRtspPubSession() string

+ func GenUkRtspPullSession() string

+ func GenUkRtspPushSession() string

+ func GenUkRtspServerCommandSession() string

+ func GenUkRtspSubSession() string

+ func GenUkStreamer() string

+ func GenUkTsSubSession() string

+ func MakeWsFrameHeader(wsHeader WsHeader) (buf []byte)

+ func OsExitAndWaitPressIfWindows(code int)

+ type ApiCtrlKickOutSession struct

+ SessionId string

+ StreamName string

+ type ApiCtrlStartPullReq struct

+ Addr string

+ AppName string

+ Protocol string

+ StreamName string

+ UrlParam string

+ type ApiStatAllGroup struct

+ Data struct{ ... }

+ type ApiStatGroup struct

+ Data *StatGroup

+ type ApiStatLalInfo struct

+ Data LalInfo

+ type AvPacket struct

+ Payload []byte

+ PayloadType AvPacketPt

+ Timestamp uint32

+ type AvPacketPt int

+ const AvPacketPtAac

+ const AvPacketPtAvc

+ const AvPacketPtHevc

+ const AvPacketPtUnknown

+ func (a AvPacketPt) ReadableString() string

+ type Handler func(http.ResponseWriter, *http.Request)

+ type HttpResponseBasic struct

+ Desp string

+ ErrorCode int

+ type HttpServerManager struct

+ func NewHttpServerManager() *HttpServerManager

+ func (s *HttpServerManager) AddListen(addrCtx LocalAddrCtx, pattern string, handler Handler) error

+ func (s *HttpServerManager) Dispose() error

+ func (s *HttpServerManager) RunLoop() error

+ type HttpSubSession struct

+ func NewHttpSubSession(option HttpSubSessionOption) *HttpSubSession

+ func (session *HttpSubSession) AppName() string

+ func (session *HttpSubSession) Dispose() error

+ func (session *HttpSubSession) GetStat() StatSession

+ func (session *HttpSubSession) IsAlive() (readAlive, writeAlive bool)

+ func (session *HttpSubSession) RawQuery() string

+ func (session *HttpSubSession) RunLoop() error

+ func (session *HttpSubSession) StreamName() string

+ func (session *HttpSubSession) UniqueKey() string

+ func (session *HttpSubSession) UpdateStat(intervalSec uint32)

+ func (session *HttpSubSession) Url() string

+ func (session *HttpSubSession) Write(b []byte)

+ func (session *HttpSubSession) WriteHttpResponseHeader(b []byte)

+ type HttpSubSessionOption struct

+ Conn net.Conn

+ ConnModOption connection.ModOption

+ IsWebSocket bool

+ Protocol string

+ Uk string

+ UrlCtx UrlContext

+ WebSocketKey string

+ type IBufWriter interface

+ Flush func()

+ Write func(p []byte)

+ func NewWriterFuncSize(wr WriterFunc, size int) IBufWriter

+ type ISessionUrlContext interface

+ AppName func() string

+ RawQuery func() string

+ StreamName func() string

+ Url func() string

+ type LalInfo struct

+ ApiVersion string

+ BinInfo string

+ LalVersion string

+ NotifyVersion string

+ ServerId string

+ StartTime string

+ type LocalAddrCtx struct

+ Addr string

+ CertFile string

+ IsHttps bool

+ KeyFile string

+ Network string

+ type RtmpConnectInfo struct

+ App string

+ FlashVer string

+ RemoteAddr string

+ ServerId string

+ SessionId string

+ TcUrl string

+ type RtmpHeader struct

+ Csid int

+ MsgLen uint32

+ MsgStreamId int

+ MsgTypeId uint8

+ TimestampAbs uint32

+ type RtmpMsg struct

+ Header RtmpHeader

+ Payload []byte

+ func (msg RtmpMsg) Clone() (ret RtmpMsg)

+ func (msg RtmpMsg) IsAacSeqHeader() bool

+ func (msg RtmpMsg) IsAvcKeyNalu() bool

+ func (msg RtmpMsg) IsAvcKeySeqHeader() bool

+ func (msg RtmpMsg) IsHevcKeyNalu() bool

+ func (msg RtmpMsg) IsHevcKeySeqHeader() bool

+ func (msg RtmpMsg) IsVideoKeyNalu() bool

+ func (msg RtmpMsg) IsVideoKeySeqHeader() bool

+ type ServerCtx struct

type SessionEventCommonInfo

+ ServerId string

+ SessionId string

+ Url string

+ UrlParam string

type StatSession

+ SessionId string

type UpdateInfo

+ ServerId string

+ type UrlContext struct

+ Host string

+ HostWithPort string

+ LastItemOfPath string

+ Password string

+ Path string

+ PathWithRawQuery string

+ PathWithoutLastItem string

+ Port int

+ RawQuery string

+ RawUrlWithoutUserInfo string

+ Scheme string

+ StdHost string

+ Url string

+ Username string

+ func ParseHttpUrl(rawUrl string, isHttps bool, suffix string) (ctx UrlContext, err error)

+ func ParseHttpflvUrl(rawUrl string, isHttps bool) (ctx UrlContext, err error)

+ func ParseHttptsUrl(rawUrl string, isHttps bool) (ctx UrlContext, err error)

+ func ParseRtmpUrl(rawUrl string) (ctx UrlContext, err error)

+ func ParseRtspUrl(rawUrl string) (ctx UrlContext, err error)

+ func ParseUrl(rawUrl string, defaultPort int) (ctx UrlContext, err error)

+ type UrlPathContext struct

+ LastItemOfPath string

+ Path string

+ PathWithRawQuery string

+ PathWithoutLastItem string

+ RawQuery string

+ type WriterFunc func(p []byte)

+ type WsHeader struct

+ Fin bool

+ MaskKey uint32

+ Masked bool

+ Opcode WsOpcode

+ PayloadLength uint64

+ Rsv1 bool

+ Rsv2 bool

+ Rsv3 bool

type WsOpcode

+ const Wso_Binary

+ const Wso_Close

+ const Wso_Continuous

+ const Wso_Ping

+ const Wso_Pong

+ const Wso_Rsv3

+ const Wso_Rsv4

+ const Wso_Rsv5

+ const Wso_Rsv6

+ const Wso_Rsv7

+ const Wso_RsvB

+ const Wso_RsvC

+ const Wso_RsvD

+ const Wso_RsvE

+ const Wso_RsvF

+ const Wso_Text

v0.22.0

May 3, 2021

Changes in this version

+ const WS_MAGIC_STR

+ func MakeWSFrameHeader(wsHeader WSHeader) (buf []byte)

+ func UpdateWebSocketHeader(secWebSocketKey string) []byte

type AVPacketPT

+ func (a AVPacketPT) ReadableString() string

+ type WSHeader struct

+ Fin bool

+ MaskKey uint32

+ Masked bool

+ Opcode WsOpcode

+ PayloadLength uint64

+ Rsv1 bool

+ Rsv2 bool

+ Rsv3 bool

+ type WsOpcode = uint8

+ const WSO_Binary

+ const WSO_Close

+ const WSO_Continuous

+ const WSO_Ping

+ const WSO_Pong

+ const WSO_Rsv3

+ const WSO_Rsv4

+ const WSO_Rsv5

+ const WSO_Rsv6

+ const WSO_Rsv7

+ const WSO_RsvB

+ const WSO_RsvC

+ const WSO_RsvD

+ const WSO_RsvE

+ const WSO_RsvF

+ const WSO_Text

v0.21.0

Apr 11, 2021

Changes in this version

+ const RTMPTypeIDAggregateMessage

v0.20.0

Mar 21, 2021

Changes in this version

+ const DefaultHTTPSPort

+ const UKPreFLVPullSession

+ const UKPreFLVSubSession

+ const UKPreGroup

+ const UKPreHLSMuxer

+ const UKPreRTMPPullSession

+ const UKPreRTMPPushSession

+ const UKPreRTMPServerSession

+ const UKPreRTSPPubSession

+ const UKPreRTSPPullSession

+ const UKPreRTSPPushSession

+ const UKPreRTSPServerCommandSession

+ const UKPreRTSPSubSession

+ const UKPreStreamer

+ const UKPreTSSubSession

+ var ErrSessionNotStarted = errors.New("lal.base: session has not been started yet")

+ func GenUKFLVPullSession() string

+ func GenUKFLVSubSession() string

+ func GenUKGroup() string

+ func GenUKHLSMuxer() string

+ func GenUKRTMPPullSession() string

+ func GenUKRTMPPushSession() string

+ func GenUKRTMPServerSession() string

+ func GenUKRTSPPubSession() string

+ func GenUKRTSPPullSession() string

+ func GenUKRTSPPushSession() string

+ func GenUKRTSPServerCommandSession() string

+ func GenUKRTSPSubSession() string

+ func GenUKStreamer() string

+ func GenUKTSSubSession() string

+ type IClientSession interface

+ type IClientSessionLifecycle interface

+ Dispose func() error

+ WaitChan func() <-chan error

+ type IObject interface

+ UniqueKey func() string

+ type IServerSession interface

+ type IServerSessionLifecycle interface

+ Dispose func() error

+ RunLoop func() error

type ISessionURLContext

+ URL func() string

type SessionEventCommonInfo

+ URL string

type URLContext

+ URL string

+ func ParseHTTPTSURL(rawURL string, isHTTPS bool) (ctx URLContext, err error)

v0.19.1

Feb 1, 2021

v0.19.0

Jan 24, 2021

Changes in this version

+ const UKPRTSPPushSession

+ var LALDocSite = "https://pengrl.com/lal"

+ var LALGithubRepo = "github.com/q191201771/lal"

+ var LALGithubSite = "https://github.com/q191201771/lal"

+ func OSExitAndWaitPressIfWindows(code int)

type RTMPMsg

+ func (msg RTMPMsg) Clone() (ret RTMPMsg)

v0.18.0

Dec 27, 2020

Changes in this version

+ const DefaultHTTPPort

+ const DefaultRTMPPort

+ const DefaultRTSPPort

+ const RTPPacketTypeHEVC

+ const UKPRTSPPullSession

+ const UKPRTSPServerCommandSession

+ var ErrURL = errors.New("lal.url: fxxk")

+ var LALRTSPPullSessionUA string

type AVPacketPT

+ const AVPacketPTUnknown

+ type ISessionStat interface

+ GetStat func() StatSession

+ IsAlive func() (readAlive, writeAlive bool)

+ UpdateStat func(intervalSec int)

+ type ISessionURLContext interface

+ AppName func() string

+ RawQuery func() string

+ StreamName func() string

type StatSession

+ ReadBitrate int

+ WriteBitrate int

+ type URLContext struct

+ Host string

+ HostWithPort string

+ LastItemOfPath string

+ Password string

+ Path string

+ PathWithRawQuery string

+ PathWithoutLastItem string

+ Port int

+ RawQuery string

+ RawURLWithoutUserInfo string

+ Scheme string

+ StdHost string

+ Username string

+ func ParseHTTPFLVURL(rawURL string) (ctx URLContext, err error)

+ func ParseRTMPURL(rawURL string) (ctx URLContext, err error)

+ func ParseRTSPURL(rawURL string) (ctx URLContext, err error)

+ func ParseURL(rawURL string, defaultPort int) (ctx URLContext, err error)

+ type URLPathContext struct

+ LastItemOfPath string

+ Path string

+ PathWithRawQuery string

+ PathWithoutLastItem string

+ RawQuery string

+ func ParseURLPath(path string) (ctx URLPathContext, err error)

v0.17.0

Nov 21, 2020

Changes in this version

+ const DespGroupNotFound

+ const DespParamMissing

+ const DespSessionNotFound

+ const DespSucc

+ const ErrorCodeGroupNotFound

+ const ErrorCodeParamMissing

+ const ErrorCodeSessionNotFound

+ const ErrorCodeSucc

+ const HTTPAPIVersion

+ const HTTPNotifyVersion

+ const UKPFLVPullSession

+ const UKPFLVSubSession

+ const UKPGroup

+ const UKPHLSMuxer

+ const UKPRTMPPullSession

+ const UKPRTMPPushSession

+ const UKPRTMPServerSession

+ const UKPRTSPPubSession

+ const UKPRTSPSubSession

+ const UKPStreamer

+ const UKPTSSubSession

+ func GenUniqueKey(prefix string) string

+ type APICtrlKickOutSession struct

+ SessionID string

+ StreamName string

+ type APICtrlStartPullReq struct

+ Addr string

+ AppName string

+ Protocol string

+ StreamName string

+ URLParam string

+ type APIStatAllGroup struct

+ Data struct{ ... }

+ type APIStatGroup struct

+ Data *StatGroup

+ type APIStatLALInfo struct

+ Data LALInfo

+ type HTTPResponseBasic struct

+ Desp string

+ ErrorCode int

+ type LALInfo struct

+ APIVersion string

+ BinInfo string

+ LalVersion string

+ NotifyVersion string

+ ServerID string

+ StartTime string

+ type PubStartInfo struct

+ type PubStopInfo struct

+ type RTMPConnectInfo struct

+ App string

+ FlashVer string

+ RemoteAddr string

+ ServerID string

+ SessionID string

+ TCURL string

+ type SessionEventCommonInfo struct

+ AppName string

+ HasInSession bool

+ HasOutSession bool

+ Protocol string

+ RemoteAddr string

+ ServerID string

+ SessionID string

+ StreamName string

+ URLParam string

type StatGroup

+ StatPull StatPull

+ type StatPull struct

+ func StatSession2Pull(ss StatSession) (ret StatPull)

type StatSession

+ SessionID string

+ type SubStartInfo struct

+ type SubStopInfo struct

+ type UpdateInfo struct

+ Groups []StatGroup

+ ServerID string

v0.16.0

Oct 23, 2020

Changes in this version

+ const AudioCodecAAC

+ const ProtocolHTTPFLV

+ const ProtocolHTTPTS

+ const ProtocolRTMP

+ const ProtocolRTSP

+ const RTMPHEVCInterFrame

+ const RTMPTypeIDCommandMessageAMF3

+ const RTMPUserControlRecorded

+ const RTMPUserControlStreamBegin

+ const RTPPacketTypeAVCOrHEVC

+ const VideoCodecAVC

+ const VideoCodecHEVC

+ var LALHTTPAPIServer string

+ type AVPacketPT int

+ var AVPacketPTHEVC AVPacketPT = 98

+ type StatGroup struct

+ AudioCodec string

+ StatPub StatPub

+ StatSubs []StatSub

+ StreamName string

+ VideoCodec string

+ VideoHeight int

+ VideoWidth int

+ type StatPub struct

+ func StatSession2Pub(ss StatSession) (ret StatPub)

+ type StatSession struct

+ Bitrate int

+ Protocol string

+ ReadBytesSum uint64

+ RemoteAddr string

+ StartTime string

+ WroteBytesSum uint64

+ type StatSub struct

+ func StatSession2Sub(ss StatSession) (ret StatSub)

v0.15.1

Sep 19, 2020

v0.15.0

Sep 19, 2020

Changes in this version

+ const RTMPSoundFormatAAC

+ var LALHTTPTSSubSessionServer string

v0.14.0

Aug 23, 2020

Changes in this version

+ const RTMPAACPacketTypeRaw

+ const RTMPAACPacketTypeSeqHeader

+ const RTMPAVCInterFrame

+ const RTMPAVCKeyFrame

+ const RTMPAVCPacketTypeNALU

+ const RTMPAVCPacketTypeSeqHeader

+ const RTMPCodecIDAVC

+ const RTMPCodecIDHEVC

+ const RTMPFrameTypeInter

+ const RTMPFrameTypeKey

+ const RTMPHEVCKeyFrame

+ const RTMPHEVCPacketTypeNALU

+ const RTMPHEVCPacketTypeSeqHeader

+ const RTMPSoundFormatACC

+ const RTMPTypeIDAck

+ const RTMPTypeIDAudio

+ const RTMPTypeIDBandwidth

+ const RTMPTypeIDCommandMessageAMF0

+ const RTMPTypeIDMetadata

+ const RTMPTypeIDSetChunkSize

+ const RTMPTypeIDUserControl

+ const RTMPTypeIDVideo

+ const RTMPTypeIDWinAckSize

+ const RTPPacketTypeAAC

+ const RTPPacketTypeAVC

+ var AVPacketPTAAC = 97

+ var AVPacketPTAVC = 96

+ var LALFullInfo = LALLibraryName + " " + LALVersion + " (" + LALGitHubRepo + ")"

+ var LALGitHubRepo = "github.com/q191201771/lal"

+ var LALHLSM3U8Server string

+ var LALHLSTSServer string

+ var LALHTTPFLVPullSessionUA string

+ var LALHTTPFLVSubSessionServer string

+ var LALLibraryName = "lal"

+ var LALRTMPBuildMetadataEncoder string

+ var LALRTMPConnectResultVersion string

+ var LALRTMPHandshakeWaterMark string

+ var LALRTMPPushSessionConnectVersion string

+ var LALRTSPOptionsResponseServer string

+ var LALVersion = "v0.13.0"

+ var LALVersionComma string

+ var LALVersionDot string

+ type AVPacket struct

+ Payload []byte

+ PayloadType int

+ Timestamp uint32

+ type RTMPHeader struct

+ CSID int

+ MsgLen uint32

+ MsgStreamID int

+ MsgTypeID uint8

+ TimestampAbs uint32

+ type RTMPMsg struct

+ Header RTMPHeader

+ Payload []byte

+ func (msg RTMPMsg) IsAACSeqHeader() bool

+ func (msg RTMPMsg) IsAVCKeyNALU() bool

+ func (msg RTMPMsg) IsAVCKeySeqHeader() bool

+ func (msg RTMPMsg) IsHEVCKeyNALU() bool

+ func (msg RTMPMsg) IsHEVCKeySeqHeader() bool

+ func (msg RTMPMsg) IsVideoKeyNALU() bool

+ func (msg RTMPMsg) IsVideoKeySeqHeader() bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL