route_guide

type ClientOption func(*grpcClient)

type ClientRequestFunc func(context.Context, *metadata.MD) context.Context

type ClientResponseFunc func(context.Context, metadata.MD, metadata.MD) context.Context

type Endpoints struct {
	GetFeatureEndpoint        endpoint.Endpoint
	HalfDuplexEndpoint        endpoint.Endpoint // half duplex
	ReverseHalfDuplexEndpoint endpoint.Endpoint // reverse half duplex
	FullDuplexEndpoint        endpoint.Endpoint //  full duplex
}

type Feature struct {
	Name     string
	Location *Point
}

type GRPCServer struct {
	GetFeatureGRPCHandler        kitGRPC.Handler
	HalfDuplexGRPCHandler        kitGRPC.Handler // TODO : half duplex
	ReverseHalfDuplexGRPCHandler kitGRPC.Handler // TODO : reverse half duplex
	FullDuplexGRPCHandler        kitGRPC.Handler // TODO : full duplex
	// contains filtered or unexported fields
}

type Point struct {
	Latitude  int32
	Longitude int32
}

type Rectangle struct {
	Lo *Point
	Hi *Point
}

type Repository interface {
	GetFeature(ctx context.Context, latitude int32, longitude int32) (string, *Point, error)
	HalfDuplex(ctx context.Context, lo *Point, hi *Point) (string, *Point, error)
	ReverseHalfDuplex(ctx context.Context, latitude int32, longitude int32) (int32, int32, int32, int32, error)
	FullDuplex(ctx context.Context, location *Point, message string) (*Point, string, error)
}

type RequestAndStreamHalfDuplex struct {
	Request *pb.Rectangle
	Stream  pb.RouteGuide_HalfDuplexServer
}

type RouteNote struct {
	Location *Point
	Message  string
}

type RouteSummary struct {
	PointCount   int32
	FeatureCount int32
	Distance     int32
	ElapsedTime  int32
}

type Service interface {
	GetFeature(ctx context.Context, latitude int32, longitude int32) (string, *Point, error)
	BroadcastHalfDuplex() chan Feature
	HalfDuplex(req *pb.Rectangle, stream pb.RouteGuide_HalfDuplexServer) error // half duplex (client request, server streams)
	ReverseHalfDuplex(stream pb.RouteGuide_ReverseHalfDuplexServer) error      // reverse half duplex (client streams, server responds)
	BroadcastFullDuplex() chan RouteNote
	FullDuplex(stream pb.RouteGuide_FullDuplexServer) error // full duplex (both client and server streams)
	Log() log.Logger
}