stream

Documentation

Index

• Constants
• Variables
• func RegisterGripmockServer(s grpc.ServiceRegistrar, srv GripmockServer)
• type GripmockClient
  • func NewGripmockClient(cc grpc.ClientConnInterface) GripmockClient
• type GripmockServer
• type Gripmock_BidirectionalClient
• type Gripmock_BidirectionalServer
• type Gripmock_ClientStreamClient
• type Gripmock_ClientStreamServer
• type Gripmock_ServerStreamClient
• type Gripmock_ServerStreamServer
• type Reply
  • func (*Reply) Descriptor() ([]byte, []int)
  • func (x *Reply) GetMessage() string
  • func (*Reply) ProtoMessage()
  • func (x *Reply) ProtoReflect() protoreflect.Message
  • func (x *Reply) Reset()
  • func (x *Reply) String() string
• type Request
  • func (*Request) Descriptor() ([]byte, []int)
  • func (x *Request) GetName() string
  • func (*Request) ProtoMessage()
  • func (x *Request) ProtoReflect() protoreflect.Message
  • func (x *Request) Reset()
  • func (x *Request) String() string
• type UnimplementedGripmockServer
  • func (UnimplementedGripmockServer) Bidirectional(Gripmock_BidirectionalServer) error
  • func (UnimplementedGripmockServer) ClientStream(Gripmock_ClientStreamServer) error
  • func (UnimplementedGripmockServer) ServerStream(*Request, Gripmock_ServerStreamServer) error
• type UnsafeGripmockServer

Constants

const (
	Gripmock_ServerStream_FullMethodName  = "/stream.Gripmock/serverStream"
	Gripmock_ClientStream_FullMethodName  = "/stream.Gripmock/clientStream"
	Gripmock_Bidirectional_FullMethodName = "/stream.Gripmock/bidirectional"
)

Variables

var File_stream_proto protoreflect.FileDescriptor

var Gripmock_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "stream.Gripmock",
	HandlerType: (*GripmockServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "serverStream",
			Handler:       _Gripmock_ServerStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "clientStream",
			Handler:       _Gripmock_ClientStream_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "bidirectional",
			Handler:       _Gripmock_Bidirectional_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "stream.proto",
}

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

Functions

func RegisterGripmockServer

func RegisterGripmockServer(s grpc.ServiceRegistrar, srv GripmockServer)

Types

type GripmockClient

type GripmockClient interface {
	// server to client sreaming
	ServerStream(ctx context.Context, in *Request, opts ...grpc.CallOption) (Gripmock_ServerStreamClient, error)
	// client to server streaming
	ClientStream(ctx context.Context, opts ...grpc.CallOption) (Gripmock_ClientStreamClient, error)
	// bidirectional streaming
	Bidirectional(ctx context.Context, opts ...grpc.CallOption) (Gripmock_BidirectionalClient, error)
}

GripmockClient is the client API for Gripmock 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 NewGripmockClient

func NewGripmockClient(cc grpc.ClientConnInterface) GripmockClient

type GripmockServer

type GripmockServer interface {
	// server to client sreaming
	ServerStream(*Request, Gripmock_ServerStreamServer) error
	// client to server streaming
	ClientStream(Gripmock_ClientStreamServer) error
	// bidirectional streaming
	Bidirectional(Gripmock_BidirectionalServer) error
	// contains filtered or unexported methods
}

GripmockServer is the server API for Gripmock service. All implementations must embed UnimplementedGripmockServer for forward compatibility

type Gripmock_BidirectionalClient

type Gripmock_BidirectionalClient interface {
	Send(*Request) error
	Recv() (*Reply, error)
	grpc.ClientStream
}

type Gripmock_BidirectionalServer

type Gripmock_BidirectionalServer interface {
	Send(*Reply) error
	Recv() (*Request, error)
	grpc.ServerStream
}

type Gripmock_ClientStreamClient

type Gripmock_ClientStreamClient interface {
	Send(*Request) error
	CloseAndRecv() (*Reply, error)
	grpc.ClientStream
}

type Gripmock_ClientStreamServer

type Gripmock_ClientStreamServer interface {
	SendAndClose(*Reply) error
	Recv() (*Request, error)
	grpc.ServerStream
}

type Gripmock_ServerStreamClient

type Gripmock_ServerStreamClient interface {
	Recv() (*Reply, error)
	grpc.ClientStream
}

type Gripmock_ServerStreamServer

type Gripmock_ServerStreamServer interface {
	Send(*Reply) error
	grpc.ServerStream
}

type Reply

type Reply struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the greetings

func (*Reply) Descriptor

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

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetMessage

func (x *Reply) GetMessage() string

func (*Reply) ProtoMessage

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect

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

func (*Reply) Reset

func (x *Reply) Reset()

func (*Reply) String

func (x *Reply) String() string

type Request

type Request struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the user's name.

func (*Request) Descriptor

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetName

func (x *Request) GetName() string

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

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

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type UnimplementedGripmockServer

type UnimplementedGripmockServer struct {
}

UnimplementedGripmockServer must be embedded to have forward compatible implementations.

func (UnimplementedGripmockServer) Bidirectional

func (UnimplementedGripmockServer) Bidirectional(Gripmock_BidirectionalServer) error

func (UnimplementedGripmockServer) ClientStream

func (UnimplementedGripmockServer) ClientStream(Gripmock_ClientStreamServer) error

func (UnimplementedGripmockServer) ServerStream

func (UnimplementedGripmockServer) ServerStream(*Request, Gripmock_ServerStreamServer) error

type UnsafeGripmockServer

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

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