INNER CODE UNIT · Go

cache

hb-chen/micro-starter · benchmark/_backup/micro_client.go:69

			cache := selector.NewSelector(func(o *selector.Options) {
				o.Context = context.WithValue(o.Context, "selector_ttl", time.Second*30)
			})

			helloClient := client.NewClient(
				client.Transport(tcp.NewTransport()),
				// client.ContentType("application/protobuf"),
				client.Selector(cache),
				client.Retries(1),
				client.PoolSize(10),
				client.RequestTimeout(time.Millisecond*100),
				client.Wrap(breaker.NewClientWrapper()),
				client.Wrap(ratelimit.NewClientWrapper(10)),
			)
			c := proto.NewHelloService("hello", helloClient)

			// warmup
			for j := 0; j < 5; j++ {

View source record →