product

type ConsumerController interface {
	messaging.ConsumerController

	Attach(svc pb.ProductServiceServer)
}

type ProductService struct {
	pb.UnimplementedProductServiceServer
	// contains filtered or unexported fields
}

type ServiceConfig struct {
	// Core Configuration
	Shared config.SharedConfig

	// Dynamically loaded configuration
	Postgres config.PostgresConfig
	Kafka    config.KafkaConfig
}

type StorageController interface {
	GetProduct(ctx context.Context, productId string) (*pb.Product, error)
	GetProducts(ctx context.Context) ([]*pb.Product, error)

	UpdateProductPrice(ctx context.Context, productId string, price float32) (*pb.Product, error)
	DeleteProduct(ctx context.Context, productId string) error

	PriceOrderProducts(ctx context.Context, orderId string, customerId string, productQuantities map[string]int32) error
}