grpc_server

Documentation

Index

• type ItemHandler
  • func NewItemHandler(s interfaces.OrderService) *ItemHandler
  • func (h *ItemHandler) CancelOrder(ctx context.Context, req *api.CancelOrderRequest) (*api.CancelOrderResponse, error)
  • func (h *ItemHandler) CompleteOrder(ctx context.Context, req *api.CompleteOrderRequest) (*api.CompleteOrderResponse, error)
  • func (h *ItemHandler) CreateOrder(ctx context.Context, req *api.CreateOrderRequest) (*api.CreateOrderResponse, error)
  • func (h *ItemHandler) DeleteOrder(ctx context.Context, req *api.DeleteOrderRequest) (*api.DeleteOrderResponse, error)
  • func (h *ItemHandler) GetOrder(ctx context.Context, req *api.GetOrderRequest) (*api.GetOrderResponse, error)
  • func (h *ItemHandler) ListOrders(ctx context.Context, req *api.ListOrdersRequest) (*api.ListOrdersResponse, error)
  • func (h *ItemHandler) SearchOrders(ctx context.Context, req *api.SearchOrdersRequest) (*api.SearchOrdersResponse, error)
  • func (h *ItemHandler) UpdateOrder(ctx context.Context, req *api.UpdateOrderRequest) (*api.UpdateOrderResponse, error)
• type Option
  • func WithAddr(addr string) Option
  • func WithCircuitBreakerSettings(maxRequests uint32, interval, timeout time.Duration) Option
  • func WithProfiling() Option
  • func WithRateLimiter(limit, burst int) Option
• type Server
  • func MustNew(log logger.Logger, handler api.OrderServiceServer, opts ...Option) *Server
  • func (s *Server) GracefulStop()
  • func (s *Server) Run() error

Types

type ItemHandler

type ItemHandler struct {
	api.UnimplementedOrderServiceServer
	// contains filtered or unexported fields
}

func NewItemHandler

func NewItemHandler(s interfaces.OrderService) *ItemHandler

func (*ItemHandler) CancelOrder

func (h *ItemHandler) CancelOrder(ctx context.Context, req *api.CancelOrderRequest) (*api.CancelOrderResponse, error)

func (*ItemHandler) CompleteOrder

func (h *ItemHandler) CompleteOrder(ctx context.Context, req *api.CompleteOrderRequest) (*api.CompleteOrderResponse, error)

func (*ItemHandler) CreateOrder

func (h *ItemHandler) CreateOrder(ctx context.Context, req *api.CreateOrderRequest) (*api.CreateOrderResponse, error)

func (*ItemHandler) DeleteOrder

func (h *ItemHandler) DeleteOrder(ctx context.Context, req *api.DeleteOrderRequest) (*api.DeleteOrderResponse, error)

func (*ItemHandler) GetOrder

func (h *ItemHandler) GetOrder(ctx context.Context, req *api.GetOrderRequest) (*api.GetOrderResponse, error)

func (*ItemHandler) ListOrders

func (h *ItemHandler) ListOrders(ctx context.Context, req *api.ListOrdersRequest) (*api.ListOrdersResponse, error)

func (*ItemHandler) SearchOrders

func (h *ItemHandler) SearchOrders(ctx context.Context, req *api.SearchOrdersRequest) (*api.SearchOrdersResponse, error)

func (*ItemHandler) UpdateOrder

func (h *ItemHandler) UpdateOrder(ctx context.Context, req *api.UpdateOrderRequest) (*api.UpdateOrderResponse, error)

type Option

type Option func(*Server)

func WithAddr

func WithAddr(addr string) Option

func WithCircuitBreakerSettings

func WithCircuitBreakerSettings(maxRequests uint32, interval, timeout time.Duration) Option

func WithProfiling

func WithProfiling() Option

func WithRateLimiter

func WithRateLimiter(limit, burst int) Option

type Server

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

func MustNew

func MustNew(log logger.Logger, handler api.OrderServiceServer, opts ...Option) *Server

func (*Server) GracefulStop

func (s *Server) GracefulStop()

func (*Server) Run

func (s *Server) Run() error

Run starts grpc server using cmux.

Handles all HTTP2 requests with 'content-type: application/grpc' headers with grpc server Other paths are hardcoded (for now at least).

Hardcoded ones are: <addr>/metrics. And if profiling is enabled: <addr>/debug/pprof{/,/cmdline,/profile,/symbol,/trace}.