grpcapi

Documentation

Index

• func CreateServer(logger logging.Logger, repo repository.OrderRepoWith2PC) (*grpc.Server, error)
• func ServeWithTrace(ctx context.Context, server *grpc.Server, appConfig *config.API) error
• type OrderService
  • func (s *OrderService) GetOrder(ctx context.Context, request *pb.GetOrderRequest) (*pb.OrderResponse, error)
  • func (s *OrderService) InsertOrder(ctx context.Context, order *pb.Order) (*pb.OrderTnxResponse, error)
• type TnxConfirmingService
  • func (s *TnxConfirmingService) SendConfirmation(ctx context.Context, confirmation *pb.Confirmation) (*pb.ConfirmationResponse, error)

Functions

func CreateServer

func CreateServer(logger logging.Logger, repo repository.OrderRepoWith2PC) (*grpc.Server, error)

func ServeWithTrace

func ServeWithTrace(ctx context.Context, server *grpc.Server, appConfig *config.API) error

Types

type OrderService

type OrderService struct {
	pb.OrdersManagerServiceServer
	Repo repository.OrderRepoWith2PC
}

func (*OrderService) GetOrder

func (s *OrderService) GetOrder(ctx context.Context, request *pb.GetOrderRequest) (*pb.OrderResponse, error)

func (*OrderService) InsertOrder

func (s *OrderService) InsertOrder(ctx context.Context, order *pb.Order) (*pb.OrderTnxResponse, error)

type TnxConfirmingService

type TnxConfirmingService struct {
	pb.TnxConfirmingServiceServer
	Repo repository.OrderRepoWith2PC
}

func (*TnxConfirmingService) SendConfirmation

func (s *TnxConfirmingService) SendConfirmation(ctx context.Context,
	confirmation *pb.Confirmation,
) (*pb.ConfirmationResponse, error)