transport

Documentation

Index

• Variables
• func DecodeGRPCUserRequest(ctx context.Context, r interface{}) (interface{}, error)
• func DecodeGRPCUserResponse(_ context.Context, r interface{}) (interface{}, error)
• func EncodeGRPCUserRequest(_ context.Context, r interface{}) (interface{}, error)
• func EncodeGRPCUserResponse(_ context.Context, r interface{}) (interface{}, error)
• func MakeHttpHandler(ctx context.Context, endpoints endpts.UserEndpoints, ...) http.Handler
• func NewGRPCServer(ctx context.Context, endpoints endpts.UserEndpoints, ...) pb.UserServiceServer

Variables

var (
	ErrorBadRequest = errors.New("invalid request parameter")
)

Functions

func DecodeGRPCUserRequest

func DecodeGRPCUserRequest(ctx context.Context, r interface{}) (interface{}, error)

func DecodeGRPCUserResponse

func DecodeGRPCUserResponse(_ context.Context, r interface{}) (interface{}, error)

func EncodeGRPCUserRequest

func EncodeGRPCUserRequest(_ context.Context, r interface{}) (interface{}, error)

func EncodeGRPCUserResponse

func EncodeGRPCUserResponse(_ context.Context, r interface{}) (interface{}, error)

func MakeHttpHandler

func MakeHttpHandler(ctx context.Context, endpoints endpts.UserEndpoints, zipkinTracer *gozipkin.Tracer, logger log.Logger) http.Handler

MakeHttpHandler make http handler use mux

func NewGRPCServer

func NewGRPCServer(ctx context.Context, endpoints endpts.UserEndpoints, serverTracer grpc.ServerOption) pb.UserServiceServer