Golang grpc.NewClientStream函数代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中google/golang.org/grpc.NewClientStream函数的典型用法代码示例。如果您正苦于以下问题：Golang NewClientStream函数的具体用法？Golang NewClientStream怎么用？Golang NewClientStream使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。

在下文中一共展示了NewClientStream函数的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: StreamDelete

func (c *valueStoreClient) StreamDelete(ctx context.Context, opts ...grpc.CallOption) (ValueStore_StreamDeleteClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_ValueStore_serviceDesc.Streams[3], c.cc, "/valueproto.ValueStore/StreamDelete", opts...)
	if err != nil {
		return nil, err
	}
	x := &valueStoreStreamDeleteClient{stream}
	return x, nil
}

开发者ID:wreese，项目名称:oort，代码行数:8，代码来源:value_api.pb.go

示例2: Stream

func (c *gameServiceClient) Stream(ctx context.Context, opts ...grpc.CallOption) (GameService_StreamClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_GameService_serviceDesc.Streams[0], c.cc, "/proto.GameService/Stream", opts...)
	if err != nil {
		return nil, err
	}
	x := &gameServiceStreamClient{stream}
	return x, nil
}

开发者ID:anders007，项目名称:libs，代码行数:8，代码来源:game.pb.go

示例3: RouteChat

func (c *routeGuideClient) RouteChat(ctx context.Context, opts ...grpc.CallOption) (RouteGuide_RouteChatClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_RouteGuide_serviceDesc.Streams[2], c.cc, "/routeguide.RouteGuide/RouteChat", opts...)
	if err != nil {
		return nil, err
	}
	x := &routeGuideRouteChatClient{stream}
	return x, nil
}

开发者ID:CocoaWang，项目名称:grpc-go，代码行数:8，代码来源:route_guide.pb.go

示例4: HalfDuplexCall

func (c *testServiceClient) HalfDuplexCall(ctx context.Context, opts ...grpc.CallOption) (TestService_HalfDuplexCallClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_TestService_serviceDesc.Streams[3], c.cc, "/grpc.testing.TestService/HalfDuplexCall", opts...)
	if err != nil {
		return nil, err
	}
	x := &testServiceHalfDuplexCallClient{stream}
	return x, nil
}

开发者ID:Clarifai，项目名称:kubernetes，代码行数:8，代码来源:test.pb.go

示例5: Chat

func (c *peerClient) Chat(ctx context.Context, opts ...grpc.CallOption) (Peer_ChatClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_Peer_serviceDesc.Streams[0], c.cc, "/protos.Peer/Chat", opts...)
	if err != nil {
		return nil, err
	}
	x := &peerChatClient{stream}
	return x, nil
}

开发者ID:masterDev1985，项目名称:obc-peer，代码行数:8，代码来源:openchain.pb.go

示例6: CharCount

func (c *longTestsClient) CharCount(ctx context.Context, opts ...grpc.CallOption) (LongTests_CharCountClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_LongTests_serviceDesc.Streams[0], c.cc, "/LongTests/char_count", opts...)
	if err != nil {
		return nil, err
	}
	x := &longTestsCharCountClient{stream}
	return x, nil
}

开发者ID:stepancheg，项目名称:grpc-rust，代码行数:8，代码来源:long_tests_pb.pb.go

示例7: Do

func (c *aPIClient) Do(ctx context.Context, opts ...grpc.CallOption) (API_DoClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_API_serviceDesc.Streams[0], c.cc, "/protoprocess.API/Do", opts...)
	if err != nil {
		return nil, err
	}
	x := &aPIDoClient{stream}
	return x, nil
}

开发者ID:peter-edge，项目名称:proto-go，代码行数:8，代码来源:protoprocess.pb.go

示例8: Bidi

func (c *myTestClient) Bidi(ctx context.Context, opts ...grpc1.CallOption) (MyTest_BidiClient, error) {
	stream, err := grpc1.NewClientStream(ctx, &_MyTest_serviceDesc.Streams[2], c.cc, "/grpc.MyTest/Bidi", opts...)
	if err != nil {
		return nil, err
	}
	x := &myTestBidiClient{stream}
	return x, nil
}

开发者ID:gpaul，项目名称:letmegrpc，代码行数:8，代码来源:grpc.pb.go

示例9: QueueSong

func (c *playsourceClient) QueueSong(ctx context.Context, opts ...grpc.CallOption) (Playsource_QueueSongClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_Playsource_serviceDesc.Streams[0], c.cc, "/Playsource.Playsource/QueueSong", opts...)
	if err != nil {
		return nil, err
	}
	x := &playsourceQueueSongClient{stream}
	return x, nil
}

开发者ID:CrowdSoundSystem，项目名称:go-client，代码行数:8，代码来源:playsource_service.pb.go

示例10: Chat

func (c *chatClient) Chat(ctx context.Context, opts ...grpc.CallOption) (Chat_ChatClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_Chat_serviceDesc.Streams[0], c.cc, "/chat_msg.Chat/Chat", opts...)
	if err != nil {
		return nil, err
	}
	x := &chatChatClient{stream}
	return x, nil
}

开发者ID:alvindaiyan，项目名称:goTalk2，代码行数:8，代码来源:chat_msg.pb.go

示例11: Enter

func (c *kurmaClient) Enter(ctx context.Context, opts ...grpc.CallOption) (Kurma_EnterClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_Kurma_serviceDesc.Streams[1], c.cc, "/client.Kurma/Enter", opts...)
	if err != nil {
		return nil, err
	}
	x := &kurmaEnterClient{stream}
	return x, nil
}

开发者ID:liyangdal，项目名称:kurma，代码行数:8，代码来源:init.pb.go

示例12: UploadImage

func (c *kurmaClient) UploadImage(ctx context.Context, opts ...grpc.CallOption) (Kurma_UploadImageClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_Kurma_serviceDesc.Streams[0], c.cc, "/client.Kurma/UploadImage", opts...)
	if err != nil {
		return nil, err
	}
	x := &kurmaUploadImageClient{stream}
	return x, nil
}

开发者ID:liyangdal，项目名称:kurma，代码行数:8，代码来源:init.pb.go

示例13: BalanceLoad

func (c *loadBalancerClient) BalanceLoad(ctx context.Context, opts ...grpc.CallOption) (LoadBalancer_BalanceLoadClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_LoadBalancer_serviceDesc.Streams[0], c.cc, "/grpc.lb.v1.LoadBalancer/BalanceLoad", opts...)
	if err != nil {
		return nil, err
	}
	x := &loadBalancerBalanceLoadClient{stream}
	return x, nil
}

开发者ID:ruinanchen，项目名称:grpc-go，代码行数:8，代码来源:grpclb.pb.go

示例14: RunClient

func (c *workerServiceClient) RunClient(ctx context.Context, opts ...grpc.CallOption) (WorkerService_RunClientClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_WorkerService_serviceDesc.Streams[1], c.cc, "/grpc.testing.WorkerService/RunClient", opts...)
	if err != nil {
		return nil, err
	}
	x := &workerServiceRunClientClient{stream}
	return x, nil
}

开发者ID:CocoaWang，项目名称:grpc-go，代码行数:8，代码来源:services.pb.go

示例15: StreamingSearch

func (c *searchServiceClient) StreamingSearch(ctx context.Context, opts ...grpc.CallOption) (SearchService_StreamingSearchClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_SearchService_serviceDesc.Streams[0], c.cc, "/grpc.testing.SearchService/StreamingSearch", opts...)
	if err != nil {
		return nil, err
	}
	x := &searchServiceStreamingSearchClient{stream}
	return x, nil
}

开发者ID:CocoaWang，项目名称:grpc-go，代码行数:8，代码来源:test.pb.go

示例16: StreamingCall

func (c *benchmarkServiceClient) StreamingCall(ctx context.Context, opts ...grpc.CallOption) (BenchmarkService_StreamingCallClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_BenchmarkService_serviceDesc.Streams[0], c.cc, "/grpc.testing.BenchmarkService/StreamingCall", opts...)
	if err != nil {
		return nil, err
	}
	x := &benchmarkServiceStreamingCallClient{stream}
	return x, nil
}

开发者ID:CocoaWang，项目名称:grpc-go，代码行数:8，代码来源:services.pb.go

示例17: RecordRoute

func (c *routeGuideClient) RecordRoute(ctx context.Context, opts ...grpc.CallOption) (RouteGuide_RecordRouteClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_RouteGuide_serviceDesc.Streams[1], c.cc, "/proto.RouteGuide/RecordRoute", opts...)
	if err != nil {
		return nil, err
	}
	x := &routeGuideRecordRouteClient{stream}
	return x, nil
}

开发者ID:johndmulhausen，项目名称:kubernetes，代码行数:8，代码来源:route_guide.pb.go

示例18: FlowStream

func (c *distSQLClient) FlowStream(ctx context.Context, opts ...grpc.CallOption) (DistSQL_FlowStreamClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_DistSQL_serviceDesc.Streams[1], c.cc, "/cockroach.sql.distsql.DistSQL/FlowStream", opts...)
	if err != nil {
		return nil, err
	}
	x := &distSQLFlowStreamClient{stream}
	return x, nil
}

开发者ID:hvaara，项目名称:cockroach，代码行数:8，代码来源:api.pb.go

示例19: Bar

func (c *fooClient) Bar(ctx context.Context, opts ...grpc.CallOption) (Foo_BarClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_Foo_serviceDesc.Streams[0], c.cc, "/Foo/Bar", opts...)
	if err != nil {
		return nil, err
	}
	x := &fooBarClient{stream}
	return x, nil
}

开发者ID:dpetersen，项目名称:headerbug，代码行数:8，代码来源:test.pb.go

示例20: PutBlock

func (c *aPIClient) PutBlock(ctx context.Context, opts ...grpc.CallOption) (API_PutBlockClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_API_serviceDesc.Streams[0], c.cc, "/.API/PutBlock", opts...)
	if err != nil {
		return nil, err
	}
	x := &aPIPutBlockClient{stream}
	return x, nil
}

开发者ID:tottok-ug，项目名称:pachyderm，代码行数:8，代码来源:drive.pb.go

注：本文中的google/golang.org/grpc.NewClientStream函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。