Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + var RoomType_name = map[int32]string + var RoomType_value = map[string]int32 + var WsMessageType_name = map[int32]string + var WsMessageType_value = map[string]int32 + func RegisterChatServiceHandler(s server.Server, hdlr ChatServiceHandler, opts ...server.HandlerOption) + type ChatEvent struct + Details string + Message *ChatMessage + Room *ChatRoom + func (*ChatEvent) Descriptor() ([]byte, []int) + func (*ChatEvent) ProtoMessage() + func (m *ChatEvent) GetDetails() string + func (m *ChatEvent) GetMessage() *ChatMessage + func (m *ChatEvent) GetRoom() *ChatRoom + func (m *ChatEvent) Reset() + func (m *ChatEvent) String() string + type ChatMessage struct + Activity *activity.Object + Author string + Message string + RoomUuid string + Timestamp int64 + Uuid string + func (*ChatMessage) Descriptor() ([]byte, []int) + func (*ChatMessage) ProtoMessage() + func (m *ChatMessage) GetActivity() *activity.Object + func (m *ChatMessage) GetAuthor() string + func (m *ChatMessage) GetMessage() string + func (m *ChatMessage) GetRoomUuid() string + func (m *ChatMessage) GetTimestamp() int64 + func (m *ChatMessage) GetUuid() string + func (m *ChatMessage) Reset() + func (m *ChatMessage) String() string + type ChatRoom struct + LastUpdated int32 + RoomLabel string + RoomTypeObject string + Type RoomType + Users []string + Uuid string + func (*ChatRoom) Descriptor() ([]byte, []int) + func (*ChatRoom) ProtoMessage() + func (c *ChatRoom) MarshalLogObject(encoder zapcore.ObjectEncoder) error + func (c *ChatRoom) Zap() zapcore.Field + func (m *ChatRoom) GetLastUpdated() int32 + func (m *ChatRoom) GetRoomLabel() string + func (m *ChatRoom) GetRoomTypeObject() string + func (m *ChatRoom) GetType() RoomType + func (m *ChatRoom) GetUsers() []string + func (m *ChatRoom) GetUuid() string + func (m *ChatRoom) Reset() + func (m *ChatRoom) String() string + type ChatService struct + func (h *ChatService) DeleteMessage(ctx context.Context, in *DeleteMessageRequest, out *DeleteMessageResponse) error + func (h *ChatService) DeleteRoom(ctx context.Context, in *DeleteRoomRequest, out *DeleteRoomResponse) error + func (h *ChatService) ListMessages(ctx context.Context, stream server.Streamer) error + func (h *ChatService) ListRooms(ctx context.Context, stream server.Streamer) error + func (h *ChatService) PostMessage(ctx context.Context, in *PostMessageRequest, out *PostMessageResponse) error + func (h *ChatService) PutRoom(ctx context.Context, in *PutRoomRequest, out *PutRoomResponse) error + type ChatServiceClient interface + DeleteMessage func(ctx context.Context, in *DeleteMessageRequest, opts ...client.CallOption) (*DeleteMessageResponse, error) + DeleteRoom func(ctx context.Context, in *DeleteRoomRequest, opts ...client.CallOption) (*DeleteRoomResponse, error) + ListMessages func(ctx context.Context, in *ListMessagesRequest, opts ...client.CallOption) (ChatService_ListMessagesClient, error) + ListRooms func(ctx context.Context, in *ListRoomsRequest, opts ...client.CallOption) (ChatService_ListRoomsClient, error) + PostMessage func(ctx context.Context, in *PostMessageRequest, opts ...client.CallOption) (*PostMessageResponse, error) + PutRoom func(ctx context.Context, in *PutRoomRequest, opts ...client.CallOption) (*PutRoomResponse, error) + func NewChatServiceClient(serviceName string, c client.Client) ChatServiceClient + type ChatServiceHandler interface + DeleteMessage func(context.Context, *DeleteMessageRequest, *DeleteMessageResponse) error + DeleteRoom func(context.Context, *DeleteRoomRequest, *DeleteRoomResponse) error + ListMessages func(context.Context, *ListMessagesRequest, ChatService_ListMessagesStream) error + ListRooms func(context.Context, *ListRoomsRequest, ChatService_ListRoomsStream) error + PostMessage func(context.Context, *PostMessageRequest, *PostMessageResponse) error + PutRoom func(context.Context, *PutRoomRequest, *PutRoomResponse) error + type ChatService_ListMessagesClient interface + Close func() error + Recv func() (*ListMessagesResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type ChatService_ListMessagesStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*ListMessagesResponse) error + SendMsg func(interface{}) error + type ChatService_ListRoomsClient interface + Close func() error + Recv func() (*ListRoomsResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type ChatService_ListRoomsStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*ListRoomsResponse) error + SendMsg func(interface{}) error + type DeleteMessageRequest struct + Messages []*ChatMessage + func (*DeleteMessageRequest) Descriptor() ([]byte, []int) + func (*DeleteMessageRequest) ProtoMessage() + func (m *DeleteMessageRequest) GetMessages() []*ChatMessage + func (m *DeleteMessageRequest) Reset() + func (m *DeleteMessageRequest) String() string + type DeleteMessageResponse struct + Success bool + func (*DeleteMessageResponse) Descriptor() ([]byte, []int) + func (*DeleteMessageResponse) ProtoMessage() + func (m *DeleteMessageResponse) GetSuccess() bool + func (m *DeleteMessageResponse) Reset() + func (m *DeleteMessageResponse) String() string + type DeleteRoomRequest struct + Room *ChatRoom + func (*DeleteRoomRequest) Descriptor() ([]byte, []int) + func (*DeleteRoomRequest) ProtoMessage() + func (m *DeleteRoomRequest) GetRoom() *ChatRoom + func (m *DeleteRoomRequest) Reset() + func (m *DeleteRoomRequest) String() string + type DeleteRoomResponse struct + Success bool + func (*DeleteRoomResponse) Descriptor() ([]byte, []int) + func (*DeleteRoomResponse) ProtoMessage() + func (m *DeleteRoomResponse) GetSuccess() bool + func (m *DeleteRoomResponse) Reset() + func (m *DeleteRoomResponse) String() string + type ListMessagesRequest struct + LastMessage string + Limit int64 + Offset int64 + RoomUuid string + func (*ListMessagesRequest) Descriptor() ([]byte, []int) + func (*ListMessagesRequest) ProtoMessage() + func (m *ListMessagesRequest) GetLastMessage() string + func (m *ListMessagesRequest) GetLimit() int64 + func (m *ListMessagesRequest) GetOffset() int64 + func (m *ListMessagesRequest) GetRoomUuid() string + func (m *ListMessagesRequest) Reset() + func (m *ListMessagesRequest) String() string + type ListMessagesResponse struct + Message *ChatMessage + func (*ListMessagesResponse) Descriptor() ([]byte, []int) + func (*ListMessagesResponse) ProtoMessage() + func (m *ListMessagesResponse) GetMessage() *ChatMessage + func (m *ListMessagesResponse) Reset() + func (m *ListMessagesResponse) String() string + type ListRoomsRequest struct + ByType RoomType + TypeObject string + func (*ListRoomsRequest) Descriptor() ([]byte, []int) + func (*ListRoomsRequest) ProtoMessage() + func (m *ListRoomsRequest) GetByType() RoomType + func (m *ListRoomsRequest) GetTypeObject() string + func (m *ListRoomsRequest) Reset() + func (m *ListRoomsRequest) String() string + type ListRoomsResponse struct + Room *ChatRoom + func (*ListRoomsResponse) Descriptor() ([]byte, []int) + func (*ListRoomsResponse) ProtoMessage() + func (m *ListRoomsResponse) GetRoom() *ChatRoom + func (m *ListRoomsResponse) Reset() + func (m *ListRoomsResponse) String() string + type PostMessageRequest struct + Messages []*ChatMessage + func (*PostMessageRequest) Descriptor() ([]byte, []int) + func (*PostMessageRequest) ProtoMessage() + func (m *PostMessageRequest) GetMessages() []*ChatMessage + func (m *PostMessageRequest) Reset() + func (m *PostMessageRequest) String() string + type PostMessageResponse struct + Messages []*ChatMessage + Success bool + func (*PostMessageResponse) Descriptor() ([]byte, []int) + func (*PostMessageResponse) ProtoMessage() + func (m *PostMessageResponse) GetMessages() []*ChatMessage + func (m *PostMessageResponse) GetSuccess() bool + func (m *PostMessageResponse) Reset() + func (m *PostMessageResponse) String() string + type PutRoomRequest struct + Room *ChatRoom + func (*PutRoomRequest) Descriptor() ([]byte, []int) + func (*PutRoomRequest) ProtoMessage() + func (m *PutRoomRequest) GetRoom() *ChatRoom + func (m *PutRoomRequest) Reset() + func (m *PutRoomRequest) String() string + type PutRoomResponse struct + Room *ChatRoom + func (*PutRoomResponse) Descriptor() ([]byte, []int) + func (*PutRoomResponse) ProtoMessage() + func (m *PutRoomResponse) GetRoom() *ChatRoom + func (m *PutRoomResponse) Reset() + func (m *PutRoomResponse) String() string + type RoomType int32 + const RoomType_GLOBAL + const RoomType_NODE + const RoomType_USER + const RoomType_WORKSPACE + func (RoomType) EnumDescriptor() ([]byte, []int) + func (x RoomType) String() string + type WebSocketMessage struct + Message *ChatMessage + Room *ChatRoom + Type WsMessageType + func (*WebSocketMessage) Descriptor() ([]byte, []int) + func (*WebSocketMessage) ProtoMessage() + func (m *WebSocketMessage) GetMessage() *ChatMessage + func (m *WebSocketMessage) GetRoom() *ChatRoom + func (m *WebSocketMessage) GetType() WsMessageType + func (m *WebSocketMessage) Reset() + func (m *WebSocketMessage) String() string + type WsMessageType int32 + const WsMessageType_DELETE_MSG + const WsMessageType_DELETE_ROOM + const WsMessageType_HISTORY + const WsMessageType_JOIN + const WsMessageType_LEAVE + const WsMessageType_POST + const WsMessageType_ROOM_UPDATE + func (WsMessageType) EnumDescriptor() ([]byte, []int) + func (x WsMessageType) String() string Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020