How to use NewClient method of grpc Package

Best K6 code snippet using grpc.NewClient

controller.go

Source:controller.go Github

copy

Full Screen

...34 if err := grpcServer.Serve(l); err != nil {35 errChan <- err36 }37}38func NewClient(silenceOutput bool) (pb.AnywhereServerClient, error) {39 h := log.NewHeader("grpc")40 cc, err := grpc.Dial(grpcAddress, grpc.WithInsecure(),41 grpc.WithUnaryInterceptor(func(ctx context.Context, method string, req, reply interface{},42 cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {43 if !silenceOutput {44 log.Infof(h, "calling %v", method)45 }46 err := invoker(ctx, method, req, reply, cc, opts...)47 if !silenceOutput {48 log.Infof(h, "called %v, error: %v", method, err)49 }50 return err51 }))52 if err != nil {53 return nil, err54 }55 return pb.NewAnywhereServerClient(cc), nil56}57func ListAgent() error {58 client, err := NewClient(true)59 if err != nil {60 return err61 }62 res, err := client.ListAgent(context.Background(), &pb.Empty{})63 if err != nil {64 return err65 }66 table := tablewriter.NewWriter(os.Stdout)67 table.SetAutoFormatHeaders(false)68 table.SetHeader([]string{"UserName", "ZoneName", "AgentId", "AgentAddr", "LastAckSend", "LastAckRcv"})69 for _, agent := range res.Agent {70 table.Append([]string{agent.UserName, agent.ZoneName, agent.Id, agent.RemoteAddr, agent.LastAckSend, agent.LastAckRcv})71 }72 table.Render()73 return nil74}75func AddProxyConfig(userName, zoneName string, remotePort int, localAddr string, isWhiteListOn bool, whiteListIps string) error {76 client, err := NewClient(true)77 if err != nil {78 return err79 }80 input := &pb.AddProxyConfigInput{Config: &pb.ProxyConfig{81 Username: userName,82 ZoneName: zoneName,83 RemotePort: int64(remotePort),84 LocalAddr: localAddr,85 IsWhiteListOn: isWhiteListOn,86 WhiteCidrList: whiteListIps,87 }}88 if _, err = client.AddProxyConfig(context.Background(), input); err != nil {89 return fmt.Errorf("add proxy config error: %v", err)90 }91 return nil92}93func ListProxyConfigs() error {94 client, err := NewClient(true)95 if err != nil {96 return err97 }98 configs, err := client.ListProxyConfigs(context.Background(), &pb.Empty{})99 if err != nil {100 return fmt.Errorf("list proxy config error: %v", err)101 }102 table := tablewriter.NewWriter(os.Stdout)103 table.SetAutoFormatHeaders(false)104 table.SetHeader([]string{"UserName", "ZoneName", "ServerPort", "LocalAddr", "IsWhiteListOn", "IpWhiteList", "ConnectCount", "ConnectRejectCount", "TotalNetFlowsInMB"})105 for _, config := range configs.Config {106 table.Append([]string{107 config.Username, config.ZoneName, strconv.FormatInt(config.RemotePort, 10),108 config.LocalAddr, util.BoolToString(config.IsWhiteListOn), config.WhiteCidrList,109 strconv.FormatInt(config.ProxyConnectCount, 10), strconv.FormatInt(config.ProxyConnectRejectCount, 10),110 strconv.FormatFloat(float64(config.NetworkFlowRemoteToLocalInBytes+config.NetworkFlowLocalToRemoteInBytes)/1024/1024, 'f', 5, 64),111 })112 }113 table.Render()114 return nil115}116func RemoveProxyConfig(configId int64) error {117 client, err := NewClient(true)118 if err != nil {119 return err120 }121 _, err = client.RemoveProxyConfig(context.Background(), &pb.RemoveProxyConfigInput{122 Id: configId,123 })124 return err125}126func LoadProxyConfigFile() error {127 client, err := NewClient(true)128 if err != nil {129 return err130 }131 _, err = client.LoadProxyConfigFile(context.Background(), &pb.Empty{})132 return err133}134func SaveProxyConfigToFile() error {135 client, err := NewClient(true)136 if err != nil {137 return err138 }139 _, err = client.SaveProxyConfigToFile(context.Background(), &pb.Empty{})140 return err141}142func UpdateProxyConfigWhiteList(userName, zoneName, localAddr, whiteCidrs string, whiteListEnable bool) error {143 client, err := NewClient(true)144 if err != nil {145 return err146 }147 _, err = client.UpdateProxyConfigWhiteList(context.Background(), &pb.UpdateProxyConfigWhiteListInput{148 UserName: userName,149 ZoneName: zoneName,150 LocalAddr: localAddr,151 WhiteCidrs: whiteCidrs,152 WhiteListEnable: whiteListEnable,153 })154 return err155}156func ListConns(zoneName string) error {157 client, err := NewClient(true)158 if err != nil {159 return err160 }161 res, err := client.ListConns(context.Background(), &pb.ListConnsInput{162 ZoneName: zoneName,163 })164 if err != nil {165 return err166 }167 if len(res.Conn) == 0 {168 fmt.Println("no conn exist")169 return nil170 }171 table := tablewriter.NewWriter(os.Stdout)172 table.SetAutoFormatHeaders(false)173 table.SetHeader([]string{"UserName", "ZoneName", "AgentId", "ConnId", "SrcRemoteAddr", "SrcLocalAddr", "DstRemoteAddr", "DstLocalAddr"})174 for _, conn := range res.Conn {175 table.Append([]string{conn.UserName, conn.ZoneName, conn.AgentId, strconv.Itoa(int(conn.ConnId)), conn.SrcRemoteAddr, conn.SrcLocalAddr, conn.DstRemoteAddr, conn.DstLocalAddr})176 }177 table.Render()178 return nil179}180func KillConn(id int64) error {181 client, err := NewClient(true)182 if err != nil {183 return err184 }185 _, err = client.KillConnById(context.Background(), &pb.KillConnByIdInput{186 Id: id,187 })188 return err189}190func FlushConns() error {191 fmt.Println("ATTENTION: are you sure to flush all connections?")192 fmt.Println("y/n ?")193 reader := bufio.NewReader(os.Stdin)194 text, _ := reader.ReadString('\n')195 if strings.TrimSpace(text) != "y" {196 fmt.Println("cancelled")197 return nil198 }199 client, err := NewClient(true)200 if err != nil {201 return err202 }203 _, err = client.KillAllConns(context.Background(), &pb.Empty{})204 return err205}...

Full Screen

Full Screen

client.go

Source:client.go Github

copy

Full Screen

...6 "google.golang.org/grpc/balancer/roundrobin"7 "google.golang.org/grpc/credentials"8 "google.golang.org/grpc/resolver"9)10// NewClient grpc.Dail()11func NewClient() *grpc.ClientConn {12 // server config13 serverConfig := balancer.GetServerConfig()14 return newClient(serverConfig.ServerName)15}16// NewClientWithServerName grpc.Dail()17func NewClientWithServerName(serverName string) *grpc.ClientConn {18 return newClient(serverName)19}20// newClient grpc.Dail()21func newClient(serverName string) *grpc.ClientConn {22 // resolver23 r := balancer.NewResolver()24 resolver.Register(r)25 // options26 var opts []grpc.DialOption27 // ssl28 if config.SSLEnable {29 cred, err := credentials.NewClientTLSFromFile(config.SSLCertFile, config.SSLServerName)30 if err != nil {31 logrus.Panicf("NewClient credentials.NewClientTLSFromFile error : %v", err)32 }33 opts = append(opts, grpc.WithTransportCredentials(cred))34 } else {35 opts = append(opts, grpc.WithInsecure())36 }37 // balancer name38 opts = append(opts, grpc.WithBalancerName(roundrobin.Name))39 // server address40 serverAddr := r.Scheme() + "://ikaiguang/" + serverName41 logrus.Printf("dial : %s", serverAddr)42 // client43 conn, err := grpc.Dial(serverAddr, opts...)44 if err != nil {45 logrus.Panicf("NewClient grpc.Dial error : %v", err)46 }47 //defer conn.Close()48 return conn49}...

Full Screen

Full Screen

NewClient

Using AI Code Generation

copy

Full Screen

1conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure())2if err != nil {3log.Fatalf("did not connect: %v", err)4}5defer conn.Close()6c := pb.NewGreeterClient(conn)7if len(os.Args) > 1 {8}9ctx, cancel := context.WithTimeout(context.Background(), time.Second)10defer cancel()11r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})12if err != nil {13log.Fatalf("could not greet: %v", err)14}15log.Printf("Greeting: %s", r.Message)16}17conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure())18if err != nil {19log.Fatalf("did not connect: %v", err)20}21defer conn.Close()22c := pb.NewGreeterClient(conn)23if len(os.Args) > 1 {24}25ctx, cancel := context.WithTimeout(context.Background(), time.Second)26defer cancel()27r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})28if err != nil {29log.Fatalf("could not greet: %v", err)30}31log.Printf("Greeting: %s", r.Message)32}

Full Screen

Full Screen

NewClient

Using AI Code Generation

copy

Full Screen

1conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure())2if err != nil {3log.Fatalf("did not connect: %v", err)4}5defer conn.Close()6c := pb.NewGreeterClient(conn)7if len(os.Args) > 1 {8}9ctx, cancel := context.WithTimeout(context.Background(), time.Second)10defer cancel()11r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})12if err != nil {13log.Fatalf("could not greet: %v", err)14}15log.Printf("Greeting: %s", r.Message)16}

Full Screen

Full Screen

NewClient

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 opts = append(opts, grpc.WithInsecure())4 opts = append(opts, grpc.WithBlock())5 opts = append(opts, grpc.WithTimeout(time.Second))6 opts = append(opts, grpc.WithBlock())7 opts = append(opts, grpc.WithUserAgent("test"))8 ctx, cancel := context.WithTimeout(context.Background(), time.Second)9 defer cancel()10 conn, err := grpc.DialContext(ctx, "localhost:8080", opts...)11 if err != nil {12 log.Fatalf("fail to dial: %v", err)13 }14 defer conn.Close()15 fmt.Println("success")16}17import (18func main() {19 opts = append(opts, grpc.WithInsecure())20 opts = append(opts, grpc.WithBlock())21 opts = append(opts, grpc.WithTimeout(time.Second))22 opts = append(opts, grpc.WithBlock())23 opts = append(opts, grpc.WithUserAgent("test"))24 conn, err := grpc.Dial("localhost:8080", opts...)25 if err != nil {26 log.Fatalf("fail to dial: %v", err)27 }28 defer conn.Close()29 fmt.Println("success")30}31import (32func main() {33 opts = append(opts, grpc.WithInsecure())34 opts = append(opts, grpc.WithBlock())35 opts = append(opts, grpc.WithTimeout(time.Second))36 opts = append(opts, grpc.WithBlock())37 opts = append(opts, grpc.WithUserAgent("test"))38 ctx, cancel := context.WithTimeout(context.Background(), time.Second)39 defer cancel()40 conn, err := grpc.DialContext(ctx, "localhost:8080", opts...)41 if err != nil {42 log.Fatalf("fail to dial: %v", err)43 }44 defer conn.Close()45 fmt.Println("success")46}47import (

Full Screen

Full Screen

NewClient

Using AI Code Generation

copy

Full Screen

1conn, err := grpc.NewClient(ctx, grpc.WithInsecure())2if err != nil {3 log.Fatalf("did not connect: %v", err)4}5defer conn.Close()6c := pb.NewGreeterClient(conn)7r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})8if err != nil {9 log.Fatalf("could not greet: %v", err)10}11log.Printf("Greeting: %s", r.Message)12conn, err := grpc.NewClient(ctx, grpc.WithInsecure())13if err != nil {14 log.Fatalf("did not connect: %v", err)15}16defer conn.Close()17c := pb.NewGreeterClient(conn)18r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})19if err != nil {20 log.Fatalf("could not greet: %v", err)21}22log.Printf("Greeting: %s", r.Message)23conn, err := grpc.NewClient(ctx, grpc.WithInsecure())24if err != nil {25 log.Fatalf("did not connect: %v", err)26}27defer conn.Close()28c := pb.NewGreeterClient(conn)29r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})30if err != nil {31 log.Fatalf("could not greet: %v", err)32}33log.Printf("Greeting: %s", r.Message)34conn, err := grpc.NewClient(ctx, grpc.WithInsecure())35if err != nil {36 log.Fatalf("did not connect: %v", err)37}38defer conn.Close()39c := pb.NewGreeterClient(conn)

Full Screen

Full Screen

NewClient

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure(), grpc.WithBlock())4 if err != nil {5 log.Fatalf("did not connect: %v", err)6 }7 defer conn.Close()8 c := pb.NewGreeterClient(conn)9 ctx, cancel := context.WithTimeout(context.Background(), time.Second)10 defer cancel()11 r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})12 if err != nil {13 log.Fatalf("could not greet: %v", err)14 }15 fmt.Println("Greeting: ", r.Message)16}17import (18func main() {19 lis, err := net.Listen("tcp", fmt.Sprintf(":%d", 50051))20 if err != nil {21 log.Fatalf("failed to listen: %v", err)22 }23 s := grpc.NewServer()24 pb.RegisterGreeterServer(s, &server{})25 if err := s.Serve(lis); err != nil {26 log.Fatalf("failed to serve: %v", err)27 }28}29import (30func main() {31 conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure())32 if err != nil {33 log.Fatalf("did not connect: %v", err)34 }35 defer conn.Close()36}37import (38func main() {39 lis, err := net.Listen("tcp", fmt.Sprintf(":%d", 50051))40 if err != nil {41 log.Fatalf("failed to listen: %v", err)42 }43 s := grpc.NewServer()

Full Screen

Full Screen

NewClient

Using AI Code Generation

copy

Full Screen

1import (2const (3type server struct{}4func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {5 return &pb.HelloReply{Message: "Hello " + in.Name}, nil6}7func main() {8 lis, err := net.Listen("tcp", port)9 if err != nil {10 log.Fatalf("failed to listen: %v", err)11 }12 s := grpc.NewServer()13 pb.RegisterGreeterServer(s, &server{})14 reflection.Register(s)15 if err := s.Serve(lis); err != nil {16 log.Fatalf("failed to serve: %v", err)17 }18}19import (20type HelloRequest struct {21}22func (m *HelloRequest) Reset() { *m = HelloRequest{} }23func (m *HelloRequest) String() string { return proto.CompactTextString(m) }24func (*HelloRequest) ProtoMessage() {}25func (*HelloRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }26type HelloReply struct {27}28func (m *HelloReply) Reset()

Full Screen

Full Screen

NewClient

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 conn, err := grpc.Dial("localhost:9000", grpc.WithInsecure())4 if err != nil {5 log.Fatalf("did not connect: %v", err)6 }7 defer conn.Close()8 c := pb.NewGreeterClient(conn)9 ctx, cancel := context.WithTimeout(context.Background(), time.Second)10 defer cancel()11 r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})12 if err != nil {13 log.Fatalf("could not greet: %v", err)14 }15 fmt.Println("Greeting: ", r.Message)16}

Full Screen

Full Screen

NewClient

Using AI Code Generation

copy

Full Screen

1import (2const (3func main() {4 conn, err := grpc.Dial(address, grpc.WithInsecure())5 if err != nil {6 log.Fatalf("did not connect: %v", err)7 }8 defer conn.Close()9 c := pb.NewGreeterClient(conn)10 if len(os.Args) > 1 {11 }12 ctx, cancel := context.WithTimeout(context.Background(), time.Second)13 defer cancel()14 r, err := c.SayHello(ctx, &pb.HelloRequest{Name: name})15 if err != nil {16 log.Fatalf("could not greet: %v", err)17 }18 log.Printf("Greeting: %s", r.Message)19}20import (21const (22type server struct {23}24func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {25 log.Printf("Received: %v", in.GetName())26 return &pb.HelloReply{Message: "Hello " + in.GetName()}, nil27}28func main() {29 lis, err := net.Listen("tcp", port)30 if err != nil {31 log.Fatalf("failed to listen: %v", err)32 }33 s := grpc.NewServer()34 pb.RegisterGreeterServer(s, &server{})35 if err := s.Serve(lis); err != nil {36 log.Fatalf("failed to serve: %v", err)37 }38}39syntax = "proto3";40package proto;

Full Screen

Full Screen

NewClient

Using AI Code Generation

copy

Full Screen

1import (2type server struct {3}4func main() {5 lis, err := net.Listen("tcp", ":50051")6 if err != nil {7 log.Fatalf("failed to listen: %v", err)8 }9 s := grpc.NewServer()10 pb.RegisterAddServiceServer(s, &server{})11 if err := s.Serve(lis); err != nil {12 log.Fatalf("failed to serve: %v", err)13 }14}15func (s *server) Add(ctx context.Context, in *pb.Request) (*pb.Response, error) {16 fmt.Printf("Received: %v17", in.GetA())18 return &pb.Response{Sum: in.GetA() + in.GetB()}, nil19}20import (21func main() {22 conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure())23 if err != nil {24 log.Fatalf("did not connect: %v", err)25 }26 defer conn.Close()27 c := pb.NewAddServiceClient(conn)28 r, err := c.Add(context.Background(), &pb.Request{A: 3, B: 4})29 if err != nil {30 log.Fatalf("could not greet: %v", err)31 }32 log.Printf("Greeting: %s", r.GetSum())33}

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run K6 automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Most used method in

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful