app

Documentation

Index

• type Server
  • func NewServer(srvManager *srv.ServiceManager) (*Server, error)
  • func (s *Server) Config(ctx context.Context, req *connect.Request[pb.ConfigRequest]) (*connect.Response[pb.ConfigResponse], error)
  • func (s *Server) Heartbeat(ctx context.Context, req *connect.Request[pb.HeartbeatRequest]) (*connect.Response[pb.HeartbeatResponse], error)
  • func (s *Server) Register(ctx context.Context, req *connect.Request[pb.RegisterRequest]) (*connect.Response[pb.RegisterResponse], error)
  • func (s *Server) Submit(ctx context.Context, req *connect.Request[pb.SubmitRequest]) (*connect.Response[pb.SubmitResponse], error)
  • func (s *Server) Unregister(ctx context.Context, req *connect.Request[pb.UnregisterRequest]) (*connect.Response[pb.UnregisterResult], error)
  • func (s *Server) Users(ctx context.Context, req *connect.Request[pb.UsersRequest]) (*connect.Response[pb.UsersResponse], error)
  • func (s *Server) Verify(ctx context.Context, req *connect.Request[pb.VerifyRequest]) (*connect.Response[pb.VerifyResponse], error)

Types

type Server

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

func NewServer

func NewServer(srvManager *srv.ServiceManager) (*Server, error)

func (*Server) Config

func (s *Server) Config(ctx context.Context, req *connect.Request[pb.ConfigRequest]) (*connect.Response[pb.ConfigResponse], error)

func (*Server) Heartbeat

func (s *Server) Heartbeat(ctx context.Context, req *connect.Request[pb.HeartbeatRequest]) (*connect.Response[pb.HeartbeatResponse], error)

func (*Server) Register

func (s *Server) Register(ctx context.Context, req *connect.Request[pb.RegisterRequest]) (*connect.Response[pb.RegisterResponse], error)

func (*Server) Submit

func (s *Server) Submit(ctx context.Context, req *connect.Request[pb.SubmitRequest]) (*connect.Response[pb.SubmitResponse], error)

func (*Server) Unregister

func (s *Server) Unregister(ctx context.Context, req *connect.Request[pb.UnregisterRequest]) (*connect.Response[pb.UnregisterResult], error)

func (*Server) Users

func (s *Server) Users(ctx context.Context, req *connect.Request[pb.UsersRequest]) (*connect.Response[pb.UsersResponse], error)

func (*Server) Verify

func (s *Server) Verify(ctx context.Context, req *connect.Request[pb.VerifyRequest]) (*connect.Response[pb.VerifyResponse], error)