grpc

Documentation

Index

• func Dial(ctx context.Context, endpoint string) (conn *grpc.ClientConn, err error)
• func RegisterServer(app application.App, registrar grpc.ServiceRegistrar) error
• type CustomerRepository
  • func NewCustomerRepository(conn *grpc.ClientConn) CustomerRepository
  • func (r CustomerRepository) Authorize(ctx context.Context, customerID string) error
• type PaymentRepository
  • func NewPaymentRepository(conn *grpc.ClientConn) PaymentRepository
  • func (r PaymentRepository) Confirm(ctx context.Context, paymentID string) error
• type ShoppingRepository
  • func NewShoppingListRepository(conn *grpc.ClientConn) ShoppingRepository
  • func (r ShoppingRepository) Cancel(ctx context.Context, shoppingID string) error
  • func (r ShoppingRepository) Create(ctx context.Context, orderID string, orderItems []domain.Item) (string, error)

Functions

func Dial

func Dial(ctx context.Context, endpoint string) (conn *grpc.ClientConn, err error)

func RegisterServer

func RegisterServer(app application.App, registrar grpc.ServiceRegistrar) error

Types

type CustomerRepository

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

func NewCustomerRepository

func NewCustomerRepository(conn *grpc.ClientConn) CustomerRepository

func (CustomerRepository) Authorize

func (r CustomerRepository) Authorize(ctx context.Context, customerID string) error

type PaymentRepository

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

func NewPaymentRepository

func NewPaymentRepository(conn *grpc.ClientConn) PaymentRepository

func (PaymentRepository) Confirm

func (r PaymentRepository) Confirm(ctx context.Context, paymentID string) error

type ShoppingRepository

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

func NewShoppingListRepository

func NewShoppingListRepository(conn *grpc.ClientConn) ShoppingRepository

func (ShoppingRepository) Cancel

func (r ShoppingRepository) Cancel(ctx context.Context, shoppingID string) error

func (ShoppingRepository) Create

func (r ShoppingRepository) Create(ctx context.Context, orderID string, orderItems []domain.Item) (string, error)