driver

Documentation

Index

• type Client
  • func NewClient(tracer opentracing.Tracer, logger log.Factory, hostPort string) *Client
  • func (c *Client) FindNearest(ctx context.Context, location string) ([]Driver, error)
• type Driver
• type Interface
• type Redis
  • func (r *Redis) FindDriverIDs(ctx context.Context, location string) []string
  • func (r *Redis) GetDriver(ctx context.Context, driverID string) (Driver, error)
• type Server
  • func NewServer(hostPort string, tracer opentracing.Tracer, metricsFactory metrics.Factory, ...) *Server
  • func (s *Server) FindNearest(ctx thrift.Context, location string) ([]*driver.DriverLocation, error)
  • func (s *Server) Run() error

Types

type Client

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

Client is a remote client that implements driver.Interface

func NewClient

func NewClient(tracer opentracing.Tracer, logger log.Factory, hostPort string) *Client

NewClient creates a new driver.Client

func (*Client) FindNearest

func (c *Client) FindNearest(ctx context.Context, location string) ([]Driver, error)

FindNearest implements driver.Interface#FindNearest as an RPC

type Driver

type Driver struct {
	DriverID string
	Location string
}

Driver describes a driver and the currentl car location.

type Interface

type Interface interface {
	FindNearest(ctx context.Context, location string) ([]Driver, error)
}

Interface exposed by the Driver service.

type Redis

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

Redis is a simulator of remote Redis cache

func (*Redis) FindDriverIDs

func (r *Redis) FindDriverIDs(ctx context.Context, location string) []string

FindDriverIDs finds IDs of drivers who are near the location.

func (*Redis) GetDriver

func (r *Redis) GetDriver(ctx context.Context, driverID string) (Driver, error)

GetDriver returns driver and the current car location

type Server

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

Server implements jaeger-demo-frontend service

func NewServer

func NewServer(hostPort string, tracer opentracing.Tracer, metricsFactory metrics.Factory, logger log.Factory) *Server

NewServer creates a new driver.Server

func (*Server) FindNearest

func (s *Server) FindNearest(ctx thrift.Context, location string) ([]*driver.DriverLocation, error)

FindNearest implements Thrift interface TChanDriver

func (*Server) Run

func (s *Server) Run() error

Run starts the Driver server