|
|
|
@ -16,6 +16,7 @@ package startrpc
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
"fmt"
|
|
|
|
|
"github.com/openimsdk/open-im-server/v3/pkg/common/config"
|
|
|
|
|
"net"
|
|
|
|
|
"testing"
|
|
|
|
|
"time"
|
|
|
|
@ -25,7 +26,7 @@ import (
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
// mockRpcFn is a mock gRPC function for testing.
|
|
|
|
|
func mockRpcFn(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error {
|
|
|
|
|
func mockRpcFn(config *config.GlobalConfig, client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error {
|
|
|
|
|
// Implement a mock gRPC service registration logic if needed
|
|
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
@ -40,7 +41,8 @@ func TestStart(t *testing.T) {
|
|
|
|
|
doneChan := make(chan error, 1)
|
|
|
|
|
|
|
|
|
|
go func() {
|
|
|
|
|
err := Start(testRpcPort, testRpcRegisterName, testPrometheusPort, mockRpcFn)
|
|
|
|
|
err := Start(testRpcPort, testRpcRegisterName, testPrometheusPort,
|
|
|
|
|
config.NewGlobalConfig(), mockRpcFn)
|
|
|
|
|
doneChan <- err
|
|
|
|
|
}()
|
|
|
|
|
|
|
|
|
|