shipping

type ConsumerController interface {
	messaging.ConsumerController

	Attach(svc pb.ShippingServiceServer)
}

type EventOrderMetadata struct {
	CustomerId string
	ItemsPrice float32
	TotalPrice float32
}

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

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

type ShippingService struct {
	pb.UnimplementedShippingServiceServer
	// contains filtered or unexported fields
}

type StorageController interface {
	GetShipment(ctx context.Context, shipmentId string) (*pb.Shipment, error)
	GetShipmentItems(ctx context.Context, shipmentId string) ([]*pb.ShipmentItem, error)

	AllocateOrderShipment(ctx context.Context, orderId string, orderMetadata EventOrderMetadata, productQuantities map[string]int32) error
	CancelOrderShipment(ctx context.Context, orderId string) error
}