transport

Documentation

Index

• func DecodeCreateJobRequest(ctx context.Context, r *http.Request) (interface{}, error)
• func DecodeGetJobRequest(ctx context.Context, r *http.Request) (interface{}, error)
• func DecodeLukeRequestFunc(_ context.Context, req interface{}) (request interface{}, err error)
• func EncodeHTTPResponse(_ context.Context, w http.ResponseWriter, response interface{}) error
• func EncodeLukeResponseFunc(_ context.Context, response interface{}) (interface{}, error)
• func MakeGRPCServer(endpoints endpoint.LukeEndPoints) pb.LukeServiceServer
• func MakeHTTPHandler(endpoints endpoint.LukeEndPoints) http.Handler

Functions

func DecodeCreateJobRequest

func DecodeCreateJobRequest(ctx context.Context, r *http.Request) (interface{}, error)

func DecodeGetJobRequest

func DecodeGetJobRequest(ctx context.Context, r *http.Request) (interface{}, error)

func DecodeLukeRequestFunc

func DecodeLukeRequestFunc(_ context.Context, req interface{}) (request interface{}, err error)

func EncodeHTTPResponse

func EncodeHTTPResponse(_ context.Context, w http.ResponseWriter, response interface{}) error

func EncodeLukeResponseFunc

func EncodeLukeResponseFunc(_ context.Context, response interface{}) (interface{}, error)

EncodeLukeResponseFunc is a transport/grpc.EncodeResponseFunc that converts a user-domain generic response to a gRPC generic reply. Primarily useful in a server.

func MakeGRPCServer

func MakeGRPCServer(endpoints endpoint.LukeEndPoints) pb.LukeServiceServer

MakeGRPCServer makes a set of endpoints available as a gRPC LukeServiceServer.

func MakeHTTPHandler

func MakeHTTPHandler(endpoints endpoint.LukeEndPoints) http.Handler