Home
last modified time | relevance | path

Searched defs:ClientStream (Results 1 – 25 of 3343) sorted by relevance

12345678910>>...134

/dports/net/grpcui/grpcui-1.1.0/vendor/github.com/jhump/protoreflect/dynamic/grpcdynamic/
H A Dstub.go199 type ClientStream struct { struct
200 stream grpc.ClientStream
201 method *desc.MethodDescriptor
202 mf *dynamic.MessageFactory
203 cancel context.CancelFunc
208 func (s *ClientStream) Header() (metadata.MD, error) {
214 func (s *ClientStream) Trailer() metadata.MD {
219 func (s *ClientStream) Context() context.Context {
224 func (s *ClientStream) SendMsg(m proto.Message) error {
232 func (s *ClientStream) CloseAndReceive() (proto.Message, error) {
/dports/net/evans/evans-0.9.1/vendor/github.com/jhump/protoreflect/dynamic/grpcdynamic/
H A Dstub.go199 type ClientStream struct { struct
200 stream grpc.ClientStream
201 method *desc.MethodDescriptor
202 mf *dynamic.MessageFactory
203 cancel context.CancelFunc
208 func (s *ClientStream) Header() (metadata.MD, error) {
214 func (s *ClientStream) Trailer() metadata.MD {
219 func (s *ClientStream) Context() context.Context {
224 func (s *ClientStream) SendMsg(m proto.Message) error {
232 func (s *ClientStream) CloseAndReceive() (proto.Message, error) {
/dports/www/gitea/gitea-1.16.5/vendor/github.com/jhump/protoreflect/dynamic/grpcdynamic/
H A Dstub.go199 type ClientStream struct { struct
200 stream grpc.ClientStream
201 method *desc.MethodDescriptor
202 mf *dynamic.MessageFactory
203 cancel context.CancelFunc
208 func (s *ClientStream) Header() (metadata.MD, error) {
214 func (s *ClientStream) Trailer() metadata.MD {
219 func (s *ClientStream) Context() context.Context {
224 func (s *ClientStream) SendMsg(m proto.Message) error {
232 func (s *ClientStream) CloseAndReceive() (proto.Message, error) {
/dports/net/grpcox/grpcox-1.0.0/vendor/github.com/jhump/protoreflect/dynamic/grpcdynamic/
H A Dstub.go199 type ClientStream struct { struct
200 stream grpc.ClientStream
201 method *desc.MethodDescriptor
202 mf *dynamic.MessageFactory
203 cancel context.CancelFunc
208 func (s *ClientStream) Header() (metadata.MD, error) {
214 func (s *ClientStream) Trailer() metadata.MD {
219 func (s *ClientStream) Context() context.Context {
224 func (s *ClientStream) SendMsg(m proto.Message) error {
232 func (s *ClientStream) CloseAndReceive() (proto.Message, error) {
/dports/net/grpcurl/grpcurl-1.8.5/vendor/github.com/jhump/protoreflect/dynamic/grpcdynamic/
H A Dstub.go199 type ClientStream struct { struct
200 stream grpc.ClientStream
201 method *desc.MethodDescriptor
202 mf *dynamic.MessageFactory
203 cancel context.CancelFunc
208 func (s *ClientStream) Header() (metadata.MD, error) {
214 func (s *ClientStream) Trailer() metadata.MD {
219 func (s *ClientStream) Context() context.Context {
224 func (s *ClientStream) SendMsg(m proto.Message) error {
232 func (s *ClientStream) CloseAndReceive() (proto.Message, error) {
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/session/test/
H A DHQDownstreamSessionTest.h165 struct ClientStream { struct
166 explicit ClientStream(std::unique_ptr<proxygen::HTTPCodec> c) in ClientStream() function
176 ClientStream& getStream(proxygen::HTTPCodec::StreamID id); argument
/dports/net/grpcurl/grpcurl-1.8.5/vendor/google.golang.org/grpc/xds/internal/client/v3/
H A Dloadreport.go48 func (v3c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
64 func (v3c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
95 func (v3c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/net/rclone/rclone-1.57.0/vendor/google.golang.org/grpc/xds/internal/xdsclient/v3/
H A Dloadreport.go49 func (v3c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v3c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v3c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/net/rclone/rclone-1.57.0/vendor/google.golang.org/grpc/xds/internal/xdsclient/v2/
H A Dloadreport.go49 func (v2c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v2c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v2c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/net/drive/drive-0.4.0/vendor/google.golang.org/grpc/xds/internal/xdsclient/v2/
H A Dloadreport.go49 func (v2c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v2c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v2c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/net/drive/drive-0.4.0/vendor/google.golang.org/grpc/xds/internal/xdsclient/v3/
H A Dloadreport.go49 func (v3c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v3c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v3c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/google.golang.org/grpc/xds/internal/client/v2/
H A Dloadreport.go48 func (v2c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
64 func (v2c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
95 func (v2c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/grpc/xds/internal/xdsclient/v3/
H A Dloadreport.go49 func (v3c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v3c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v3c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/grpc/xds/internal/xdsclient/v2/
H A Dloadreport.go49 func (v2c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v2c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v2c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/www/gitea/gitea-1.16.5/vendor/google.golang.org/grpc/xds/internal/xdsclient/controller/version/v3/
H A Dloadreport.go49 func (v3c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v3c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v3c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/google.golang.org/grpc/xds/internal/xdsclient/v2/
H A Dloadreport.go49 func (v2c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v2c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v2c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/google.golang.org/grpc/xds/internal/xdsclient/v3/
H A Dloadreport.go49 func (v3c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v3c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v3c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/net/cloudquery/cloudquery-0.16.0/vendor/google.golang.org/grpc/xds/internal/xdsclient/v2/
H A Dloadreport.go49 func (v2c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v2c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v2c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/net/cloudquery/cloudquery-0.16.0/vendor/google.golang.org/grpc/xds/internal/xdsclient/v3/
H A Dloadreport.go49 func (v3c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v3c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v3c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/google.golang.org/grpc/xds/internal/xdsclient/v3/
H A Dloadreport.go49 func (v3c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v3c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v3c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/google.golang.org/grpc/xds/internal/xdsclient/v2/
H A Dloadreport.go49 func (v2c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v2c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v2c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/security/xray-core/Xray-core-1.5.0/vendor/google.golang.org/grpc/xds/internal/xdsclient/v2/
H A Dloadreport.go49 func (v2c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v2c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v2c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/security/xray-core/Xray-core-1.5.0/vendor/google.golang.org/grpc/xds/internal/xdsclient/v3/
H A Dloadreport.go49 func (v3c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
65 func (v3c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
96 func (v3c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/google.golang.org/grpc/xds/internal/client/v2/
H A Dloadreport.go48 func (v2c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
64 func (v2c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
95 func (v2c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/google.golang.org/grpc/xds/internal/client/v3/
H A Dloadreport.go48 func (v3c *client) SendFirstLoadStatsRequest(s grpc.ClientStream) error {
64 func (v3c *client) HandleLoadStatsResponse(s grpc.ClientStream) ([]string, time.Duration, error) {
95 func (v3c *client) SendLoadStatsRequest(s grpc.ClientStream, loads []*load.Data) error {

12345678910>>...134