service

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2024 License: MIT Imports: 25 Imported by: 0

Documentation

Index

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) GetBannedUsersFromRoom added in v0.8.0 

func (rs *RoomsServer) GetBannedUsersFromRoom(ctx context.Context, r *connect.Request[roomsv1.GetBannedUsersFromRoomRequest]) (*connect.Response[roomsv1.GetBannedUsersFromRoomResponse], 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) RemoveUserFromRoom added in v0.8.0 

func (rs *RoomsServer) RemoveUserFromRoom(ctx context.Context, r *connect.Request[roomsv1.RemoveUserFromRoomRequest]) (*connect.Response[roomsv1.RemoveUserFromRoomResponse], 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) UnbanUserFromRoom added in v0.8.0 

func (rs *RoomsServer) UnbanUserFromRoom(ctx context.Context, r *connect.Request[roomsv1.UnbanUserFromRoomRequest]) (*connect.Response[roomsv1.UnbanUserFromRoomResponse], 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

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.