base

package

Go to main page

Versions in this module

v0

v0.24.28

Oct 29, 2021

v0.24.27

Oct 29, 2021

v0.24.26

Oct 28, 2021

v0.24.25

Oct 28, 2021

v0.24.24

Oct 21, 2021

v0.24.23

Oct 21, 2021

v0.24.22

Oct 15, 2021

v0.24.21

Sep 12, 2021

v0.24.20

Sep 12, 2021

v0.24.19

Sep 12, 2021

v0.24.18

Aug 24, 2021

v0.24.17

Aug 24, 2021

v0.24.16

Aug 24, 2021

v0.24.15

Aug 24, 2021

v0.24.14

Aug 24, 2021

v0.24.13

Aug 22, 2021

v0.24.12

Aug 22, 2021

v0.24.11

Aug 22, 2021

v0.24.10

Aug 22, 2021

v0.24.9

Aug 22, 2021

v0.24.8

Aug 22, 2021

v0.24.7

Aug 22, 2021

v0.24.6

Aug 20, 2021

v0.24.5

Aug 20, 2021

v0.24.4

Aug 19, 2021

v0.24.3

Aug 19, 2021

v0.24.2

Aug 19, 2021

v0.24.1

Aug 19, 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/cfeeling/lal"

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

+ var LalHlsM3u8Server string

+ var LalHlsTsServer string

+ var LalHttpApiServer string

+ var LalHttpflvPullSessionUa string

+ var LalHttpflvSubSessionServer string

+ var LalHttptsSubSessionServer string

+ var LalLibraryName = "lal"

+ var LalPackSdp string

+ 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 IsUseClosedConnectionError(err error) bool

+ 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.19.16

Aug 18, 2021

v0.19.15

Aug 18, 2021

v0.19.14

Aug 18, 2021

v0.19.13

Aug 16, 2021

v0.19.12

May 1, 2021

Changes in this version

+ const RTMPTypeIDAggregateMessage

+ 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 WS_MAGIC_STR

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

+ var LALRTMPHandshakeWaterMark string

+ 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 UpdateWebSocketHeader(secWebSocketKey string) []byte

+ 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 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.19.11

Apr 14, 2021

v0.19.10

Apr 14, 2021

v0.19.9

Apr 14, 2021

v0.19.8

Mar 22, 2021

v0.19.7

Mar 22, 2021

v0.19.6

Mar 22, 2021

v0.19.5

Mar 22, 2021

v0.19.4

Mar 22, 2021

v0.19.3

Mar 22, 2021

v0.19.2

Mar 19, 2021

Changes in this version

+ const AudioCodecAAC

+ const DefaultHTTPPort

+ const DefaultHTTPSPort

+ const DefaultRTMPPort

+ const DefaultRTSPPort

+ const DespGroupNotFound

+ const DespParamMissing

+ const DespSessionNotFound

+ const DespSucc

+ const ErrorCodeGroupNotFound

+ const ErrorCodeParamMissing

+ const ErrorCodeSessionNotFound

+ const ErrorCodeSucc

+ const HTTPAPIVersion

+ const HTTPNotifyVersion

+ const LALVersion

+ 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 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 UKPFLVPullSession

+ const UKPFLVSubSession

+ const UKPGroup

+ const UKPHLSMuxer

+ const UKPRTMPPullSession

+ const UKPRTMPPushSession

+ const UKPRTMPServerSession

+ const UKPRTSPPubSession

+ const UKPRTSPPullSession

+ const UKPRTSPPushSession

+ const UKPRTSPServerCommandSession

+ const UKPRTSPSubSession

+ const UKPStreamer

+ const UKPTSSubSession

+ const VideoCodecAVC

+ const VideoCodecHEVC

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

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

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

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

+ var LALGithubSite = "https://github.com/cfeeling/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 LALRTMPPushSessionConnectVersion string

+ var LALRTSPOptionsResponseServer string

+ var LALRTSPPullSessionUA string

+ var LALVersionComma string

+ var LALVersionDot string

+ func GenUniqueKey(prefix string) string

+ 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

+ type HTTPResponseBasic struct

+ Desp string

+ ErrorCode int

+ type ISession interface

+ RemoteAddr func() string

+ type ISessionStat interface

+ GetStat func() StatSession

+ IsAlive func() (readAlive, writeAlive bool)

+ UpdateStat func(intervalSec uint32)

+ 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 PubStartInfo struct

+ type PubStopInfo struct

+ 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 SessionEventCommonInfo struct

+ AppName string

+ HasInSession bool

+ HasOutSession bool

+ Protocol string

+ RemoteAddr string

+ ServerID string

+ SessionID string

+ StreamName string

+ URL string

+ URLParam string

+ type StatGroup struct

+ AudioCodec string

+ StatPub StatPub

+ StatPull StatPull

+ StatSubs []StatSub

+ StreamName string

+ VideoCodec string

+ VideoHeight int

+ VideoWidth int

+ type StatPub struct

+ func StatSession2Pub(ss StatSession) (ret StatPub)

+ type StatPull struct

+ func StatSession2Pull(ss StatSession) (ret StatPull)

+ type StatSession struct

+ Bitrate int

+ Protocol string

+ ReadBitrate int

+ ReadBytesSum uint64

+ RemoteAddr string

+ SessionID string

+ StartTime string

+ WriteBitrate int

+ WroteBytesSum uint64

+ type StatSub struct

+ func StatSession2Sub(ss StatSession) (ret StatSub)

+ type SubStartInfo struct

+ type SubStopInfo struct

+ 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 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 UpdateInfo struct

+ Groups []StatGroup

+ ServerID string

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