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 ResponceRecorder
  • func (rec *ResponceRecorder) Write(body []byte) (int, error)
  • func (rec *ResponceRecorder) WriteHeader(statusCode int)
• type Server
  • func NewServer(config util.Config, store db.Store, taskDistributer worker.TaskDistributor) (*Server, error)
  • func (server *Server) CreateUser(ctx context.Context, req *pb.CreateUserRequest) (*pb.CreateUserResponse, error)
  • func (server *Server) LoginUser(ctx context.Context, req *pb.LoginUserRequest) (*pb.LoginUserResponse, error)
  • func (server *Server) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (*pb.UpdateUserResponse, error)

Functions

func GrpcLogger

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

func HttpLogger

func HttpLogger(handler http.Handler) http.Handler

Types

type Metadata

type Metadata struct {
	UserAgent string
	ClientIP  string
}

type ResponceRecorder

type ResponceRecorder struct {
	http.ResponseWriter

	Body []byte
	// contains filtered or unexported fields
}

func (*ResponceRecorder) Write

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

func (*ResponceRecorder) WriteHeader

func (rec *ResponceRecorder) WriteHeader(statusCode int)

type Server

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

func NewServer

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

*db.Queries change on db.Store mock db

func (*Server) CreateUser

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

func (*Server) LoginUser

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

func (*Server) UpdateUser

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