Versions in this module Expand all Collapse all v0 v0.0.2 Mar 14, 2020 Changes in this version + func NewClient(conn *grpc.ClientConn, logger log.Logger, options ...kitGRPC.ClientOption) *grpcClient + func NewPBFromReply(msg *Reply) *pb.Reply + func NewPBFromRequest(msg *Request) *pb.Request + type ClientOption func(*grpcClient) + func ClientAfter(after ...ClientResponseFunc) ClientOption + func ClientBefore(before ...ClientRequestFunc) ClientOption + type ClientRequestFunc func(context.Context, *metadata.MD) context.Context + type ClientResponseFunc func(context.Context, metadata.MD, metadata.MD) context.Context + type Endpoints struct + FullDuplexEndpoint endpoint.Endpoint + HalfDuplexEndpoint endpoint.Endpoint + func MakeEndpoints(svc Service, mwares []endpoint.Middleware) Endpoints + type GRPCServer struct + FullDuplexGRPCHandler kitGRPC.Handler + HalfDuplexGRPCHandler kitGRPC.Handler + func NewGRPCServer(endpoints Endpoints, logger log.Logger, options ...kitGRPC.ServerOption) (*GRPCServer, error) + func (s *GRPCServer) FullDuplex(stream pb.Streams_FullDuplexServer) error + func (s *GRPCServer) HalfDuplex(req *pb.Request, stream pb.Streams_HalfDuplexServer) error + type Reply struct + Msg string + func NewReplyFromPB(msg *pb.Reply) *Reply + type Repository interface + FullDuplex func(ctx context.Context, msg string) (string, error) + HalfDuplex func(ctx context.Context, msg string) (string, error) + func NewRepository(logger log.Logger, db interface{}) Repository + type Request struct + Msg string + func NewRequestFromPB(msg *pb.Request) *Request + type RequestAndStreamHalfDuplex struct + Request *pb.Request + Stream pb.Streams_HalfDuplexServer + type Service interface + BroadcastFullDuplex func() chan Reply + BroadcastHalfDuplex func() chan Reply + FullDuplex func(stream pb.Streams_FullDuplexServer) error + HalfDuplex func(req *pb.Request, stream pb.Streams_HalfDuplexServer) error + Log func() log.Logger + func NewService(log log.Logger, repo Repository) Service