server

Documentation

Index

• func Start(ip string, port int, logger *slog.Logger, ts telemetry.TelemetryService, ...)
• type GuessesServer
  • func (gs *GuessesServer) GetLeaderboard(ctx context.Context, r *connect.Request[guessesv1.GetLeaderboardRequest]) (*connect.Response[guessesv1.GetLeaderboardResponse], error)
  • func (gs *GuessesServer) ResetScores(ctx context.Context, r *connect.Request[guessesv1.ResetScoresRequest]) (*connect.Response[guessesv1.ResetScoresResponse], error)
  • func (gs *GuessesServer) SubmitGuess(ctx context.Context, r *connect.Request[guessesv1.SubmitGuessRequest]) (*connect.Response[guessesv1.SubmitGuessResponse], error)
  • func (rs *GuessesServer) SubscribeAllGuessesEvents(ctx context.Context, ...) error
  • func (rs *GuessesServer) SubscribeGuessesEvents(ctx context.Context, ...) error

Functions

func Start

func Start(ip string, port int, logger *slog.Logger, ts telemetry.TelemetryService, usecase usecase.Guesses)

Types

type GuessesServer

type GuessesServer struct {
	guessesv1connect.UnimplementedGuessesServiceHandler
	guessesv1connect.UnimplementedEventServiceHandler
	// contains filtered or unexported fields
}

func (*GuessesServer) GetLeaderboard

func (gs *GuessesServer) GetLeaderboard(ctx context.Context, r *connect.Request[guessesv1.GetLeaderboardRequest]) (*connect.Response[guessesv1.GetLeaderboardResponse], error)

func (*GuessesServer) ResetScores

func (gs *GuessesServer) ResetScores(ctx context.Context, r *connect.Request[guessesv1.ResetScoresRequest]) (*connect.Response[guessesv1.ResetScoresResponse], error)

func (*GuessesServer) SubmitGuess

func (gs *GuessesServer) SubmitGuess(ctx context.Context, r *connect.Request[guessesv1.SubmitGuessRequest]) (*connect.Response[guessesv1.SubmitGuessResponse], error)

func (*GuessesServer) SubscribeAllGuessesEvents

func (rs *GuessesServer) SubscribeAllGuessesEvents(ctx context.Context, r *connect.Request[guessesv1.SubscribeAllGuessesEventsRequest], s *connect.ServerStream[guessesv1.SubscribeAllGuessesEventsResponse]) error

func (*GuessesServer) SubscribeGuessesEvents

func (rs *GuessesServer) SubscribeGuessesEvents(ctx context.Context, r *connect.Request[guessesv1.SubscribeGuessesEventsRequest], s *connect.ServerStream[guessesv1.SubscribeGuessesEventsResponse]) error