service

package

v0.7.5 Latest Latest Go to latest Published: Aug 31, 2024 License: MIT Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

gitlab.com/binarygame/microservices/rooms

Links

Open Source Insights

Documentation ¶

Index ¶

func Start(ip string, port int, repository repository.RoomsRepository, ...)
type RoomsServer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Start ¶

func Start(ip string, port int, repository repository.RoomsRepository, logger *slog.Logger, questionsClient questionsv1connect.QuestionsServiceClient, guessesClient guessesv1connect.GuessesServiceClient, ts telemetry.TelemetryService)

Types ¶

type RoomsServer ¶

type RoomsServer struct {
	roomsv1connect.UnimplementedRoomsServiceHandler
	roomsv1connect.UnimplementedEventServiceHandler
	// contains filtered or unexported fields
}

func (*RoomsServer) BanUserFromRoom ¶

func (rs *RoomsServer) BanUserFromRoom(ctx context.Context, r *connect.Request[roomsv1.BanUserFromRoomRequest]) (*connect.Response[roomsv1.BanUserFromRoomResponse], error)

func (*RoomsServer) CheckIfRoomExists ¶ added in v0.7.3

func (rs *RoomsServer) CheckIfRoomExists(ctx context.Context, r *connect.Request[roomsv1.CheckIfRoomExistsRequest]) (*connect.Response[roomsv1.CheckIfRoomExistsResponse], error)

func (*RoomsServer) CreateRoom ¶

func (rs *RoomsServer) CreateRoom(ctx context.Context, r *connect.Request[roomsv1.CreateRoomRequest]) (*connect.Response[roomsv1.CreateRoomResponse], error)

func (*RoomsServer) GetQuestionCount ¶

func (rs *RoomsServer) GetQuestionCount(ctx context.Context, r *connect.Request[roomsv1.GetQuestionCountRequest]) (*connect.Response[roomsv1.GetQuestionCountResponse], error)

func (*RoomsServer) GetRoom ¶

func (rs *RoomsServer) GetRoom(ctx context.Context, r *connect.Request[roomsv1.GetRoomRequest]) (*connect.Response[roomsv1.GetRoomResponse], error)

func (*RoomsServer) GetUsersInRoom ¶

func (rs *RoomsServer) GetUsersInRoom(ctx context.Context, r *connect.Request[roomsv1.GetUsersInRoomRequest]) (*connect.Response[roomsv1.GetUsersInRoomResponse], error)

func (*RoomsServer) RegisterUserInRoom ¶

func (rs *RoomsServer) RegisterUserInRoom(ctx context.Context, r *connect.Request[roomsv1.RegisterUserInRoomRequest]) (*connect.Response[roomsv1.RegisterUserInRoomResponse], error)

func (*RoomsServer) StartMatch ¶

func (rs *RoomsServer) StartMatch(ctx context.Context, r *connect.Request[roomsv1.StartMatchRequest]) (*connect.Response[roomsv1.StartMatchResponse], error)

func (*RoomsServer) SubscribeAllRoomEvents ¶

func (rs *RoomsServer) SubscribeAllRoomEvents(ctx context.Context, r *connect.Request[roomsv1.SubscribeAllRoomEventsRequest], s *connect.ServerStream[roomsv1.SubscribeAllRoomEventsResponse]) error

func (*RoomsServer) SubscribeRoomEvents ¶

func (rs *RoomsServer) SubscribeRoomEvents(ctx context.Context, r *connect.Request[roomsv1.SubscribeRoomEventsRequest], s *connect.ServerStream[roomsv1.SubscribeRoomEventsResponse]) error

func (*RoomsServer) UserFinishedAnswering ¶ added in v0.7.5

func (rs *RoomsServer) UserFinishedAnswering(ctx context.Context, r *connect.Request[roomsv1.UserFinishedAnsweringRequest]) (*connect.Response[roomsv1.UserFinishedAnsweringResponse], error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL