order

Documentation

Index

• func ListenGRPC(s Service, accountURL, catalogURL string, port int) error
• type Client
  • func NewClient(url string) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) GetOrdersForAccount(ctx context.Context, accountID string) ([]Order, error)
  • func (c *Client) PostOrder(ctx context.Context, accountID string, products []OrderedProduct) (*Order, error)
• type Order
• type OrderedProduct
• type Repository
  • func NewPostgresRepository(url string) (Repository, error)
• type Service
  • func NewService(r Repository) Service

Functions

func ListenGRPC

func ListenGRPC(s Service, accountURL, catalogURL string, port int) error

Types

type Client

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

func NewClient

func NewClient(url string) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) GetOrdersForAccount

func (c *Client) GetOrdersForAccount(ctx context.Context, accountID string) ([]Order, error)

func (*Client) PostOrder

func (c *Client) PostOrder(
	ctx context.Context,
	accountID string,
	products []OrderedProduct,
) (*Order, error)

type Order

type Order struct {
	ID         string
	CreatedAt  time.Time
	TotalPrice float64
	AccountID  string
	Products   []OrderedProduct
}

type OrderedProduct

type OrderedProduct struct {
	ID          string
	Name        string
	Description string
	Price       float64
	Quantity    uint32
}

type Repository

type Repository interface {
	Close()
	PutOrder(ctx context.Context, o Order) error
	GetOrdersForAccount(ctx context.Context, accountID string) ([]Order, error)
}

func NewPostgresRepository

func NewPostgresRepository(url string) (Repository, error)

type Service

type Service interface {
	PostOrder(ctx context.Context, accountID string, products []OrderedProduct) (*Order, error)
	GetOrdersForAccount(ctx context.Context, accountID string) ([]Order, error)
}

func NewService

func NewService(r Repository) Service