pms

Documentation

Index

• func PMSModule() gomodule.IModule
• type ISignalServer
• type PMSSettings
• type Request
• type Response
• type SignalServer
  • func NewSignalServer(ctx context.Context, logger *logrus.Entry) *SignalServer
  • func (ss *SignalServer) Close() error
  • func (ss *SignalServer) Start() error

Functions

func PMSModule

func PMSModule() gomodule.IModule

Types

type ISignalServer

type ISignalServer interface {
	Start() error
	Close() error
}

type PMSSettings

type PMSSettings struct {
	httpserv.HttpParams    `json:"http" mapstructure:"http"`
	KeyFrameIntervalSecond time.Duration `json:"keyFrameIntervalSeconds" mapstructure:"keyFrameIntervalSeconds"`
	JoinTimeoutSecond      time.Duration `json:"joinTimeoutSeconds" mapstructure:"joinTimeoutSeconds"`
}

type Request

type Request struct {
	Version string `json:"version"`
	Method  string `json:"method"`
	Stream  string `json:"stream"`
	Session string `json:"session"`
	Data    struct {
		SDP        string `json:"sdp"`
		MaxBitrate int    `json:"max_bitrate"`
	} `json:"data"`
}

type Response

type Response struct {
	Version string `json:"version"`
	Method  string `json:"method"`
	Err     int    `json:"err"`
	ErrMsg  string `json:"err_msg"`
	Session string `json:"session"`
	Data    struct {
		SDP string `json:"sdp"`
	} `json:"data"`
}

type SignalServer

type SignalServer struct {
	*httpserv.SignalServer
	// contains filtered or unexported fields
}

func NewSignalServer

func NewSignalServer(ctx context.Context, logger *logrus.Entry) *SignalServer

func (*SignalServer) Close

func (ss *SignalServer) Close() error

func (*SignalServer) Start

func (ss *SignalServer) Start() error