chatv1

Documentation

Index

• Variables
• func RegisterChatServiceServer(s grpc.ServiceRegistrar, srv ChatServiceServer)
• type ChatServiceClient
  • func NewChatServiceClient(cc grpc.ClientConnInterface) ChatServiceClient
• type ChatServiceServer
• type ChatService_StreamClient
• type ChatService_StreamServer
• type StreamRequest
  • func (*StreamRequest) Descriptor() ([]byte, []int)
  • func (x *StreamRequest) GetMessage() string
  • func (x *StreamRequest) GetTimestamp() *timestamppb.Timestamp
  • func (x *StreamRequest) GetUsername() string
  • func (*StreamRequest) ProtoMessage()
  • func (x *StreamRequest) ProtoReflect() protoreflect.Message
  • func (x *StreamRequest) Reset()
  • func (x *StreamRequest) String() string
• type StreamResponse
  • func (*StreamResponse) Descriptor() ([]byte, []int)
  • func (x *StreamResponse) GetMessage() string
  • func (x *StreamResponse) GetTimestamp() *timestamppb.Timestamp
  • func (x *StreamResponse) GetUsername() string
  • func (*StreamResponse) ProtoMessage()
  • func (x *StreamResponse) ProtoReflect() protoreflect.Message
  • func (x *StreamResponse) Reset()
  • func (x *StreamResponse) String() string
• type UnimplementedChatServiceServer
  • func (UnimplementedChatServiceServer) Stream(ChatService_StreamServer) error
• type UnsafeChatServiceServer

Variables

var ChatService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpcchat.chat.v1.ChatService",
	HandlerType: (*ChatServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _ChatService_Stream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "chat/v1/chat.proto",
}

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

var File_chat_v1_chat_proto protoreflect.FileDescriptor

Functions

func RegisterChatServiceServer

func RegisterChatServiceServer(s grpc.ServiceRegistrar, srv ChatServiceServer)

Types

type ChatServiceClient

type ChatServiceClient interface {
	Stream(ctx context.Context, opts ...grpc.CallOption) (ChatService_StreamClient, error)
}

ChatServiceClient is the client API for ChatService 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 NewChatServiceClient

func NewChatServiceClient(cc grpc.ClientConnInterface) ChatServiceClient

type ChatServiceServer

type ChatServiceServer interface {
	Stream(ChatService_StreamServer) error
	// contains filtered or unexported methods
}

ChatServiceServer is the server API for ChatService service. All implementations must embed UnimplementedChatServiceServer for forward compatibility

type ChatService_StreamClient

type ChatService_StreamClient interface {
	Send(*StreamRequest) error
	Recv() (*StreamResponse, error)
	grpc.ClientStream
}

type ChatService_StreamServer

type ChatService_StreamServer interface {
	Send(*StreamResponse) error
	Recv() (*StreamRequest, error)
	grpc.ServerStream
}

type StreamRequest

type StreamRequest struct {
	Username  string                 `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Message   string                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRequest) Descriptor

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

Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.

func (*StreamRequest) GetMessage

func (x *StreamRequest) GetMessage() string

func (*StreamRequest) GetTimestamp

func (x *StreamRequest) GetTimestamp() *timestamppb.Timestamp

func (*StreamRequest) GetUsername

func (x *StreamRequest) GetUsername() string

func (*StreamRequest) ProtoMessage

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) ProtoReflect

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

func (*StreamRequest) Reset

func (x *StreamRequest) Reset()

func (*StreamRequest) String

func (x *StreamRequest) String() string

type StreamResponse

type StreamResponse struct {
	Username  string                 `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Message   string                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamResponse) Descriptor

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

Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.

func (*StreamResponse) GetMessage

func (x *StreamResponse) GetMessage() string

func (*StreamResponse) GetTimestamp

func (x *StreamResponse) GetTimestamp() *timestamppb.Timestamp

func (*StreamResponse) GetUsername

func (x *StreamResponse) GetUsername() string

func (*StreamResponse) ProtoMessage

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) ProtoReflect

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

func (*StreamResponse) Reset

func (x *StreamResponse) Reset()

func (*StreamResponse) String

func (x *StreamResponse) String() string

type UnimplementedChatServiceServer

type UnimplementedChatServiceServer struct {
}

UnimplementedChatServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedChatServiceServer) Stream

func (UnimplementedChatServiceServer) Stream(ChatService_StreamServer) error

type UnsafeChatServiceServer

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

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