room303connect

package
v1.7.6 Latest Latest
Warning

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

 Go to latest Published: May 24, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Room303APIAddRoomMemberProcedure is the fully-qualified name of the Room303API's AddRoomMember
	// RPC.
	Room303APIAddRoomMemberProcedure = "/api.v1alpha1.room303.Room303API/AddRoomMember"
	// Room303APIRemoveRoomMemberProcedure is the fully-qualified name of the Room303API's
	// RemoveRoomMember RPC.
	Room303APIRemoveRoomMemberProcedure = "/api.v1alpha1.room303.Room303API/RemoveRoomMember"
	// Room303APIListRoomMembersProcedure is the fully-qualified name of the Room303API's
	// ListRoomMembers RPC.
	Room303APIListRoomMembersProcedure = "/api.v1alpha1.room303.Room303API/ListRoomMembers"
	// Room303APISetAdminForRoomMemberProcedure is the fully-qualified name of the Room303API's
	// SetAdminForRoomMember RPC.
	Room303APISetAdminForRoomMemberProcedure = "/api.v1alpha1.room303.Room303API/SetAdminForRoomMember"
	// Room303APIJoinRoomProcedure is the fully-qualified name of the Room303API's JoinRoom RPC.
	Room303APIJoinRoomProcedure = "/api.v1alpha1.room303.Room303API/JoinRoom"
	// Room303APIGetRoomMemberProcedure is the fully-qualified name of the Room303API's GetRoomMember
	// RPC.
	Room303APIGetRoomMemberProcedure = "/api.v1alpha1.room303.Room303API/GetRoomMember"
	// Room303APICreateMessageProcedure is the fully-qualified name of the Room303API's CreateMessage
	// RPC.
	Room303APICreateMessageProcedure = "/api.v1alpha1.room303.Room303API/CreateMessage"
	// Room303APIEditMessageProcedure is the fully-qualified name of the Room303API's EditMessage RPC.
	Room303APIEditMessageProcedure = "/api.v1alpha1.room303.Room303API/EditMessage"
	// Room303APIDeleteMessageProcedure is the fully-qualified name of the Room303API's DeleteMessage
	// RPC.
	Room303APIDeleteMessageProcedure = "/api.v1alpha1.room303.Room303API/DeleteMessage"
	// Room303APIGetMessagesProcedure is the fully-qualified name of the Room303API's GetMessages RPC.
	Room303APIGetMessagesProcedure = "/api.v1alpha1.room303.Room303API/GetMessages"
	// Room303APIStreamMessageUpdatesProcedure is the fully-qualified name of the Room303API's
	// StreamMessageUpdates RPC.
	Room303APIStreamMessageUpdatesProcedure = "/api.v1alpha1.room303.Room303API/StreamMessageUpdates"
	// Room303APIGetUnreadStatsProcedure is the fully-qualified name of the Room303API's GetUnreadStats
	// RPC.
	Room303APIGetUnreadStatsProcedure = "/api.v1alpha1.room303.Room303API/GetUnreadStats"
	// Room303APIMarkMessageReadProcedure is the fully-qualified name of the Room303API's
	// MarkMessageRead RPC.
	Room303APIMarkMessageReadProcedure = "/api.v1alpha1.room303.Room303API/MarkMessageRead"
	// Room303APIMarkAllMessagesReadProcedure is the fully-qualified name of the Room303API's
	// MarkAllMessagesRead RPC.
	Room303APIMarkAllMessagesReadProcedure = "/api.v1alpha1.room303.Room303API/MarkAllMessagesRead"
	// Room303APIBulkMarkMessageReadProcedure is the fully-qualified name of the Room303API's
	// BulkMarkMessageRead RPC.
	Room303APIBulkMarkMessageReadProcedure = "/api.v1alpha1.room303.Room303API/BulkMarkMessageRead"
	// Room303APICreateRoomProcedure is the fully-qualified name of the Room303API's CreateRoom RPC.
	Room303APICreateRoomProcedure = "/api.v1alpha1.room303.Room303API/CreateRoom"
	// Room303APIGetRoomProcedure is the fully-qualified name of the Room303API's GetRoom RPC.
	Room303APIGetRoomProcedure = "/api.v1alpha1.room303.Room303API/GetRoom"
	// Room303APIListAllRoomsProcedure is the fully-qualified name of the Room303API's ListAllRooms RPC.
	Room303APIListAllRoomsProcedure = "/api.v1alpha1.room303.Room303API/ListAllRooms"
	// Room303APIListRoomsForMemberProcedure is the fully-qualified name of the Room303API's
	// ListRoomsForMember RPC.
	Room303APIListRoomsForMemberProcedure = "/api.v1alpha1.room303.Room303API/ListRoomsForMember"
	// Room303APIArchiveRoomProcedure is the fully-qualified name of the Room303API's ArchiveRoom RPC.
	Room303APIArchiveRoomProcedure = "/api.v1alpha1.room303.Room303API/ArchiveRoom"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// Room303APIName is the fully-qualified name of the Room303API service.
	Room303APIName = "api.v1alpha1.room303.Room303API"
)

Variables

This section is empty.

Functions

func NewRoom303APIHandler 

func NewRoom303APIHandler(svc Room303APIHandler, opts ...connect_go.HandlerOption) (string, http.Handler)

NewRoom303APIHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type Room303APIClient 

type Room303APIClient interface {
	// Member
	//
	// Add a new member to a room, you must be a room admin in order to do that
	AddRoomMember(context.Context, *connect_go.Request[room303.AddRoomMemberRequest]) (*connect_go.Response[commons.Member], error)
	// Remove room member (kick), the room member will not receive notifications from that room
	RemoveRoomMember(context.Context, *connect_go.Request[room303.RemoveRoomMemberRequest]) (*connect_go.Response[room303.RemoveRoomMemberResponse], error)
	// List the members of this room
	ListRoomMembers(context.Context, *connect_go.Request[room303.ListRoomMembersRequest]) (*connect_go.Response[room303.ListRoomMembersResponse], error)
	// Set a room member as admin, you must be a room admin in order to do this.
	SetAdminForRoomMember(context.Context, *connect_go.Request[room303.SetAdminForRoomMemberRequest]) (*connect_go.Response[room303.SetAdminForRoomMemberResponse], error)
	// adds new member to a room and does not require the member to be admin
	JoinRoom(context.Context, *connect_go.Request[room303.JoinRoomRequest]) (*connect_go.Response[commons.Room], error)
	// gets the member entity from the provided room if it exists
	GetRoomMember(context.Context, *connect_go.Request[room303.GetRoomMemberRequest]) (*connect_go.Response[commons.Member], error)
	// Message
	CreateMessage(context.Context, *connect_go.Request[room303.CreateMessageRequest]) (*connect_go.Response[room303.CreateMessageResponse], error)
	EditMessage(context.Context, *connect_go.Request[room303.EditMessageRequest]) (*connect_go.Response[room303.EditMessageResponse], error)
	DeleteMessage(context.Context, *connect_go.Request[room303.DeleteMessageRequest]) (*connect_go.Response[room303.DeleteMessageResponse], error)
	GetMessages(context.Context, *connect_go.Request[room303.GetMessagesRequest]) (*connect_go.Response[room303.GetMessagesResponse], error)
	StreamMessageUpdates(context.Context, *connect_go.Request[room303.StreamMessageUpdatesRequest]) (*connect_go.ServerStreamForClient[room303.StreamMessageUpdatesResponse], error)
	GetUnreadStats(context.Context, *connect_go.Request[room303.GetUnreadStatsRequest]) (*connect_go.Response[room303.GetUnreadStatsResponse], error)
	MarkMessageRead(context.Context, *connect_go.Request[room303.MarkMessageReadRequest]) (*connect_go.Response[room303.MarkMessageReadResponse], error)
	MarkAllMessagesRead(context.Context, *connect_go.Request[room303.MarkAllMessagesReadRequest]) (*connect_go.Response[room303.MarkAllMessagesReadResponse], error)
	BulkMarkMessageRead(context.Context, *connect_go.Request[room303.BulkMarkMessageReadRequest]) (*connect_go.Response[room303.BulkMarkMessageReadResponse], error)
	// Room
	CreateRoom(context.Context, *connect_go.Request[room303.CreateRoomRequest]) (*connect_go.Response[commons.Room], error)
	GetRoom(context.Context, *connect_go.Request[room303.GetRoomRequest]) (*connect_go.Response[commons.Room], error)
	ListAllRooms(context.Context, *connect_go.Request[room303.ListAllRoomsRequest]) (*connect_go.Response[room303.ListRoomsResponse], error)
	ListRoomsForMember(context.Context, *connect_go.Request[room303.ListRoomsForMemberRequest]) (*connect_go.Response[room303.ListRoomsResponse], error)
	ArchiveRoom(context.Context, *connect_go.Request[room303.ArchiveRoomRequest]) (*connect_go.Response[commons.Room], error)
}

Room303APIClient is a client for the api.v1alpha1.room303.Room303API service.

func NewRoom303APIClient 

func NewRoom303APIClient(httpClient connect_go.HTTPClient, baseURL string, opts ...connect_go.ClientOption) Room303APIClient

NewRoom303APIClient constructs a client for the api.v1alpha1.room303.Room303API service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type Room303APIHandler 

type Room303APIHandler interface {
	// Member
	//
	// Add a new member to a room, you must be a room admin in order to do that
	AddRoomMember(context.Context, *connect_go.Request[room303.AddRoomMemberRequest]) (*connect_go.Response[commons.Member], error)
	// Remove room member (kick), the room member will not receive notifications from that room
	RemoveRoomMember(context.Context, *connect_go.Request[room303.RemoveRoomMemberRequest]) (*connect_go.Response[room303.RemoveRoomMemberResponse], error)
	// List the members of this room
	ListRoomMembers(context.Context, *connect_go.Request[room303.ListRoomMembersRequest]) (*connect_go.Response[room303.ListRoomMembersResponse], error)
	// Set a room member as admin, you must be a room admin in order to do this.
	SetAdminForRoomMember(context.Context, *connect_go.Request[room303.SetAdminForRoomMemberRequest]) (*connect_go.Response[room303.SetAdminForRoomMemberResponse], error)
	// adds new member to a room and does not require the member to be admin
	JoinRoom(context.Context, *connect_go.Request[room303.JoinRoomRequest]) (*connect_go.Response[commons.Room], error)
	// gets the member entity from the provided room if it exists
	GetRoomMember(context.Context, *connect_go.Request[room303.GetRoomMemberRequest]) (*connect_go.Response[commons.Member], error)
	// Message
	CreateMessage(context.Context, *connect_go.Request[room303.CreateMessageRequest]) (*connect_go.Response[room303.CreateMessageResponse], error)
	EditMessage(context.Context, *connect_go.Request[room303.EditMessageRequest]) (*connect_go.Response[room303.EditMessageResponse], error)
	DeleteMessage(context.Context, *connect_go.Request[room303.DeleteMessageRequest]) (*connect_go.Response[room303.DeleteMessageResponse], error)
	GetMessages(context.Context, *connect_go.Request[room303.GetMessagesRequest]) (*connect_go.Response[room303.GetMessagesResponse], error)
	StreamMessageUpdates(context.Context, *connect_go.Request[room303.StreamMessageUpdatesRequest], *connect_go.ServerStream[room303.StreamMessageUpdatesResponse]) error
	GetUnreadStats(context.Context, *connect_go.Request[room303.GetUnreadStatsRequest]) (*connect_go.Response[room303.GetUnreadStatsResponse], error)
	MarkMessageRead(context.Context, *connect_go.Request[room303.MarkMessageReadRequest]) (*connect_go.Response[room303.MarkMessageReadResponse], error)
	MarkAllMessagesRead(context.Context, *connect_go.Request[room303.MarkAllMessagesReadRequest]) (*connect_go.Response[room303.MarkAllMessagesReadResponse], error)
	BulkMarkMessageRead(context.Context, *connect_go.Request[room303.BulkMarkMessageReadRequest]) (*connect_go.Response[room303.BulkMarkMessageReadResponse], error)
	// Room
	CreateRoom(context.Context, *connect_go.Request[room303.CreateRoomRequest]) (*connect_go.Response[commons.Room], error)
	GetRoom(context.Context, *connect_go.Request[room303.GetRoomRequest]) (*connect_go.Response[commons.Room], error)
	ListAllRooms(context.Context, *connect_go.Request[room303.ListAllRoomsRequest]) (*connect_go.Response[room303.ListRoomsResponse], error)
	ListRoomsForMember(context.Context, *connect_go.Request[room303.ListRoomsForMemberRequest]) (*connect_go.Response[room303.ListRoomsResponse], error)
	ArchiveRoom(context.Context, *connect_go.Request[room303.ArchiveRoomRequest]) (*connect_go.Response[commons.Room], error)
}

Room303APIHandler is an implementation of the api.v1alpha1.room303.Room303API service.

type UnimplementedRoom303APIHandler 

type UnimplementedRoom303APIHandler struct{}

UnimplementedRoom303APIHandler returns CodeUnimplemented from all methods.

func (UnimplementedRoom303APIHandler) AddRoomMember 

func (UnimplementedRoom303APIHandler) AddRoomMember(context.Context, *connect_go.Request[room303.AddRoomMemberRequest]) (*connect_go.Response[commons.Member], error)

func (UnimplementedRoom303APIHandler) ArchiveRoom 

func (UnimplementedRoom303APIHandler) ArchiveRoom(context.Context, *connect_go.Request[room303.ArchiveRoomRequest]) (*connect_go.Response[commons.Room], error)

func (UnimplementedRoom303APIHandler) BulkMarkMessageRead 

func (UnimplementedRoom303APIHandler) BulkMarkMessageRead(context.Context, *connect_go.Request[room303.BulkMarkMessageReadRequest]) (*connect_go.Response[room303.BulkMarkMessageReadResponse], error)

func (UnimplementedRoom303APIHandler) CreateMessage 

func (UnimplementedRoom303APIHandler) CreateMessage(context.Context, *connect_go.Request[room303.CreateMessageRequest]) (*connect_go.Response[room303.CreateMessageResponse], error)

func (UnimplementedRoom303APIHandler) CreateRoom 

func (UnimplementedRoom303APIHandler) CreateRoom(context.Context, *connect_go.Request[room303.CreateRoomRequest]) (*connect_go.Response[commons.Room], error)

func (UnimplementedRoom303APIHandler) DeleteMessage 

func (UnimplementedRoom303APIHandler) DeleteMessage(context.Context, *connect_go.Request[room303.DeleteMessageRequest]) (*connect_go.Response[room303.DeleteMessageResponse], error)

func (UnimplementedRoom303APIHandler) EditMessage 

func (UnimplementedRoom303APIHandler) EditMessage(context.Context, *connect_go.Request[room303.EditMessageRequest]) (*connect_go.Response[room303.EditMessageResponse], error)

func (UnimplementedRoom303APIHandler) GetMessages 

func (UnimplementedRoom303APIHandler) GetMessages(context.Context, *connect_go.Request[room303.GetMessagesRequest]) (*connect_go.Response[room303.GetMessagesResponse], error)

func (UnimplementedRoom303APIHandler) GetRoom 

func (UnimplementedRoom303APIHandler) GetRoom(context.Context, *connect_go.Request[room303.GetRoomRequest]) (*connect_go.Response[commons.Room], error)

func (UnimplementedRoom303APIHandler) GetRoomMember 

func (UnimplementedRoom303APIHandler) GetRoomMember(context.Context, *connect_go.Request[room303.GetRoomMemberRequest]) (*connect_go.Response[commons.Member], error)

func (UnimplementedRoom303APIHandler) GetUnreadStats 

func (UnimplementedRoom303APIHandler) GetUnreadStats(context.Context, *connect_go.Request[room303.GetUnreadStatsRequest]) (*connect_go.Response[room303.GetUnreadStatsResponse], error)

func (UnimplementedRoom303APIHandler) JoinRoom 

func (UnimplementedRoom303APIHandler) JoinRoom(context.Context, *connect_go.Request[room303.JoinRoomRequest]) (*connect_go.Response[commons.Room], error)

func (UnimplementedRoom303APIHandler) ListAllRooms 

func (UnimplementedRoom303APIHandler) ListAllRooms(context.Context, *connect_go.Request[room303.ListAllRoomsRequest]) (*connect_go.Response[room303.ListRoomsResponse], error)

func (UnimplementedRoom303APIHandler) ListRoomMembers 

func (UnimplementedRoom303APIHandler) ListRoomMembers(context.Context, *connect_go.Request[room303.ListRoomMembersRequest]) (*connect_go.Response[room303.ListRoomMembersResponse], error)

func (UnimplementedRoom303APIHandler) ListRoomsForMember 

func (UnimplementedRoom303APIHandler) ListRoomsForMember(context.Context, *connect_go.Request[room303.ListRoomsForMemberRequest]) (*connect_go.Response[room303.ListRoomsResponse], error)

func (UnimplementedRoom303APIHandler) MarkAllMessagesRead 

func (UnimplementedRoom303APIHandler) MarkAllMessagesRead(context.Context, *connect_go.Request[room303.MarkAllMessagesReadRequest]) (*connect_go.Response[room303.MarkAllMessagesReadResponse], error)

func (UnimplementedRoom303APIHandler) MarkMessageRead 

func (UnimplementedRoom303APIHandler) MarkMessageRead(context.Context, *connect_go.Request[room303.MarkMessageReadRequest]) (*connect_go.Response[room303.MarkMessageReadResponse], error)

func (UnimplementedRoom303APIHandler) RemoveRoomMember 

func (UnimplementedRoom303APIHandler) RemoveRoomMember(context.Context, *connect_go.Request[room303.RemoveRoomMemberRequest]) (*connect_go.Response[room303.RemoveRoomMemberResponse], error)

func (UnimplementedRoom303APIHandler) SetAdminForRoomMember 

func (UnimplementedRoom303APIHandler) SetAdminForRoomMember(context.Context, *connect_go.Request[room303.SetAdminForRoomMemberRequest]) (*connect_go.Response[room303.SetAdminForRoomMemberResponse], error)

func (UnimplementedRoom303APIHandler) StreamMessageUpdates 

func (UnimplementedRoom303APIHandler) StreamMessageUpdates(context.Context, *connect_go.Request[room303.StreamMessageUpdatesRequest], *connect_go.ServerStream[room303.StreamMessageUpdatesResponse]) error

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.