/dports/net/grpcui/grpcui-1.1.0/vendor/github.com/jhump/protoreflect/dynamic/grpcdynamic/ |
H A D | stub.go | 199 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 D | stub.go | 199 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 D | stub.go | 199 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 D | stub.go | 199 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 D | stub.go | 199 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 D | HQDownstreamSessionTest.h | 165 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 D | loadreport.go | 48 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 48 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 49 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 D | loadreport.go | 48 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 D | loadreport.go | 48 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 {
|