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 OrderRepository
  • func NewOrderRepository(conn *grpc.ClientConn) OrderRepository
  • func (r OrderRepository) Save(ctx context.Context, paymentID, customerID string, ...) (string, error)
• type ProductRepository
  • func NewProductRepository(conn *grpc.ClientConn) ProductRepository
  • func (r ProductRepository) Find(ctx context.Context, productID string) (*domain.Product, error)
• type StoreRepository
  • func NewStoreRepository(conn *grpc.ClientConn) StoreRepository
  • func (r StoreRepository) Find(ctx context.Context, storeID string) (*domain.Store, 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 OrderRepository

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

func NewOrderRepository

func NewOrderRepository(conn *grpc.ClientConn) OrderRepository

func (OrderRepository) Save

func (r OrderRepository) Save(ctx context.Context, paymentID, customerID string, basketItems map[string]domain.Item) (string, error)

type ProductRepository

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

func NewProductRepository

func NewProductRepository(conn *grpc.ClientConn) ProductRepository

func (ProductRepository) Find

func (r ProductRepository) Find(ctx context.Context, productID string) (*domain.Product, error)

type StoreRepository

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

func NewStoreRepository

func NewStoreRepository(conn *grpc.ClientConn) StoreRepository

func (StoreRepository) Find

func (r StoreRepository) Find(ctx context.Context, storeID string) (*domain.Store, error)