external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-03-09 15:49:59 +00:00
Code Issues Releases Wiki Activity

Use memory LB for simple use scenarios.

Browse source
This commit is contained in:
winlin 2024-08-29 17:21:11 +08:00
parent 3269228e64
commit 82707ebd76
2 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

6
proxy/env.go
View file

@ -8,10 +8,10 @@ import (
"os" "os"
"path" "path"
"github.com/joho/godotenv"
"srs-proxy/errors" "srs-proxy/errors"
"srs-proxy/logger" "srs-proxy/logger"
"github.com/joho/godotenv"
) )
// loadEnvFile loads the environment variables from file. Note that we only use .env file. // loadEnvFile loads the environment variables from file. Note that we only use .env file.
@ -48,7 +48,7 @@ func setupDefaultEnv(ctx context.Context) {
setEnvDefault("PROXY_SYSTEM_API", "12025") setEnvDefault("PROXY_SYSTEM_API", "12025")
// The load balancer, use redis or memory. // The load balancer, use redis or memory.
setEnvDefault("PROXY_LOAD_BALANCER_TYPE", "redis") setEnvDefault("PROXY_LOAD_BALANCER_TYPE", "memory")
// The redis server host. // The redis server host.
setEnvDefault("PROXY_REDIS_HOST", "127.0.0.1") setEnvDefault("PROXY_REDIS_HOST", "127.0.0.1")
// The redis server port. // The redis server port.

6
proxy/srs.go
View file

@ -155,7 +155,7 @@ func (v *srsMemoryLoadBalancer) Initialize(ctx context.Context) error {
if err := v.Update(ctx, server); err != nil { if err := v.Update(ctx, server); err != nil {
return errors.Wrapf(err, "update default SRS %+v", server) return errors.Wrapf(err, "update default SRS %+v", server)
} }
logger.Df(ctx, "Initialize default SRS media server, %+v", server) logger.Df(ctx, "MemoryLB: Initialize default SRS media server, %+v", server)
} }
return nil return nil
} }
@ -224,7 +224,7 @@ func (v *srsRedisLoadBalancer) Initialize(ctx context.Context) error {
if err := rdb.Ping(ctx).Err(); err != nil { if err := rdb.Ping(ctx).Err(); err != nil {
return errors.Wrapf(err, "unable to connect to redis %v", rdb.String()) return errors.Wrapf(err, "unable to connect to redis %v", rdb.String())
} }
logger.Df(ctx, "connected to redis %v ok", rdb.String()) logger.Df(ctx, "RedisLB: connected to redis %v ok", rdb.String())
if server, err := NewDefaultSRSForDebugging(); err != nil { if server, err := NewDefaultSRSForDebugging(); err != nil {
return errors.Wrapf(err, "initialize default SRS") return errors.Wrapf(err, "initialize default SRS")
@ -246,7 +246,7 @@ func (v *srsRedisLoadBalancer) Initialize(ctx context.Context) error {
} }
} }
}() }()
logger.Df(ctx, "Initialize default SRS media server, %+v", server) logger.Df(ctx, "RedisLB: Initialize default SRS media server, %+v", server)
} }
return nil return nil
} }