grpc_handlers

Documentation

Index

• func NewChatGrpcHandler(logger *log.SubLogger, chatService *chat.ChatService) chatv1connect.ChatServiceHandler
• func NewEventsGrpcHandler(logger *log.SubLogger, streamer stream.StreamSubscriber) eventsv1connect.EventsServiceHandler
• func NewMessageGrpcHandler(logger *log.SubLogger, messageService *message.MessageService) messagev1connect.MessageServiceHandler
• func NewSearchGrpcHandler(logger *log.SubLogger, searchService *search.SearchService) searchv1connect.SearchServiceHandler
• type AuthGrpcServer
  • func NewAuthGrpcHandler(authService *auth.AuthService) AuthGrpcServer
  • func (a AuthGrpcServer) Authenticate(ctx context.Context, req *connect.Request[authv1.AuthenticateRequest]) (*connect.Response[authv1.AuthenticateResponse], error)
  • func (a AuthGrpcServer) ChangePassword(ctx context.Context, req *connect.Request[authv1.ChangePasswordRequest]) (*connect.Response[authv1.ChangePasswordResponse], error)
  • func (a AuthGrpcServer) Login(ctx context.Context, req *connect.Request[authv1.LoginRequest]) (*connect.Response[authv1.LoginResponse], error)
  • func (a AuthGrpcServer) RefreshToken(ctx context.Context, req *connect.Request[authv1.RefreshTokenRequest]) (*connect.Response[authv1.RefreshTokenResponse], error)
  • func (a AuthGrpcServer) Register(ctx context.Context, req *connect.Request[authv1.RegisterRequest]) (*connect.Response[authv1.RegisterResponse], error)
  • func (a AuthGrpcServer) SendResetPassword(ctx context.Context, req *connect.Request[authv1.SendResetPasswordRequest]) (*connect.Response[authv1.SendResetPasswordResponse], error)
  • func (a AuthGrpcServer) SubmitResetPassword(ctx context.Context, req *connect.Request[authv1.SubmitResetPasswordRequest]) (*connect.Response[authv1.SubmitResetPasswordResponse], error)
  • func (a AuthGrpcServer) VerifyEmail(ctx context.Context, req *connect.Request[authv1.VerifyEmailRequest]) (*connect.Response[authv1.VerifyEmailResponse], error)
• type MessageGrpcServer
  • func (h MessageGrpcServer) FetchMessages(ctx context.Context, req *connect.Request[messagev1.FetchMessagesRequest]) (*connect.Response[messagev1.FetchMessagesResponse], error)
  • func (h MessageGrpcServer) SendTextMessage(ctx context.Context, req *connect.Request[messagev1.SendTextMessageRequest]) (*connect.Response[messagev1.SendTextMessageResponse], error)

Functions

func NewChatGrpcHandler

func NewChatGrpcHandler(logger *log.SubLogger, chatService *chat.ChatService) chatv1connect.ChatServiceHandler

func NewEventsGrpcHandler

func NewEventsGrpcHandler(logger *log.SubLogger, streamer stream.StreamSubscriber) eventsv1connect.EventsServiceHandler

func NewMessageGrpcHandler

func NewMessageGrpcHandler(logger *log.SubLogger, messageService *message.MessageService) messagev1connect.MessageServiceHandler

func NewSearchGrpcHandler

func NewSearchGrpcHandler(logger *log.SubLogger, searchService *search.SearchService) searchv1connect.SearchServiceHandler

Types

type AuthGrpcServer

type AuthGrpcServer struct {
	// contains filtered or unexported fields
}

func NewAuthGrpcHandler

func NewAuthGrpcHandler(authService *auth.AuthService) AuthGrpcServer

func (AuthGrpcServer) Authenticate

func (a AuthGrpcServer) Authenticate(ctx context.Context, req *connect.Request[authv1.AuthenticateRequest]) (*connect.Response[authv1.AuthenticateResponse], error)

func (AuthGrpcServer) ChangePassword

func (a AuthGrpcServer) ChangePassword(ctx context.Context, req *connect.Request[authv1.ChangePasswordRequest]) (*connect.Response[authv1.ChangePasswordResponse], error)

func (AuthGrpcServer) Login

func (a AuthGrpcServer) Login(ctx context.Context, req *connect.Request[authv1.LoginRequest]) (*connect.Response[authv1.LoginResponse], error)

func (AuthGrpcServer) RefreshToken

func (a AuthGrpcServer) RefreshToken(ctx context.Context, req *connect.Request[authv1.RefreshTokenRequest]) (*connect.Response[authv1.RefreshTokenResponse], error)

func (AuthGrpcServer) Register

func (a AuthGrpcServer) Register(ctx context.Context, req *connect.Request[authv1.RegisterRequest]) (*connect.Response[authv1.RegisterResponse], error)

func (AuthGrpcServer) SendResetPassword

func (a AuthGrpcServer) SendResetPassword(ctx context.Context, req *connect.Request[authv1.SendResetPasswordRequest]) (*connect.Response[authv1.SendResetPasswordResponse], error)

func (AuthGrpcServer) SubmitResetPassword

func (a AuthGrpcServer) SubmitResetPassword(ctx context.Context, req *connect.Request[authv1.SubmitResetPasswordRequest]) (*connect.Response[authv1.SubmitResetPasswordResponse], error)

func (AuthGrpcServer) VerifyEmail

func (a AuthGrpcServer) VerifyEmail(ctx context.Context, req *connect.Request[authv1.VerifyEmailRequest]) (*connect.Response[authv1.VerifyEmailResponse], error)

type MessageGrpcServer

type MessageGrpcServer struct {
	// contains filtered or unexported fields
}

func (MessageGrpcServer) FetchMessages

func (h MessageGrpcServer) FetchMessages(ctx context.Context, req *connect.Request[messagev1.FetchMessagesRequest]) (*connect.Response[messagev1.FetchMessagesResponse], error)

func (MessageGrpcServer) SendTextMessage

func (h MessageGrpcServer) SendTextMessage(ctx context.Context, req *connect.Request[messagev1.SendTextMessageRequest]) (*connect.Response[messagev1.SendTextMessageResponse], error)