chat

package
v5.0.0-...-1b49765 Latest Latest
Warning

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

 Go to latest Published: Feb 19, 2025 License: AGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RoomType_name = map[int32]string{
		0: "GLOBAL",
		1: "WORKSPACE",
		2: "USER",
		3: "NODE",
		4: "ANY",
	}
	RoomType_value = map[string]int32{
		"GLOBAL":    0,
		"WORKSPACE": 1,
		"USER":      2,
		"NODE":      3,
		"ANY":       4,
	}
)

Enum value maps for RoomType.

View Source 
var (
	WsMessageType_name = map[int32]string{
		0: "JOIN",
		1: "LEAVE",
		2: "POST",
		3: "ROOM_UPDATE",
		4: "HISTORY",
		5: "DELETE_MSG",
		6: "DELETE_ROOM",
	}
	WsMessageType_value = map[string]int32{
		"JOIN":        0,
		"LEAVE":       1,
		"POST":        2,
		"ROOM_UPDATE": 3,
		"HISTORY":     4,
		"DELETE_MSG":  5,
		"DELETE_ROOM": 6,
	}
)

Enum value maps for WsMessageType.

View Source 
var ChatService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chat.ChatService",
	HandlerType: (*ChatServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PutRoom",
			Handler:    _ChatService_PutRoom_Handler,
		},
		{
			MethodName: "DeleteRoom",
			Handler:    _ChatService_DeleteRoom_Handler,
		},
		{
			MethodName: "PostMessage",
			Handler:    _ChatService_PostMessage_Handler,
		},
		{
			MethodName: "DeleteMessage",
			Handler:    _ChatService_DeleteMessage_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListRooms",
			Handler:       _ChatService_ListRooms_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListMessages",
			Handler:       _ChatService_ListMessages_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cells-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)

View Source 
var File_cells_chat_proto protoreflect.FileDescriptor

Functions

func NewIChatEvent 

func NewIChatEvent(x any) error

func NewIChatMessage 

func NewIChatMessage(x any) error

func NewIChatRoom 

func NewIChatRoom(x any) error

func NewIWebSocketMessage 

func NewIWebSocketMessage(x any) error

func RegisterChatServiceServer 

func RegisterChatServiceServer(s grpc.ServiceRegistrar, srv ChatServiceServer)

Types

type ChatEvent 

type ChatEvent struct {
	Message *ChatMessage `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	Room    *ChatRoom    `protobuf:"bytes,2,opt,name=Room,proto3" json:"Room,omitempty"`
	Details string       `protobuf:"bytes,3,opt,name=Details,proto3" json:"Details,omitempty"`
	// contains filtered or unexported fields
}

func (*ChatEvent) Descriptor deprecated 

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

Deprecated: Use ChatEvent.ProtoReflect.Descriptor instead.

func (*ChatEvent) GetDetails 

func (x *ChatEvent) GetDetails() string

func (*ChatEvent) GetMessage 

func (x *ChatEvent) GetMessage() *ChatMessage

func (*ChatEvent) GetRoom 

func (x *ChatEvent) GetRoom() *ChatRoom

func (*ChatEvent) ProtoMessage 

func (*ChatEvent) ProtoMessage()

func (*ChatEvent) ProtoReflect 

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

func (*ChatEvent) Reset 

func (x *ChatEvent) Reset()

func (*ChatEvent) SetDetails 

func (x *ChatEvent) SetDetails(v string)

func (*ChatEvent) SetMessage 

func (x *ChatEvent) SetMessage(v *ChatMessage)

func (*ChatEvent) SetRoom 

func (x *ChatEvent) SetRoom(v *ChatRoom)

func (*ChatEvent) String 

func (x *ChatEvent) String() string

type ChatEventGetter 

type ChatEventGetter interface {
	GetMessage() *ChatMessage
	GetRoom() *ChatRoom
	GetDetails() string
}

type ChatEventSetter 

type ChatEventSetter interface {
	SetMessage(*ChatMessage)
	SetRoom(*ChatRoom)
	SetDetails(string)
}

type ChatMessage 

type ChatMessage struct {
	Uuid      string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"`
	RoomUuid  string `protobuf:"bytes,2,opt,name=RoomUuid,proto3" json:"RoomUuid,omitempty"`
	Message   string `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	Author    string `protobuf:"bytes,4,opt,name=Author,proto3" json:"Author,omitempty"`
	Timestamp int64  `protobuf:"varint,5,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	// Additional information or metadata
	Activity *activity.Object  `protobuf:"bytes,6,opt,name=Activity,proto3" json:"Activity,omitempty"`
	Info     map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ChatMessage) Descriptor deprecated 

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

Deprecated: Use ChatMessage.ProtoReflect.Descriptor instead.

func (*ChatMessage) GetActivity 

func (x *ChatMessage) GetActivity() *activity.Object

func (*ChatMessage) GetAuthor 

func (x *ChatMessage) GetAuthor() string

func (*ChatMessage) GetInfo 

func (x *ChatMessage) GetInfo() map[string]string

func (*ChatMessage) GetMessage 

func (x *ChatMessage) GetMessage() string

func (*ChatMessage) GetRoomUuid 

func (x *ChatMessage) GetRoomUuid() string

func (*ChatMessage) GetTimestamp 

func (x *ChatMessage) GetTimestamp() int64

func (*ChatMessage) GetUuid 

func (x *ChatMessage) GetUuid() string

func (*ChatMessage) ProtoMessage 

func (*ChatMessage) ProtoMessage()

func (*ChatMessage) ProtoReflect 

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

func (*ChatMessage) Reset 

func (x *ChatMessage) Reset()

func (*ChatMessage) SetActivity 

func (x *ChatMessage) SetActivity(v *activity.Object)

func (*ChatMessage) SetAuthor 

func (x *ChatMessage) SetAuthor(v string)

func (*ChatMessage) SetInfo 

func (x *ChatMessage) SetInfo(v map[string]string)

func (*ChatMessage) SetMessage 

func (x *ChatMessage) SetMessage(v string)

func (*ChatMessage) SetRoomUuid 

func (x *ChatMessage) SetRoomUuid(v string)

func (*ChatMessage) SetTimestamp 

func (x *ChatMessage) SetTimestamp(v int64)

func (*ChatMessage) SetUuid 

func (x *ChatMessage) SetUuid(v string)

func (*ChatMessage) String 

func (x *ChatMessage) String() string

type ChatMessageGetter 

type ChatMessageGetter interface {
	GetUuid() string
	GetRoomUuid() string
	GetMessage() string
	GetAuthor() string
	GetTimestamp() int64
	GetActivity() *activity.Object
	GetInfo() map[string]string
}

type ChatMessageSetter 

type ChatMessageSetter interface {
	SetUuid(string)
	SetRoomUuid(string)
	SetMessage(string)
	SetAuthor(string)
	SetTimestamp(int64)
	SetActivity(*activity.Object)
	SetInfo(map[string]string)
}

type ChatRoom 

type ChatRoom struct {
	Uuid           string   `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"`
	Type           RoomType `protobuf:"varint,2,opt,name=Type,proto3,enum=chat.RoomType" json:"Type,omitempty"`
	RoomTypeObject string   `protobuf:"bytes,3,opt,name=RoomTypeObject,proto3" json:"RoomTypeObject,omitempty"`
	RoomLabel      string   `protobuf:"bytes,4,opt,name=RoomLabel,proto3" json:"RoomLabel,omitempty"`
	Users          []string `protobuf:"bytes,5,rep,name=Users,proto3" json:"Users,omitempty"`
	LastUpdated    int32    `protobuf:"varint,6,opt,name=LastUpdated,proto3" json:"LastUpdated,omitempty"`
	// contains filtered or unexported fields
}

func (*ChatRoom) Descriptor deprecated 

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

Deprecated: Use ChatRoom.ProtoReflect.Descriptor instead.

func (*ChatRoom) GetLastUpdated 

func (x *ChatRoom) GetLastUpdated() int32

func (*ChatRoom) GetRoomLabel 

func (x *ChatRoom) GetRoomLabel() string

func (*ChatRoom) GetRoomTypeObject 

func (x *ChatRoom) GetRoomTypeObject() string

func (*ChatRoom) GetType 

func (x *ChatRoom) GetType() RoomType

func (*ChatRoom) GetUsers 

func (x *ChatRoom) GetUsers() []string

func (*ChatRoom) GetUuid 

func (x *ChatRoom) GetUuid() string

func (*ChatRoom) MarshalLogObject 

func (c *ChatRoom) MarshalLogObject(encoder zapcore.ObjectEncoder) error

MarshalLogObject implements custom marshalling for logs

func (*ChatRoom) ProtoMessage 

func (*ChatRoom) ProtoMessage()

func (*ChatRoom) ProtoReflect 

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

func (*ChatRoom) Reset 

func (x *ChatRoom) Reset()

func (*ChatRoom) SetLastUpdated 

func (x *ChatRoom) SetLastUpdated(v int32)

func (*ChatRoom) SetRoomLabel 

func (x *ChatRoom) SetRoomLabel(v string)

func (*ChatRoom) SetRoomTypeObject 

func (x *ChatRoom) SetRoomTypeObject(v string)

func (*ChatRoom) SetType 

func (x *ChatRoom) SetType(v RoomType)

func (*ChatRoom) SetUsers 

func (x *ChatRoom) SetUsers(v []string)

func (*ChatRoom) SetUuid 

func (x *ChatRoom) SetUuid(v string)

func (*ChatRoom) String 

func (x *ChatRoom) String() string

func (*ChatRoom) Zap 

func (c *ChatRoom) Zap() zapcore.Field

Zap simply returns a zapcore.Field object populated with this ChatRoom under a standard key

type ChatRoomGetter 

type ChatRoomGetter interface {
	GetUuid() string
	GetType() RoomType
	GetRoomTypeObject() string
	GetRoomLabel() string
	GetUsers() []string
	GetLastUpdated() int32
}

type ChatRoomSetter 

type ChatRoomSetter interface {
	SetUuid(string)
	SetType(RoomType)
	SetRoomTypeObject(string)
	SetRoomLabel(string)
	SetUsers([]string)
	SetLastUpdated(int32)
}

type ChatServiceClient 

type ChatServiceClient interface {
	PutRoom(ctx context.Context, in *PutRoomRequest, opts ...grpc.CallOption) (*PutRoomResponse, error)
	DeleteRoom(ctx context.Context, in *DeleteRoomRequest, opts ...grpc.CallOption) (*DeleteRoomResponse, error)
	ListRooms(ctx context.Context, in *ListRoomsRequest, opts ...grpc.CallOption) (ChatService_ListRoomsClient, error)
	ListMessages(ctx context.Context, in *ListMessagesRequest, opts ...grpc.CallOption) (ChatService_ListMessagesClient, error)
	PostMessage(ctx context.Context, in *PostMessageRequest, opts ...grpc.CallOption) (*PostMessageResponse, error)
	DeleteMessage(ctx context.Context, in *DeleteMessageRequest, opts ...grpc.CallOption) (*DeleteMessageResponse, 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 {
	PutRoom(context.Context, *PutRoomRequest) (*PutRoomResponse, error)
	DeleteRoom(context.Context, *DeleteRoomRequest) (*DeleteRoomResponse, error)
	ListRooms(*ListRoomsRequest, ChatService_ListRoomsServer) error
	ListMessages(*ListMessagesRequest, ChatService_ListMessagesServer) error
	PostMessage(context.Context, *PostMessageRequest) (*PostMessageResponse, error)
	DeleteMessage(context.Context, *DeleteMessageRequest) (*DeleteMessageResponse, error)
	// contains filtered or unexported methods
}

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

type ChatService_ListMessagesClient 

type ChatService_ListMessagesClient interface {
	Recv() (*ListMessagesResponse, error)
	grpc.ClientStream
}

type ChatService_ListMessagesServer 

type ChatService_ListMessagesServer interface {
	Send(*ListMessagesResponse) error
	grpc.ServerStream
}

type ChatService_ListRoomsClient 

type ChatService_ListRoomsClient interface {
	Recv() (*ListRoomsResponse, error)
	grpc.ClientStream
}

type ChatService_ListRoomsServer 

type ChatService_ListRoomsServer interface {
	Send(*ListRoomsResponse) error
	grpc.ServerStream
}

type DeleteMessageRequest 

type DeleteMessageRequest struct {
	Messages   []*ChatMessage       `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages,omitempty"`
	KnownRooms map[string]*ChatRoom `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DeleteMessageRequest) Descriptor deprecated 

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

Deprecated: Use DeleteMessageRequest.ProtoReflect.Descriptor instead.

func (*DeleteMessageRequest) GetKnownRooms 

func (x *DeleteMessageRequest) GetKnownRooms() map[string]*ChatRoom

func (*DeleteMessageRequest) GetMessages 

func (x *DeleteMessageRequest) GetMessages() []*ChatMessage

func (*DeleteMessageRequest) ProtoMessage 

func (*DeleteMessageRequest) ProtoMessage()

func (*DeleteMessageRequest) ProtoReflect 

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

func (*DeleteMessageRequest) Reset 

func (x *DeleteMessageRequest) Reset()

func (*DeleteMessageRequest) String 

func (x *DeleteMessageRequest) String() string

type DeleteMessageResponse 

type DeleteMessageResponse struct {
	Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteMessageResponse) Descriptor deprecated 

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

Deprecated: Use DeleteMessageResponse.ProtoReflect.Descriptor instead.

func (*DeleteMessageResponse) GetSuccess 

func (x *DeleteMessageResponse) GetSuccess() bool

func (*DeleteMessageResponse) ProtoMessage 

func (*DeleteMessageResponse) ProtoMessage()

func (*DeleteMessageResponse) ProtoReflect 

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

func (*DeleteMessageResponse) Reset 

func (x *DeleteMessageResponse) Reset()

func (*DeleteMessageResponse) String 

func (x *DeleteMessageResponse) String() string

type DeleteRoomRequest 

type DeleteRoomRequest struct {
	Room *ChatRoom `protobuf:"bytes,1,opt,name=Room,proto3" json:"Room,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRoomRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRoomRequest.ProtoReflect.Descriptor instead.

func (*DeleteRoomRequest) GetRoom 

func (x *DeleteRoomRequest) GetRoom() *ChatRoom

func (*DeleteRoomRequest) ProtoMessage 

func (*DeleteRoomRequest) ProtoMessage()

func (*DeleteRoomRequest) ProtoReflect 

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

func (*DeleteRoomRequest) Reset 

func (x *DeleteRoomRequest) Reset()

func (*DeleteRoomRequest) String 

func (x *DeleteRoomRequest) String() string

type DeleteRoomResponse 

type DeleteRoomResponse struct {
	Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRoomResponse) Descriptor deprecated 

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

Deprecated: Use DeleteRoomResponse.ProtoReflect.Descriptor instead.

func (*DeleteRoomResponse) GetSuccess 

func (x *DeleteRoomResponse) GetSuccess() bool

func (*DeleteRoomResponse) ProtoMessage 

func (*DeleteRoomResponse) ProtoMessage()

func (*DeleteRoomResponse) ProtoReflect 

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

func (*DeleteRoomResponse) Reset 

func (x *DeleteRoomResponse) Reset()

func (*DeleteRoomResponse) String 

func (x *DeleteRoomResponse) String() string

type IChatEvent 

type IChatEvent interface {
	proto.Message
	ChatEventGetter
	ChatEventSetter
}

type IChatMessage 

type IChatMessage interface {
	proto.Message
	ChatMessageGetter
	ChatMessageSetter
}

type IChatRoom 

type IChatRoom interface {
	proto.Message
	ChatRoomGetter
	ChatRoomSetter
}

type IWebSocketMessage 

type IWebSocketMessage interface {
	proto.Message
	WebSocketMessageGetter
	WebSocketMessageSetter
}

type ListMessagesRequest 

type ListMessagesRequest struct {
	RoomUuid string `protobuf:"bytes,1,opt,name=RoomUuid,proto3" json:"RoomUuid,omitempty"`
	// List starting at a given message ID
	LastMessage string `protobuf:"bytes,2,opt,name=LastMessage,proto3" json:"LastMessage,omitempty"`
	Offset      int64  `protobuf:"varint,3,opt,name=Offset,proto3" json:"Offset,omitempty"`
	Limit       int64  `protobuf:"varint,4,opt,name=Limit,proto3" json:"Limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMessagesRequest) Descriptor deprecated 

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

Deprecated: Use ListMessagesRequest.ProtoReflect.Descriptor instead.

func (*ListMessagesRequest) GetLastMessage 

func (x *ListMessagesRequest) GetLastMessage() string

func (*ListMessagesRequest) GetLimit 

func (x *ListMessagesRequest) GetLimit() int64

func (*ListMessagesRequest) GetOffset 

func (x *ListMessagesRequest) GetOffset() int64

func (*ListMessagesRequest) GetRoomUuid 

func (x *ListMessagesRequest) GetRoomUuid() string

func (*ListMessagesRequest) ProtoMessage 

func (*ListMessagesRequest) ProtoMessage()

func (*ListMessagesRequest) ProtoReflect 

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

func (*ListMessagesRequest) Reset 

func (x *ListMessagesRequest) Reset()

func (*ListMessagesRequest) String 

func (x *ListMessagesRequest) String() string

type ListMessagesResponse 

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

func (*ListMessagesResponse) Descriptor deprecated 

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

Deprecated: Use ListMessagesResponse.ProtoReflect.Descriptor instead.

func (*ListMessagesResponse) GetMessage 

func (x *ListMessagesResponse) GetMessage() *ChatMessage

func (*ListMessagesResponse) ProtoMessage 

func (*ListMessagesResponse) ProtoMessage()

func (*ListMessagesResponse) ProtoReflect 

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

func (*ListMessagesResponse) Reset 

func (x *ListMessagesResponse) Reset()

func (*ListMessagesResponse) String 

func (x *ListMessagesResponse) String() string

type ListRoomsRequest 

type ListRoomsRequest struct {
	ByType     RoomType `protobuf:"varint,1,opt,name=ByType,proto3,enum=chat.RoomType" json:"ByType,omitempty"`
	TypeObject string   `protobuf:"bytes,2,opt,name=TypeObject,proto3" json:"TypeObject,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRoomsRequest) Descriptor deprecated 

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

Deprecated: Use ListRoomsRequest.ProtoReflect.Descriptor instead.

func (*ListRoomsRequest) GetByType 

func (x *ListRoomsRequest) GetByType() RoomType

func (*ListRoomsRequest) GetTypeObject 

func (x *ListRoomsRequest) GetTypeObject() string

func (*ListRoomsRequest) ProtoMessage 

func (*ListRoomsRequest) ProtoMessage()

func (*ListRoomsRequest) ProtoReflect 

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

func (*ListRoomsRequest) Reset 

func (x *ListRoomsRequest) Reset()

func (*ListRoomsRequest) String 

func (x *ListRoomsRequest) String() string

type ListRoomsResponse 

type ListRoomsResponse struct {
	Room *ChatRoom `protobuf:"bytes,1,opt,name=Room,proto3" json:"Room,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRoomsResponse) Descriptor deprecated 

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

Deprecated: Use ListRoomsResponse.ProtoReflect.Descriptor instead.

func (*ListRoomsResponse) GetRoom 

func (x *ListRoomsResponse) GetRoom() *ChatRoom

func (*ListRoomsResponse) ProtoMessage 

func (*ListRoomsResponse) ProtoMessage()

func (*ListRoomsResponse) ProtoReflect 

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

func (*ListRoomsResponse) Reset 

func (x *ListRoomsResponse) Reset()

func (*ListRoomsResponse) String 

func (x *ListRoomsResponse) String() string

type PostMessageRequest 

type PostMessageRequest struct {
	Messages   []*ChatMessage       `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages,omitempty"`
	KnownRooms map[string]*ChatRoom `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PostMessageRequest) Descriptor deprecated 

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

Deprecated: Use PostMessageRequest.ProtoReflect.Descriptor instead.

func (*PostMessageRequest) GetKnownRooms 

func (x *PostMessageRequest) GetKnownRooms() map[string]*ChatRoom

func (*PostMessageRequest) GetMessages 

func (x *PostMessageRequest) GetMessages() []*ChatMessage

func (*PostMessageRequest) ProtoMessage 

func (*PostMessageRequest) ProtoMessage()

func (*PostMessageRequest) ProtoReflect 

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

func (*PostMessageRequest) Reset 

func (x *PostMessageRequest) Reset()

func (*PostMessageRequest) String 

func (x *PostMessageRequest) String() string

type PostMessageResponse 

type PostMessageResponse struct {
	Success  bool           `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Messages []*ChatMessage `protobuf:"bytes,2,rep,name=Messages,proto3" json:"Messages,omitempty"`
	// contains filtered or unexported fields
}

func (*PostMessageResponse) Descriptor deprecated 

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

Deprecated: Use PostMessageResponse.ProtoReflect.Descriptor instead.

func (*PostMessageResponse) GetMessages 

func (x *PostMessageResponse) GetMessages() []*ChatMessage

func (*PostMessageResponse) GetSuccess 

func (x *PostMessageResponse) GetSuccess() bool

func (*PostMessageResponse) ProtoMessage 

func (*PostMessageResponse) ProtoMessage()

func (*PostMessageResponse) ProtoReflect 

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

func (*PostMessageResponse) Reset 

func (x *PostMessageResponse) Reset()

func (*PostMessageResponse) String 

func (x *PostMessageResponse) String() string

type PutRoomRequest 

type PutRoomRequest struct {
	Room *ChatRoom `protobuf:"bytes,1,opt,name=Room,proto3" json:"Room,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRoomRequest) Descriptor deprecated 

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

Deprecated: Use PutRoomRequest.ProtoReflect.Descriptor instead.

func (*PutRoomRequest) GetRoom 

func (x *PutRoomRequest) GetRoom() *ChatRoom

func (*PutRoomRequest) ProtoMessage 

func (*PutRoomRequest) ProtoMessage()

func (*PutRoomRequest) ProtoReflect 

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

func (*PutRoomRequest) Reset 

func (x *PutRoomRequest) Reset()

func (*PutRoomRequest) String 

func (x *PutRoomRequest) String() string

type PutRoomResponse 

type PutRoomResponse struct {
	Room *ChatRoom `protobuf:"bytes,1,opt,name=Room,proto3" json:"Room,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRoomResponse) Descriptor deprecated 

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

Deprecated: Use PutRoomResponse.ProtoReflect.Descriptor instead.

func (*PutRoomResponse) GetRoom 

func (x *PutRoomResponse) GetRoom() *ChatRoom

func (*PutRoomResponse) ProtoMessage 

func (*PutRoomResponse) ProtoMessage()

func (*PutRoomResponse) ProtoReflect 

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

func (*PutRoomResponse) Reset 

func (x *PutRoomResponse) Reset()

func (*PutRoomResponse) String 

func (x *PutRoomResponse) String() string

type RoomType 

type RoomType int32
const (
	RoomType_GLOBAL    RoomType = 0
	RoomType_WORKSPACE RoomType = 1
	RoomType_USER      RoomType = 2
	RoomType_NODE      RoomType = 3
	RoomType_ANY       RoomType = 4
)

func (RoomType) Descriptor 

func (RoomType) Descriptor() protoreflect.EnumDescriptor

func (RoomType) Enum 

func (x RoomType) Enum() *RoomType

func (RoomType) EnumDescriptor deprecated 

func (RoomType) EnumDescriptor() ([]byte, []int)

Deprecated: Use RoomType.Descriptor instead.

func (RoomType) Number 

func (x RoomType) Number() protoreflect.EnumNumber

func (RoomType) String 

func (x RoomType) String() string

func (RoomType) Type 

func (RoomType) Type() protoreflect.EnumType

type UnimplementedChatServiceServer 

type UnimplementedChatServiceServer struct {
}

UnimplementedChatServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedChatServiceServer) DeleteMessage 

func (UnimplementedChatServiceServer) DeleteMessage(context.Context, *DeleteMessageRequest) (*DeleteMessageResponse, error)

func (UnimplementedChatServiceServer) DeleteRoom 

func (UnimplementedChatServiceServer) DeleteRoom(context.Context, *DeleteRoomRequest) (*DeleteRoomResponse, error)

func (UnimplementedChatServiceServer) ListMessages 

func (UnimplementedChatServiceServer) ListMessages(*ListMessagesRequest, ChatService_ListMessagesServer) error

func (UnimplementedChatServiceServer) ListRooms 

func (UnimplementedChatServiceServer) ListRooms(*ListRoomsRequest, ChatService_ListRoomsServer) error

func (UnimplementedChatServiceServer) PostMessage 

func (UnimplementedChatServiceServer) PostMessage(context.Context, *PostMessageRequest) (*PostMessageResponse, error)

func (UnimplementedChatServiceServer) PutRoom 

func (UnimplementedChatServiceServer) PutRoom(context.Context, *PutRoomRequest) (*PutRoomResponse, 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.

type WebSocketMessage 

type WebSocketMessage struct {
	Type    WsMessageType `protobuf:"varint,1,opt,name=Type,json=@type,proto3,enum=chat.WsMessageType" json:"Type,omitempty"`
	Room    *ChatRoom     `protobuf:"bytes,2,opt,name=Room,proto3" json:"Room,omitempty"`
	Message *ChatMessage  `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

func (*WebSocketMessage) Descriptor deprecated 

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

Deprecated: Use WebSocketMessage.ProtoReflect.Descriptor instead.

func (*WebSocketMessage) GetMessage 

func (x *WebSocketMessage) GetMessage() *ChatMessage

func (*WebSocketMessage) GetRoom 

func (x *WebSocketMessage) GetRoom() *ChatRoom

func (*WebSocketMessage) GetType 

func (x *WebSocketMessage) GetType() WsMessageType

func (*WebSocketMessage) ProtoMessage 

func (*WebSocketMessage) ProtoMessage()

func (*WebSocketMessage) ProtoReflect 

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

func (*WebSocketMessage) Reset 

func (x *WebSocketMessage) Reset()

func (*WebSocketMessage) SetMessage 

func (x *WebSocketMessage) SetMessage(v *ChatMessage)

func (*WebSocketMessage) SetRoom 

func (x *WebSocketMessage) SetRoom(v *ChatRoom)

func (*WebSocketMessage) SetType 

func (x *WebSocketMessage) SetType(v WsMessageType)

func (*WebSocketMessage) String 

func (x *WebSocketMessage) String() string

type WebSocketMessageGetter 

type WebSocketMessageGetter interface {
	GetType() WsMessageType
	GetRoom() *ChatRoom
	GetMessage() *ChatMessage
}

type WebSocketMessageSetter 

type WebSocketMessageSetter interface {
	SetType(WsMessageType)
	SetRoom(*ChatRoom)
	SetMessage(*ChatMessage)
}

type WsMessageType 

type WsMessageType int32
const (
	WsMessageType_JOIN        WsMessageType = 0
	WsMessageType_LEAVE       WsMessageType = 1
	WsMessageType_POST        WsMessageType = 2
	WsMessageType_ROOM_UPDATE WsMessageType = 3
	WsMessageType_HISTORY     WsMessageType = 4
	WsMessageType_DELETE_MSG  WsMessageType = 5
	WsMessageType_DELETE_ROOM WsMessageType = 6
)

func (WsMessageType) Descriptor 

func (WsMessageType) Descriptor() protoreflect.EnumDescriptor

func (WsMessageType) Enum 

func (x WsMessageType) Enum() *WsMessageType

func (WsMessageType) EnumDescriptor deprecated 

func (WsMessageType) EnumDescriptor() ([]byte, []int)

Deprecated: Use WsMessageType.Descriptor instead.

func (WsMessageType) Number 

func (x WsMessageType) Number() protoreflect.EnumNumber

func (WsMessageType) String 

func (x WsMessageType) String() string

func (WsMessageType) Type 

func (WsMessageType) Type() protoreflect.EnumType

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.