Documentation
¶
Index ¶
- Variables
- func RegisterChatServer(s grpc.ServiceRegistrar, srv ChatServer)
- type ChatClient
- type ChatServer
- type Chat_RouteChatClient
- type Chat_RouteChatServer
- type ClientMessage
- func (*ClientMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ClientMessage) GetCommand() ClientMessage_ClientCommand
- func (x *ClientMessage) GetOperation() *anypb.Any
- func (*ClientMessage) ProtoMessage()
- func (x *ClientMessage) ProtoReflect() protoreflect.Message
- func (x *ClientMessage) Reset()
- func (x *ClientMessage) String() string
- type ClientMessage_ClientCommand
- func (ClientMessage_ClientCommand) Descriptor() protoreflect.EnumDescriptor
- func (x ClientMessage_ClientCommand) Enum() *ClientMessage_ClientCommand
- func (ClientMessage_ClientCommand) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClientMessage_ClientCommand) Number() protoreflect.EnumNumber
- func (x ClientMessage_ClientCommand) String() string
- func (ClientMessage_ClientCommand) Type() protoreflect.EnumType
- type ClientMessage_ClientHelo
- func (*ClientMessage_ClientHelo) Descriptor() ([]byte, []int)deprecated
- func (x *ClientMessage_ClientHelo) GetAuthor() string
- func (*ClientMessage_ClientHelo) ProtoMessage()
- func (x *ClientMessage_ClientHelo) ProtoReflect() protoreflect.Message
- func (x *ClientMessage_ClientHelo) Reset()
- func (x *ClientMessage_ClientHelo) String() string
- type ClientMessage_ClientQuit
- type ClientMessage_ClientWriteMessage
- func (*ClientMessage_ClientWriteMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ClientMessage_ClientWriteMessage) GetBody() string
- func (*ClientMessage_ClientWriteMessage) ProtoMessage()
- func (x *ClientMessage_ClientWriteMessage) ProtoReflect() protoreflect.Message
- func (x *ClientMessage_ClientWriteMessage) Reset()
- func (x *ClientMessage_ClientWriteMessage) String() string
- type ServerMessage
- func (*ServerMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ServerMessage) GetCommand() ServerMessage_ServerCommand
- func (x *ServerMessage) GetOperation() *anypb.Any
- func (*ServerMessage) ProtoMessage()
- func (x *ServerMessage) ProtoReflect() protoreflect.Message
- func (x *ServerMessage) Reset()
- func (x *ServerMessage) String() string
- type ServerMessage_ServerCommand
- func (ServerMessage_ServerCommand) Descriptor() protoreflect.EnumDescriptor
- func (x ServerMessage_ServerCommand) Enum() *ServerMessage_ServerCommand
- func (ServerMessage_ServerCommand) EnumDescriptor() ([]byte, []int)deprecated
- func (x ServerMessage_ServerCommand) Number() protoreflect.EnumNumber
- func (x ServerMessage_ServerCommand) String() string
- func (ServerMessage_ServerCommand) Type() protoreflect.EnumType
- type ServerMessage_ServerConfirmRoomCheckout
- func (*ServerMessage_ServerConfirmRoomCheckout) Descriptor() ([]byte, []int)deprecated
- func (*ServerMessage_ServerConfirmRoomCheckout) ProtoMessage()
- func (x *ServerMessage_ServerConfirmRoomCheckout) ProtoReflect() protoreflect.Message
- func (x *ServerMessage_ServerConfirmRoomCheckout) Reset()
- func (x *ServerMessage_ServerConfirmRoomCheckout) String() string
- type ServerMessage_ServerForwardMessage
- func (*ServerMessage_ServerForwardMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ServerMessage_ServerForwardMessage) GetAuthor() string
- func (x *ServerMessage_ServerForwardMessage) GetBody() string
- func (*ServerMessage_ServerForwardMessage) ProtoMessage()
- func (x *ServerMessage_ServerForwardMessage) ProtoReflect() protoreflect.Message
- func (x *ServerMessage_ServerForwardMessage) Reset()
- func (x *ServerMessage_ServerForwardMessage) String() string
- type ServerMessage_ServerShutdown
- func (*ServerMessage_ServerShutdown) Descriptor() ([]byte, []int)deprecated
- func (*ServerMessage_ServerShutdown) ProtoMessage()
- func (x *ServerMessage_ServerShutdown) ProtoReflect() protoreflect.Message
- func (x *ServerMessage_ServerShutdown) Reset()
- func (x *ServerMessage_ServerShutdown) String() string
- type UnimplementedChatServer
- type UnsafeChatServer
Constants ¶
This section is empty.
Variables ¶
var ( ClientMessage_ClientCommand_name = map[int32]string{ 0: "Helo", 1: "Quit", 2: "WriteMessage", } ClientMessage_ClientCommand_value = map[string]int32{ "Helo": 0, "Quit": 1, "WriteMessage": 2, } )
Enum value maps for ClientMessage_ClientCommand.
var ( ServerMessage_ServerCommand_name = map[int32]string{ 0: "Shutdown", 1: "ForwardMessage", 2: "ConfirmRoomCheckout", } ServerMessage_ServerCommand_value = map[string]int32{ "Shutdown": 0, "ForwardMessage": 1, "ConfirmRoomCheckout": 2, } )
Enum value maps for ServerMessage_ServerCommand.
var Chat_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pbuf.Chat", HandlerType: (*ChatServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "RouteChat", Handler: _Chat_RouteChat_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "pbuf/chat.proto", }
Chat_ServiceDesc is the grpc.ServiceDesc for Chat service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_pbuf_chat_proto protoreflect.FileDescriptor
Functions ¶
func RegisterChatServer ¶
func RegisterChatServer(s grpc.ServiceRegistrar, srv ChatServer)
Types ¶
type ChatClient ¶
type ChatClient interface {
RouteChat(ctx context.Context, opts ...grpc.CallOption) (Chat_RouteChatClient, error)
}
ChatClient is the client API for Chat 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 NewChatClient ¶
func NewChatClient(cc grpc.ClientConnInterface) ChatClient
type ChatServer ¶
type ChatServer interface { RouteChat(Chat_RouteChatServer) error // contains filtered or unexported methods }
ChatServer is the server API for Chat service. All implementations must embed UnimplementedChatServer for forward compatibility
type Chat_RouteChatClient ¶
type Chat_RouteChatClient interface { Send(*ClientMessage) error Recv() (*ServerMessage, error) grpc.ClientStream }
type Chat_RouteChatServer ¶
type Chat_RouteChatServer interface { Send(*ServerMessage) error Recv() (*ClientMessage, error) grpc.ServerStream }
type ClientMessage ¶
type ClientMessage struct { Operation *anypb.Any `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` Command ClientMessage_ClientCommand `protobuf:"varint,2,opt,name=command,proto3,enum=pbuf.ClientMessage_ClientCommand" json:"command,omitempty"` // contains filtered or unexported fields }
func (*ClientMessage) Descriptor
deprecated
func (*ClientMessage) Descriptor() ([]byte, []int)
Deprecated: Use ClientMessage.ProtoReflect.Descriptor instead.
func (*ClientMessage) GetCommand ¶
func (x *ClientMessage) GetCommand() ClientMessage_ClientCommand
func (*ClientMessage) GetOperation ¶
func (x *ClientMessage) GetOperation() *anypb.Any
func (*ClientMessage) ProtoMessage ¶
func (*ClientMessage) ProtoMessage()
func (*ClientMessage) ProtoReflect ¶
func (x *ClientMessage) ProtoReflect() protoreflect.Message
func (*ClientMessage) Reset ¶
func (x *ClientMessage) Reset()
func (*ClientMessage) String ¶
func (x *ClientMessage) String() string
type ClientMessage_ClientCommand ¶
type ClientMessage_ClientCommand int32
const ( ClientMessage_Helo ClientMessage_ClientCommand = 0 ClientMessage_Quit ClientMessage_ClientCommand = 1 ClientMessage_WriteMessage ClientMessage_ClientCommand = 2 )
func (ClientMessage_ClientCommand) Descriptor ¶
func (ClientMessage_ClientCommand) Descriptor() protoreflect.EnumDescriptor
func (ClientMessage_ClientCommand) Enum ¶
func (x ClientMessage_ClientCommand) Enum() *ClientMessage_ClientCommand
func (ClientMessage_ClientCommand) EnumDescriptor
deprecated
func (ClientMessage_ClientCommand) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClientMessage_ClientCommand.Descriptor instead.
func (ClientMessage_ClientCommand) Number ¶
func (x ClientMessage_ClientCommand) Number() protoreflect.EnumNumber
func (ClientMessage_ClientCommand) String ¶
func (x ClientMessage_ClientCommand) String() string
func (ClientMessage_ClientCommand) Type ¶
func (ClientMessage_ClientCommand) Type() protoreflect.EnumType
type ClientMessage_ClientHelo ¶
type ClientMessage_ClientHelo struct { Author string `protobuf:"bytes,1,opt,name=author,proto3" json:"author,omitempty"` // contains filtered or unexported fields }
func (*ClientMessage_ClientHelo) Descriptor
deprecated
func (*ClientMessage_ClientHelo) Descriptor() ([]byte, []int)
Deprecated: Use ClientMessage_ClientHelo.ProtoReflect.Descriptor instead.
func (*ClientMessage_ClientHelo) GetAuthor ¶
func (x *ClientMessage_ClientHelo) GetAuthor() string
func (*ClientMessage_ClientHelo) ProtoMessage ¶
func (*ClientMessage_ClientHelo) ProtoMessage()
func (*ClientMessage_ClientHelo) ProtoReflect ¶
func (x *ClientMessage_ClientHelo) ProtoReflect() protoreflect.Message
func (*ClientMessage_ClientHelo) Reset ¶
func (x *ClientMessage_ClientHelo) Reset()
func (*ClientMessage_ClientHelo) String ¶
func (x *ClientMessage_ClientHelo) String() string
type ClientMessage_ClientQuit ¶
type ClientMessage_ClientQuit struct {
// contains filtered or unexported fields
}
func (*ClientMessage_ClientQuit) Descriptor
deprecated
func (*ClientMessage_ClientQuit) Descriptor() ([]byte, []int)
Deprecated: Use ClientMessage_ClientQuit.ProtoReflect.Descriptor instead.
func (*ClientMessage_ClientQuit) ProtoMessage ¶
func (*ClientMessage_ClientQuit) ProtoMessage()
func (*ClientMessage_ClientQuit) ProtoReflect ¶
func (x *ClientMessage_ClientQuit) ProtoReflect() protoreflect.Message
func (*ClientMessage_ClientQuit) Reset ¶
func (x *ClientMessage_ClientQuit) Reset()
func (*ClientMessage_ClientQuit) String ¶
func (x *ClientMessage_ClientQuit) String() string
type ClientMessage_ClientWriteMessage ¶
type ClientMessage_ClientWriteMessage struct { Body string `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
func (*ClientMessage_ClientWriteMessage) Descriptor
deprecated
func (*ClientMessage_ClientWriteMessage) Descriptor() ([]byte, []int)
Deprecated: Use ClientMessage_ClientWriteMessage.ProtoReflect.Descriptor instead.
func (*ClientMessage_ClientWriteMessage) GetBody ¶
func (x *ClientMessage_ClientWriteMessage) GetBody() string
func (*ClientMessage_ClientWriteMessage) ProtoMessage ¶
func (*ClientMessage_ClientWriteMessage) ProtoMessage()
func (*ClientMessage_ClientWriteMessage) ProtoReflect ¶
func (x *ClientMessage_ClientWriteMessage) ProtoReflect() protoreflect.Message
func (*ClientMessage_ClientWriteMessage) Reset ¶
func (x *ClientMessage_ClientWriteMessage) Reset()
func (*ClientMessage_ClientWriteMessage) String ¶
func (x *ClientMessage_ClientWriteMessage) String() string
type ServerMessage ¶
type ServerMessage struct { Operation *anypb.Any `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` Command ServerMessage_ServerCommand `protobuf:"varint,2,opt,name=command,proto3,enum=pbuf.ServerMessage_ServerCommand" json:"command,omitempty"` // contains filtered or unexported fields }
func (*ServerMessage) Descriptor
deprecated
func (*ServerMessage) Descriptor() ([]byte, []int)
Deprecated: Use ServerMessage.ProtoReflect.Descriptor instead.
func (*ServerMessage) GetCommand ¶
func (x *ServerMessage) GetCommand() ServerMessage_ServerCommand
func (*ServerMessage) GetOperation ¶
func (x *ServerMessage) GetOperation() *anypb.Any
func (*ServerMessage) ProtoMessage ¶
func (*ServerMessage) ProtoMessage()
func (*ServerMessage) ProtoReflect ¶
func (x *ServerMessage) ProtoReflect() protoreflect.Message
func (*ServerMessage) Reset ¶
func (x *ServerMessage) Reset()
func (*ServerMessage) String ¶
func (x *ServerMessage) String() string
type ServerMessage_ServerCommand ¶
type ServerMessage_ServerCommand int32
const ( ServerMessage_Shutdown ServerMessage_ServerCommand = 0 ServerMessage_ForwardMessage ServerMessage_ServerCommand = 1 ServerMessage_ConfirmRoomCheckout ServerMessage_ServerCommand = 2 )
func (ServerMessage_ServerCommand) Descriptor ¶
func (ServerMessage_ServerCommand) Descriptor() protoreflect.EnumDescriptor
func (ServerMessage_ServerCommand) Enum ¶
func (x ServerMessage_ServerCommand) Enum() *ServerMessage_ServerCommand
func (ServerMessage_ServerCommand) EnumDescriptor
deprecated
func (ServerMessage_ServerCommand) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServerMessage_ServerCommand.Descriptor instead.
func (ServerMessage_ServerCommand) Number ¶
func (x ServerMessage_ServerCommand) Number() protoreflect.EnumNumber
func (ServerMessage_ServerCommand) String ¶
func (x ServerMessage_ServerCommand) String() string
func (ServerMessage_ServerCommand) Type ¶
func (ServerMessage_ServerCommand) Type() protoreflect.EnumType
type ServerMessage_ServerConfirmRoomCheckout ¶
type ServerMessage_ServerConfirmRoomCheckout struct {
// contains filtered or unexported fields
}
func (*ServerMessage_ServerConfirmRoomCheckout) Descriptor
deprecated
func (*ServerMessage_ServerConfirmRoomCheckout) Descriptor() ([]byte, []int)
Deprecated: Use ServerMessage_ServerConfirmRoomCheckout.ProtoReflect.Descriptor instead.
func (*ServerMessage_ServerConfirmRoomCheckout) ProtoMessage ¶
func (*ServerMessage_ServerConfirmRoomCheckout) ProtoMessage()
func (*ServerMessage_ServerConfirmRoomCheckout) ProtoReflect ¶
func (x *ServerMessage_ServerConfirmRoomCheckout) ProtoReflect() protoreflect.Message
func (*ServerMessage_ServerConfirmRoomCheckout) Reset ¶
func (x *ServerMessage_ServerConfirmRoomCheckout) Reset()
func (*ServerMessage_ServerConfirmRoomCheckout) String ¶
func (x *ServerMessage_ServerConfirmRoomCheckout) String() string
type ServerMessage_ServerForwardMessage ¶
type ServerMessage_ServerForwardMessage struct { Body string `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` Author string `protobuf:"bytes,2,opt,name=author,proto3" json:"author,omitempty"` // contains filtered or unexported fields }
func (*ServerMessage_ServerForwardMessage) Descriptor
deprecated
func (*ServerMessage_ServerForwardMessage) Descriptor() ([]byte, []int)
Deprecated: Use ServerMessage_ServerForwardMessage.ProtoReflect.Descriptor instead.
func (*ServerMessage_ServerForwardMessage) GetAuthor ¶
func (x *ServerMessage_ServerForwardMessage) GetAuthor() string
func (*ServerMessage_ServerForwardMessage) GetBody ¶
func (x *ServerMessage_ServerForwardMessage) GetBody() string
func (*ServerMessage_ServerForwardMessage) ProtoMessage ¶
func (*ServerMessage_ServerForwardMessage) ProtoMessage()
func (*ServerMessage_ServerForwardMessage) ProtoReflect ¶
func (x *ServerMessage_ServerForwardMessage) ProtoReflect() protoreflect.Message
func (*ServerMessage_ServerForwardMessage) Reset ¶
func (x *ServerMessage_ServerForwardMessage) Reset()
func (*ServerMessage_ServerForwardMessage) String ¶
func (x *ServerMessage_ServerForwardMessage) String() string
type ServerMessage_ServerShutdown ¶
type ServerMessage_ServerShutdown struct {
// contains filtered or unexported fields
}
func (*ServerMessage_ServerShutdown) Descriptor
deprecated
func (*ServerMessage_ServerShutdown) Descriptor() ([]byte, []int)
Deprecated: Use ServerMessage_ServerShutdown.ProtoReflect.Descriptor instead.
func (*ServerMessage_ServerShutdown) ProtoMessage ¶
func (*ServerMessage_ServerShutdown) ProtoMessage()
func (*ServerMessage_ServerShutdown) ProtoReflect ¶
func (x *ServerMessage_ServerShutdown) ProtoReflect() protoreflect.Message
func (*ServerMessage_ServerShutdown) Reset ¶
func (x *ServerMessage_ServerShutdown) Reset()
func (*ServerMessage_ServerShutdown) String ¶
func (x *ServerMessage_ServerShutdown) String() string
type UnimplementedChatServer ¶
type UnimplementedChatServer struct { }
UnimplementedChatServer must be embedded to have forward compatible implementations.
func (UnimplementedChatServer) RouteChat ¶
func (UnimplementedChatServer) RouteChat(Chat_RouteChatServer) error
type UnsafeChatServer ¶
type UnsafeChatServer interface {
// contains filtered or unexported methods
}
UnsafeChatServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ChatServer will result in compilation errors.