gapi

Documentation

Index

• func GrpcLogger(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
• func HttpLogger(handler http.Handler) http.Handler
• type Metadata
• type ResponseRecorder
  • func (rec *ResponseRecorder) Write(body []byte) (int, error)
  • func (rec *ResponseRecorder) WriteHeader(statusCode int)
• type Server
  • func NewServer(config util.Config, store db.Store, taskDistributor worker.TaskDistributor) (*Server, error)
  • func (server *Server) CreateAccount(ctx context.Context, req *pb.CreateAccountRequest) (*pb.CreateAccountResponse, error)
  • func (server *Server) CreateUser(ctx context.Context, req *pb.CreateUserRequest) (*pb.CreateUserResponse, error)
  • func (server *Server) ListAccountEntries(ctx context.Context, req *pb.ListAccountEntriesRequest) (*pb.ListAccountEntriesResponse, error)
  • func (server *Server) ListUserAccounts(ctx context.Context, req *pb.ListUserAccountsRequest) (*pb.ListUserAccountsResponse, error)
  • func (server *Server) LoginUser(ctx context.Context, req *pb.LoginUserRequest) (*pb.LoginUserResponse, error)
  • func (server *Server) TransferEnergy(ctx context.Context, req *pb.TransferEnergyRequest) (*pb.TransferEnergyResponse, error)
  • func (server *Server) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (*pb.UpdateUserResponse, error)
  • func (server *Server) VerifyEmail(ctx context.Context, req *pb.VerifyEmailRequest) (*pb.VerifyEmailResponse, error)

Functions

func GrpcLogger

func GrpcLogger(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

GrpcLogger is a unary server interceptor that logs gRPC requests and responses.

func HttpLogger

func HttpLogger(handler http.Handler) http.Handler

HttpLogger is a middleware that logs HTTP requests and responses.

Types

type Metadata

type Metadata struct {
	UserAgent string
	ClientIP  string
}

type ResponseRecorder

type ResponseRecorder struct {
	http.ResponseWriter
	StatusCode int
	Body       []byte
}

ResponseRecorder is used to capture the status code and response body.

func (*ResponseRecorder) Write

func (rec *ResponseRecorder) Write(body []byte) (int, error)

Write captures the response body.

func (*ResponseRecorder) WriteHeader

func (rec *ResponseRecorder) WriteHeader(statusCode int)

WriteHeader captures the status code.

type Server

type Server struct {
	pb.UnimplementedEenergyServiceServer
	// contains filtered or unexported fields
}

Server serves gRPC requests for our eenergy service.

func NewServer

func NewServer(config util.Config, store db.Store, taskDistributor worker.TaskDistributor) (*Server, error)

NewServer creates a new gRPC server.

func (*Server) CreateAccount

func (server *Server) CreateAccount(ctx context.Context, req *pb.CreateAccountRequest) (*pb.CreateAccountResponse, error)

func (*Server) CreateUser

func (server *Server) CreateUser(ctx context.Context, req *pb.CreateUserRequest) (*pb.CreateUserResponse, error)

func (*Server) ListAccountEntries

func (server *Server) ListAccountEntries(ctx context.Context, req *pb.ListAccountEntriesRequest) (*pb.ListAccountEntriesResponse, error)

func (*Server) ListUserAccounts

func (server *Server) ListUserAccounts(ctx context.Context, req *pb.ListUserAccountsRequest) (*pb.ListUserAccountsResponse, error)

func (*Server) LoginUser

func (server *Server) LoginUser(ctx context.Context, req *pb.LoginUserRequest) (*pb.LoginUserResponse, error)

func (*Server) TransferEnergy

func (server *Server) TransferEnergy(ctx context.Context, req *pb.TransferEnergyRequest) (*pb.TransferEnergyResponse, error)

func (*Server) UpdateUser

func (server *Server) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (*pb.UpdateUserResponse, error)

func (*Server) VerifyEmail

func (server *Server) VerifyEmail(ctx context.Context, req *pb.VerifyEmailRequest) (*pb.VerifyEmailResponse, error)