grpc

Documentation

Index

• func DecodeGRPCFooRequest(_ context.Context, grpcReq interface{}) (req interface{}, err error)
• func EncodeGRPCFooResponse(_ context.Context, grpcReply interface{}) (res interface{}, err error)
• func MakeGRPCServer(endpoints endpoints.Endpoints) (req pb.TestGrpcServer)

Functions

func DecodeGRPCFooRequest

func DecodeGRPCFooRequest(_ context.Context, grpcReq interface{}) (req interface{}, err error)

DecodeGRPCFooRequest is a transport/grpc.DecodeRequestFunc that converts a gRPC request to a user-domain request. Primarily useful in a server. TODO: Do not forget to implement the decoder, you can find an example here : https://github.com/go-kit/kit/blob/master/examples/addsvc/transport_grpc.go#L62-L65

func EncodeGRPCFooResponse

func EncodeGRPCFooResponse(_ context.Context, grpcReply interface{}) (res interface{}, err error)

EncodeGRPCFooResponse is a transport/grpc.EncodeResponseFunc that converts a user-domain response to a gRPC reply. Primarily useful in a server. TODO: Do not forget to implement the encoder, you can find an example here : https://github.com/go-kit/kit/blob/master/examples/addsvc/transport_grpc.go#L62-L65

func MakeGRPCServer

func MakeGRPCServer(endpoints endpoints.Endpoints) (req pb.TestGrpcServer)

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