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 InvoiceRepository
  • func NewInvoiceRepository(conn *grpc.ClientConn) InvoiceRepository
  • func (r InvoiceRepository) Delete(ctx context.Context, invoiceID string) error
  • func (r InvoiceRepository) Save(ctx context.Context, orderID, paymentID string, amount float64) error
• type NotificationRepository
  • func NewNotificationRepository(conn *grpc.ClientConn) NotificationRepository
  • func (r NotificationRepository) NotifyOrderCanceled(ctx context.Context, orderID, customerID string) error
  • func (r NotificationRepository) NotifyOrderCreated(ctx context.Context, orderID, customerID string) error
  • func (r NotificationRepository) NotifyOrderReady(ctx context.Context, orderID, 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 InvoiceRepository

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

func NewInvoiceRepository

func NewInvoiceRepository(conn *grpc.ClientConn) InvoiceRepository

func (InvoiceRepository) Delete

func (r InvoiceRepository) Delete(ctx context.Context, invoiceID string) error

func (InvoiceRepository) Save

func (r InvoiceRepository) Save(ctx context.Context, orderID, paymentID string, amount float64) error

type NotificationRepository

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

func NewNotificationRepository

func NewNotificationRepository(conn *grpc.ClientConn) NotificationRepository

func (NotificationRepository) NotifyOrderCanceled

func (r NotificationRepository) NotifyOrderCanceled(ctx context.Context, orderID, customerID string) error

func (NotificationRepository) NotifyOrderCreated

func (r NotificationRepository) NotifyOrderCreated(ctx context.Context, orderID, customerID string) error

func (NotificationRepository) NotifyOrderReady

func (r NotificationRepository) NotifyOrderReady(ctx context.Context, orderID, 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)