pb

package
v1.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 25, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GrpcbinService_Unary_FullMethodName                  = "/main.GrpcbinService/Unary"
	GrpcbinService_ServerStreaming_FullMethodName        = "/main.GrpcbinService/ServerStreaming"
	GrpcbinService_ClientStreaming_FullMethodName        = "/main.GrpcbinService/ClientStreaming"
	GrpcbinService_BidirectionalStreaming_FullMethodName = "/main.GrpcbinService/BidirectionalStreaming"
)

Variables

View Source 
var File_pb_service_proto protoreflect.FileDescriptor
View Source 
var GrpcbinService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "main.GrpcbinService",
	HandlerType: (*GrpcbinServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Unary",
			Handler:    _GrpcbinService_Unary_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ServerStreaming",
			Handler:       _GrpcbinService_ServerStreaming_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ClientStreaming",
			Handler:       _GrpcbinService_ClientStreaming_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "BidirectionalStreaming",
			Handler:       _GrpcbinService_BidirectionalStreaming_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pb/service.proto",
}

GrpcbinService_ServiceDesc is the grpc.ServiceDesc for GrpcbinService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGrpcbinServiceServer 

func RegisterGrpcbinServiceServer(s grpc.ServiceRegistrar, srv GrpcbinServiceServer)

Types

type BidirectionalStreamingRequest 

type BidirectionalStreamingRequest struct {
	RequestAttributes *RequestAttributes `protobuf:"bytes,1,opt,name=request_attributes,json=requestAttributes,proto3" json:"request_attributes,omitempty"`
	Data              string             `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BidirectionalStreamingRequest) Descriptor deprecated 

func (*BidirectionalStreamingRequest) Descriptor() ([]byte, []int)

Deprecated: Use BidirectionalStreamingRequest.ProtoReflect.Descriptor instead.

func (*BidirectionalStreamingRequest) GetData 

func (x *BidirectionalStreamingRequest) GetData() string

func (*BidirectionalStreamingRequest) GetRequestAttributes 

func (x *BidirectionalStreamingRequest) GetRequestAttributes() *RequestAttributes

func (*BidirectionalStreamingRequest) ProtoMessage 

func (*BidirectionalStreamingRequest) ProtoMessage()

func (*BidirectionalStreamingRequest) ProtoReflect 

func (x *BidirectionalStreamingRequest) ProtoReflect() protoreflect.Message

func (*BidirectionalStreamingRequest) Reset 

func (x *BidirectionalStreamingRequest) Reset()

func (*BidirectionalStreamingRequest) String 

func (x *BidirectionalStreamingRequest) String() string

type BidirectionalStreamingResponse 

type BidirectionalStreamingResponse struct {
	ResponseAttributes *ResponseAttributes `protobuf:"bytes,1,opt,name=response_attributes,json=responseAttributes,proto3" json:"response_attributes,omitempty"`
	Result             string              `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*BidirectionalStreamingResponse) Descriptor deprecated 

func (*BidirectionalStreamingResponse) Descriptor() ([]byte, []int)

Deprecated: Use BidirectionalStreamingResponse.ProtoReflect.Descriptor instead.

func (*BidirectionalStreamingResponse) GetResponseAttributes 

func (x *BidirectionalStreamingResponse) GetResponseAttributes() *ResponseAttributes

func (*BidirectionalStreamingResponse) GetResult 

func (x *BidirectionalStreamingResponse) GetResult() string

func (*BidirectionalStreamingResponse) ProtoMessage 

func (*BidirectionalStreamingResponse) ProtoMessage()

func (*BidirectionalStreamingResponse) ProtoReflect 

func (x *BidirectionalStreamingResponse) ProtoReflect() protoreflect.Message

func (*BidirectionalStreamingResponse) Reset 

func (x *BidirectionalStreamingResponse) Reset()

func (*BidirectionalStreamingResponse) String 

func (x *BidirectionalStreamingResponse) String() string

type ClientStreamingRequest 

type ClientStreamingRequest struct {
	RequestAttributes *RequestAttributes `protobuf:"bytes,1,opt,name=request_attributes,json=requestAttributes,proto3" json:"request_attributes,omitempty"`
	Data              string             `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientStreamingRequest) Descriptor deprecated 

func (*ClientStreamingRequest) Descriptor() ([]byte, []int)

Deprecated: Use ClientStreamingRequest.ProtoReflect.Descriptor instead.

func (*ClientStreamingRequest) GetData 

func (x *ClientStreamingRequest) GetData() string

func (*ClientStreamingRequest) GetRequestAttributes 

func (x *ClientStreamingRequest) GetRequestAttributes() *RequestAttributes

func (*ClientStreamingRequest) ProtoMessage 

func (*ClientStreamingRequest) ProtoMessage()

func (*ClientStreamingRequest) ProtoReflect 

func (x *ClientStreamingRequest) ProtoReflect() protoreflect.Message

func (*ClientStreamingRequest) Reset 

func (x *ClientStreamingRequest) Reset()

func (*ClientStreamingRequest) String 

func (x *ClientStreamingRequest) String() string

type ClientStreamingResponse 

type ClientStreamingResponse struct {
	ResponseAttributes *ResponseAttributes `protobuf:"bytes,1,opt,name=response_attributes,json=responseAttributes,proto3" json:"response_attributes,omitempty"`
	Result             string              `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientStreamingResponse) Descriptor deprecated 

func (*ClientStreamingResponse) Descriptor() ([]byte, []int)

Deprecated: Use ClientStreamingResponse.ProtoReflect.Descriptor instead.

func (*ClientStreamingResponse) GetResponseAttributes 

func (x *ClientStreamingResponse) GetResponseAttributes() *ResponseAttributes

func (*ClientStreamingResponse) GetResult 

func (x *ClientStreamingResponse) GetResult() string

func (*ClientStreamingResponse) ProtoMessage 

func (*ClientStreamingResponse) ProtoMessage()

func (*ClientStreamingResponse) ProtoReflect 

func (x *ClientStreamingResponse) ProtoReflect() protoreflect.Message

func (*ClientStreamingResponse) Reset 

func (x *ClientStreamingResponse) Reset()

func (*ClientStreamingResponse) String 

func (x *ClientStreamingResponse) String() string

type GrpcbinServiceClient 

type GrpcbinServiceClient interface {
	// Unary RPC
	Unary(ctx context.Context, in *UnaryRequest, opts ...grpc.CallOption) (*UnaryResponse, error)
	// Server streaming RPC
	ServerStreaming(ctx context.Context, in *ServerStreamingRequest, opts ...grpc.CallOption) (GrpcbinService_ServerStreamingClient, error)
	// Client streaming RPC
	ClientStreaming(ctx context.Context, opts ...grpc.CallOption) (GrpcbinService_ClientStreamingClient, error)
	// Bidirectional streaming RPC
	BidirectionalStreaming(ctx context.Context, opts ...grpc.CallOption) (GrpcbinService_BidirectionalStreamingClient, error)
}

GrpcbinServiceClient is the client API for GrpcbinService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGrpcbinServiceClient 

func NewGrpcbinServiceClient(cc grpc.ClientConnInterface) GrpcbinServiceClient

type GrpcbinServiceServer 

type GrpcbinServiceServer interface {
	// Unary RPC
	Unary(context.Context, *UnaryRequest) (*UnaryResponse, error)
	// Server streaming RPC
	ServerStreaming(*ServerStreamingRequest, GrpcbinService_ServerStreamingServer) error
	// Client streaming RPC
	ClientStreaming(GrpcbinService_ClientStreamingServer) error
	// Bidirectional streaming RPC
	BidirectionalStreaming(GrpcbinService_BidirectionalStreamingServer) error
	// contains filtered or unexported methods
}

GrpcbinServiceServer is the server API for GrpcbinService service. All implementations must embed UnimplementedGrpcbinServiceServer for forward compatibility

type GrpcbinService_BidirectionalStreamingClient 

type GrpcbinService_BidirectionalStreamingClient interface {
	Send(*BidirectionalStreamingRequest) error
	Recv() (*BidirectionalStreamingResponse, error)
	grpc.ClientStream
}

type GrpcbinService_BidirectionalStreamingServer 

type GrpcbinService_BidirectionalStreamingServer interface {
	Send(*BidirectionalStreamingResponse) error
	Recv() (*BidirectionalStreamingRequest, error)
	grpc.ServerStream
}

type GrpcbinService_ClientStreamingClient 

type GrpcbinService_ClientStreamingClient interface {
	Send(*ClientStreamingRequest) error
	CloseAndRecv() (*ClientStreamingResponse, error)
	grpc.ClientStream
}

type GrpcbinService_ClientStreamingServer 

type GrpcbinService_ClientStreamingServer interface {
	SendAndClose(*ClientStreamingResponse) error
	Recv() (*ClientStreamingRequest, error)
	grpc.ServerStream
}

type GrpcbinService_ServerStreamingClient 

type GrpcbinService_ServerStreamingClient interface {
	Recv() (*ServerStreamingResponse, error)
	grpc.ClientStream
}

type GrpcbinService_ServerStreamingServer 

type GrpcbinService_ServerStreamingServer interface {
	Send(*ServerStreamingResponse) error
	grpc.ServerStream
}

type RequestAttributes 

type RequestAttributes struct {
	HttpCode        int32             `protobuf:"varint,1,opt,name=http_code,json=httpCode,proto3" json:"http_code,omitempty"`
	Delay           int32             `protobuf:"varint,2,opt,name=delay,proto3" json:"delay,omitempty"`
	ResponseHeaders map[string]string `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RequestAttributes) Descriptor deprecated 

func (*RequestAttributes) Descriptor() ([]byte, []int)

Deprecated: Use RequestAttributes.ProtoReflect.Descriptor instead.

func (*RequestAttributes) GetDelay 

func (x *RequestAttributes) GetDelay() int32

func (*RequestAttributes) GetHttpCode 

func (x *RequestAttributes) GetHttpCode() int32

func (*RequestAttributes) GetResponseHeaders 

func (x *RequestAttributes) GetResponseHeaders() map[string]string

func (*RequestAttributes) ProtoMessage 

func (*RequestAttributes) ProtoMessage()

func (*RequestAttributes) ProtoReflect 

func (x *RequestAttributes) ProtoReflect() protoreflect.Message

func (*RequestAttributes) Reset 

func (x *RequestAttributes) Reset()

func (*RequestAttributes) String 

func (x *RequestAttributes) String() string

type ResponseAttributes 

type ResponseAttributes struct {
	RequesterIp        string            `protobuf:"bytes,1,opt,name=requester_ip,json=requesterIp,proto3" json:"requester_ip,omitempty"`
	RequesterHost      string            `protobuf:"bytes,2,opt,name=requester_host,json=requesterHost,proto3" json:"requester_host,omitempty"`
	RequesterUserAgent string            `protobuf:"bytes,3,opt,name=requester_user_agent,json=requesterUserAgent,proto3" json:"requester_user_agent,omitempty"`
	RequestHeaders     map[string]string `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResponseAttributes) Descriptor deprecated 

func (*ResponseAttributes) Descriptor() ([]byte, []int)

Deprecated: Use ResponseAttributes.ProtoReflect.Descriptor instead.

func (*ResponseAttributes) GetRequestHeaders 

func (x *ResponseAttributes) GetRequestHeaders() map[string]string

func (*ResponseAttributes) GetRequesterHost 

func (x *ResponseAttributes) GetRequesterHost() string

func (*ResponseAttributes) GetRequesterIp 

func (x *ResponseAttributes) GetRequesterIp() string

func (*ResponseAttributes) GetRequesterUserAgent 

func (x *ResponseAttributes) GetRequesterUserAgent() string

func (*ResponseAttributes) ProtoMessage 

func (*ResponseAttributes) ProtoMessage()

func (*ResponseAttributes) ProtoReflect 

func (x *ResponseAttributes) ProtoReflect() protoreflect.Message

func (*ResponseAttributes) Reset 

func (x *ResponseAttributes) Reset()

func (*ResponseAttributes) String 

func (x *ResponseAttributes) String() string

type ServerStreamingRequest 

type ServerStreamingRequest struct {
	RequestAttributes *RequestAttributes `protobuf:"bytes,1,opt,name=request_attributes,json=requestAttributes,proto3" json:"request_attributes,omitempty"`
	Data              string             `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Count             int32              `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerStreamingRequest) Descriptor deprecated 

func (*ServerStreamingRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerStreamingRequest.ProtoReflect.Descriptor instead.

func (*ServerStreamingRequest) GetCount 

func (x *ServerStreamingRequest) GetCount() int32

func (*ServerStreamingRequest) GetData 

func (x *ServerStreamingRequest) GetData() string

func (*ServerStreamingRequest) GetRequestAttributes 

func (x *ServerStreamingRequest) GetRequestAttributes() *RequestAttributes

func (*ServerStreamingRequest) ProtoMessage 

func (*ServerStreamingRequest) ProtoMessage()

func (*ServerStreamingRequest) ProtoReflect 

func (x *ServerStreamingRequest) ProtoReflect() protoreflect.Message

func (*ServerStreamingRequest) Reset 

func (x *ServerStreamingRequest) Reset()

func (*ServerStreamingRequest) String 

func (x *ServerStreamingRequest) String() string

type ServerStreamingResponse 

type ServerStreamingResponse struct {
	ResponseAttributes *ResponseAttributes `protobuf:"bytes,1,opt,name=response_attributes,json=responseAttributes,proto3" json:"response_attributes,omitempty"`
	Result             string              `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerStreamingResponse) Descriptor deprecated 

func (*ServerStreamingResponse) Descriptor() ([]byte, []int)

Deprecated: Use ServerStreamingResponse.ProtoReflect.Descriptor instead.

func (*ServerStreamingResponse) GetResponseAttributes 

func (x *ServerStreamingResponse) GetResponseAttributes() *ResponseAttributes

func (*ServerStreamingResponse) GetResult 

func (x *ServerStreamingResponse) GetResult() string

func (*ServerStreamingResponse) ProtoMessage 

func (*ServerStreamingResponse) ProtoMessage()

func (*ServerStreamingResponse) ProtoReflect 

func (x *ServerStreamingResponse) ProtoReflect() protoreflect.Message

func (*ServerStreamingResponse) Reset 

func (x *ServerStreamingResponse) Reset()

func (*ServerStreamingResponse) String 

func (x *ServerStreamingResponse) String() string

type UnaryRequest 

type UnaryRequest struct {
	RequestAttributes *RequestAttributes `protobuf:"bytes,1,opt,name=request_attributes,json=requestAttributes,proto3" json:"request_attributes,omitempty"`
	Data              string             `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*UnaryRequest) Descriptor deprecated 

func (*UnaryRequest) Descriptor() ([]byte, []int)

Deprecated: Use UnaryRequest.ProtoReflect.Descriptor instead.

func (*UnaryRequest) GetData 

func (x *UnaryRequest) GetData() string

func (*UnaryRequest) GetRequestAttributes 

func (x *UnaryRequest) GetRequestAttributes() *RequestAttributes

func (*UnaryRequest) ProtoMessage 

func (*UnaryRequest) ProtoMessage()

func (*UnaryRequest) ProtoReflect 

func (x *UnaryRequest) ProtoReflect() protoreflect.Message

func (*UnaryRequest) Reset 

func (x *UnaryRequest) Reset()

func (*UnaryRequest) String 

func (x *UnaryRequest) String() string

type UnaryResponse 

type UnaryResponse struct {
	ResponseAttributes *ResponseAttributes `protobuf:"bytes,1,opt,name=response_attributes,json=responseAttributes,proto3" json:"response_attributes,omitempty"`
	Result             string              `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*UnaryResponse) Descriptor deprecated 

func (*UnaryResponse) Descriptor() ([]byte, []int)

Deprecated: Use UnaryResponse.ProtoReflect.Descriptor instead.

func (*UnaryResponse) GetResponseAttributes 

func (x *UnaryResponse) GetResponseAttributes() *ResponseAttributes

func (*UnaryResponse) GetResult 

func (x *UnaryResponse) GetResult() string

func (*UnaryResponse) ProtoMessage 

func (*UnaryResponse) ProtoMessage()

func (*UnaryResponse) ProtoReflect 

func (x *UnaryResponse) ProtoReflect() protoreflect.Message

func (*UnaryResponse) Reset 

func (x *UnaryResponse) Reset()

func (*UnaryResponse) String 

func (x *UnaryResponse) String() string

type UnimplementedGrpcbinServiceServer 

type UnimplementedGrpcbinServiceServer struct {
}

UnimplementedGrpcbinServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedGrpcbinServiceServer) BidirectionalStreaming 

func (UnimplementedGrpcbinServiceServer) BidirectionalStreaming(GrpcbinService_BidirectionalStreamingServer) error

func (UnimplementedGrpcbinServiceServer) ClientStreaming 

func (UnimplementedGrpcbinServiceServer) ClientStreaming(GrpcbinService_ClientStreamingServer) error

func (UnimplementedGrpcbinServiceServer) ServerStreaming 

func (UnimplementedGrpcbinServiceServer) ServerStreaming(*ServerStreamingRequest, GrpcbinService_ServerStreamingServer) error

func (UnimplementedGrpcbinServiceServer) Unary 

func (UnimplementedGrpcbinServiceServer) Unary(context.Context, *UnaryRequest) (*UnaryResponse, error)

type UnsafeGrpcbinServiceServer 

type UnsafeGrpcbinServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeGrpcbinServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GrpcbinServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.