mirror of
https://github.com/go-micro/go-micro.git
synced 2025-01-05 10:20:53 +02:00
65 lines
1.1 KiB
Go
65 lines
1.1 KiB
Go
package tests
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"go-micro.dev/v4"
|
|
"go-micro.dev/v4/broker"
|
|
"go-micro.dev/v4/client"
|
|
"go-micro.dev/v4/registry"
|
|
"go-micro.dev/v4/server"
|
|
"go-micro.dev/v4/transport"
|
|
"go-micro.dev/v4/util/test"
|
|
)
|
|
|
|
func BenchmarkService(b *testing.B) {
|
|
cfg := ServiceTestConfig{
|
|
Name: "test-service",
|
|
NewService: newService,
|
|
Parallel: []int{1, 8, 16, 32, 64},
|
|
Sequential: []int{0},
|
|
Streams: []int{0},
|
|
// PubSub: []int{10},
|
|
}
|
|
|
|
cfg.Run(b)
|
|
}
|
|
|
|
func newService(name string, opts ...micro.Option) (micro.Service, error) {
|
|
r := registry.NewMemoryRegistry(
|
|
registry.Services(test.Data),
|
|
)
|
|
|
|
b := broker.NewMemoryBroker()
|
|
|
|
t := transport.NewHTTPTransport()
|
|
c := client.NewClient(
|
|
client.Transport(t),
|
|
client.Broker(b),
|
|
)
|
|
|
|
s := server.NewRPCServer(
|
|
server.Name(name),
|
|
server.Registry(r),
|
|
server.Transport(t),
|
|
server.Broker(b),
|
|
)
|
|
|
|
if err := s.Init(); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
options := []micro.Option{
|
|
micro.Name(name),
|
|
micro.Server(s),
|
|
micro.Client(c),
|
|
micro.Registry(r),
|
|
micro.Broker(b),
|
|
}
|
|
options = append(options, opts...)
|
|
|
|
srv := micro.NewService(options...)
|
|
|
|
return srv, nil
|
|
}
|