util

Nov 9, 2021

Changes in this version

+ func BoolToString(flag bool) string

+ func GetArgs(args ...string) (arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10 string)

+ func GetRedisPeerKey(sid, uid string) string

+ func GetRedisPeersPrefixKey(sid string) string

+ func GetRedisRoomKey(sid string) string

+ func StringToBool(flag string) bool

+ type WrapperedGRPCWebServer struct

+ GRPCServer *grpc.Server

+ func NewWrapperedGRPCWebServer(options WrapperedServerOptions, s *grpc.Server) *WrapperedGRPCWebServer

+ func (s *WrapperedGRPCWebServer) Serve() error

+ type WrapperedServerOptions struct

+ Addr string

+ AllowAllOrigins bool

+ AllowedHeaders *[]string

+ AllowedOrigins *[]string

+ Cert string

+ Key string

+ UseWebSocket bool

+ WebsocketPingInterval time.Duration

+ func DefaultWrapperedServerOptions() WrapperedServerOptions

+ func NewWrapperedServerOptions(addr, cert, key string, websocket bool) WrapperedServerOptions

Jun 18, 2021

Changes in this version

+ func GetServiceInfo(nc nrpc.NatsConn, nid string, selfnid string) (map[string][]*reflection.MethodDescriptor, error)

Apr 10, 2021

Changes in this version

+ const DefaultGRPCTimeout

+ const DefaultStatCycle

+ func NewNatsConn(url string) (*nats.Conn, error)

+ func ParseSDP(sdpstr string) ([]*ion.Stream, error)

+ type ClientConnInterface interface

+ Close func() error

+ func NewGRPCClientConnForNode(node discovery.Node) (ClientConnInterface, error)

+ type ServiceInterface interface

+ Serve func(lis net.Listener) error

+ Stop func()

+ func NewGRPCServiceForNode(node discovery.Node) (ServiceInterface, error)

Nov 27, 2020

Changes in this version

+ func GetInterfaceIP() string

+ func RandomString(n int) string

+ type AtomicBool struct

+ func (b *AtomicBool) Get() bool

+ func (b *AtomicBool) Set(value bool)

Jun 3, 2020

Changes in this version

+ func KvOK(m map[string]interface{}, k, v string) bool

May 14, 2020

Changes in this version

+ func GetMID(uid string) string

May 1, 2020

Changes in this version

+ func NewNpError(code int, reason string) *nprotoo.Error

Feb 22, 2020

Changes in this version

+ func GetIDFromRTP(pkt *rtp.Packet) string

+ func GetIP(addr string) string

+ func GetIPFromSTUN(stunURL string) string

+ func GetIntefaceIP() string

+ func GetLostSN(begin, bitmap uint16) []uint16

+ func GetMills() int64

+ func GetPort(addr string) string

+ func IsLocalIP(ip string) bool

+ func IsVideo(pt uint8) bool

+ func Map(args ...interface{}) map[string]interface

+ func Marshal(m map[string]interface{}) string

+ func MarshalStr(args ...interface{}) string

+ func MarshalStrMap(m map[string]string) string

+ func RandStr(l int) string

+ func ReadAbsSendTime(pkt *rtp.Packet) (uint32, bool)

+ func Recover(flag string)

+ func SetIDToRTP(pkt *rtp.Packet, id string) *rtp.Packet

+ func StrToUint32(str string) uint32

+ func StrToUint8(str string) uint8

+ func Unmarshal(str string) map[string]interface

+ func Val(msg map[string]interface{}, key string) string