chat

package
v4.4.7 Latest Latest
Warning

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

 Go to latest Published: Nov 14, 2024 License: AGPL-3.0 Imports: 17 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 DeregisterChatServiceEnhancedServer 

func DeregisterChatServiceEnhancedServer(s grpc.ServiceRegistrar, name string)

func RegisterChatServiceEnhancedServer 

func RegisterChatServiceEnhancedServer(s grpc.ServiceRegistrar, srv NamedChatServiceServer)

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) String 

func (x *ChatEvent) String() string

func (*ChatEvent) Validate 

func (this *ChatEvent) Validate() error

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 added in v4.4.0 

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) String 

func (x *ChatMessage) String() string

func (*ChatMessage) Validate 

func (this *ChatMessage) Validate() error

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) String 

func (x *ChatRoom) String() string

func (*ChatRoom) Validate 

func (this *ChatRoom) Validate() error

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 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 ChatServiceEnhancedServer 

type ChatServiceEnhancedServer map[string]NamedChatServiceServer

func (ChatServiceEnhancedServer) DeleteMessage 

func (m ChatServiceEnhancedServer) DeleteMessage(ctx context.Context, r *DeleteMessageRequest) (*DeleteMessageResponse, error)

func (ChatServiceEnhancedServer) DeleteRoom 

func (m ChatServiceEnhancedServer) DeleteRoom(ctx context.Context, r *DeleteRoomRequest) (*DeleteRoomResponse, error)

func (ChatServiceEnhancedServer) ListMessages 

func (m ChatServiceEnhancedServer) ListMessages(r *ListMessagesRequest, s ChatService_ListMessagesServer) error

func (ChatServiceEnhancedServer) ListRooms 

func (m ChatServiceEnhancedServer) ListRooms(r *ListRoomsRequest, s ChatService_ListRoomsServer) error

func (ChatServiceEnhancedServer) PostMessage 

func (m ChatServiceEnhancedServer) PostMessage(ctx context.Context, r *PostMessageRequest) (*PostMessageResponse, error)

func (ChatServiceEnhancedServer) PutRoom 

func (m ChatServiceEnhancedServer) PutRoom(ctx context.Context, r *PutRoomRequest) (*PutRoomResponse, error)

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 added in v4.4.0 

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

func (*DeleteMessageRequest) Validate 

func (this *DeleteMessageRequest) Validate() error

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

func (*DeleteMessageResponse) Validate 

func (this *DeleteMessageResponse) Validate() error

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

func (*DeleteRoomRequest) Validate 

func (this *DeleteRoomRequest) Validate() error

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

func (*DeleteRoomResponse) Validate 

func (this *DeleteRoomResponse) Validate() error

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

func (*ListMessagesRequest) Validate 

func (this *ListMessagesRequest) Validate() error

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

func (*ListMessagesResponse) Validate 

func (this *ListMessagesResponse) Validate() error

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

func (*ListRoomsRequest) Validate 

func (this *ListRoomsRequest) Validate() error

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

func (*ListRoomsResponse) Validate 

func (this *ListRoomsResponse) Validate() error

type NamedChatServiceServer 

type NamedChatServiceServer interface {
	ChatServiceServer
	Name() 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 added in v4.4.0 

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

func (*PostMessageRequest) Validate 

func (this *PostMessageRequest) Validate() error

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

func (*PostMessageResponse) Validate 

func (this *PostMessageResponse) Validate() error

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

func (*PutRoomRequest) Validate 

func (this *PutRoomRequest) Validate() error

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

func (*PutRoomResponse) Validate 

func (this *PutRoomResponse) Validate() error

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) String 

func (x *WebSocketMessage) String() string

func (*WebSocketMessage) Validate 

func (this *WebSocketMessage) Validate() error

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.