rpc

Documentation

Index

• func NewPRCServer(db db.Service) pb.NYCabServer
• func Start(ctx context.Context, t *Server, lis net.Listener)
• type Server
  • func (r *Server) DoGetCabPickupCount(ctx context.Context, req *pb.GetCabPickupCountRequest) (*pb.GetCabPickupCountResponse, error)

Functions

func NewPRCServer

func NewPRCServer(db db.Service) pb.NYCabServer

NewPRCServer implementation

func Start

func Start(ctx context.Context, t *Server, lis net.Listener)

Start RPC listening service at given network listener Terminates when ctx.Done is received

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server implement proto NYCabServer

func (*Server) DoGetCabPickupCount

func (r *Server) DoGetCabPickupCount(ctx context.Context, req *pb.GetCabPickupCountRequest) (*pb.GetCabPickupCountResponse, error)

DoGetCabPickupCount implementation