catalog

Documentation

Index

• Variables
• func ListenGRPC(s Service, port int) error
• type Client
  • func NewClient(url string) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) GetProduct(ctx context.Context, id string) (*Product, error)
  • func (c *Client) GetProducts(ctx context.Context, skip uint64, take uint64, ids []string, query string) ([]Product, error)
  • func (c *Client) PostProduct(ctx context.Context, name, description string, price float64) (*Product, error)
• type Product
• type Repository
  • func NewElasticRepository(url string) (Repository, error)
• type Service
  • func NewService(r Repository) Service

Variables

var (
	ErrNotFound = errors.New("Entity not found")
)

Functions

func ListenGRPC

func ListenGRPC(s Service, 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) GetProduct

func (c *Client) GetProduct(ctx context.Context, id string) (*Product, error)

func (*Client) GetProducts

func (c *Client) GetProducts(ctx context.Context, skip uint64, take uint64, ids []string, query string) ([]Product, error)

func (*Client) PostProduct

func (c *Client) PostProduct(ctx context.Context, name, description string, price float64) (*Product, error)

type Product

type Product struct {
	ID          string  `json:"id"`
	Name        string  `json:"name"`
	Description string  `json:"description"`
	Price       float64 `json:"price"`
}

type Repository

type Repository interface {
	Close()
	PutProduct(ctx context.Context, p Product) error
	GetProductByID(ctx context.Context, id string) (*Product, error)
	ListProducts(ctx context.Context, skip uint64, take uint64) ([]Product, error)
	ListProductsWithIDs(ctx context.Context, ids []string) ([]Product, error)
	SearchProducts(ctx context.Context, query string, skip uint64, take uint64) ([]Product, error)
}

func NewElasticRepository

func NewElasticRepository(url string) (Repository, error)

type Service

type Service interface {
	PostProduct(ctx context.Context, name, description string, price float64) (*Product, error)
	GetProduct(ctx context.Context, id string) (*Product, error)
	GetProducts(ctx context.Context, skip uint64, take uint64) ([]Product, error)
	GetProductsByIDs(ctx context.Context, ids []string) ([]Product, error)
	SearchProducts(ctx context.Context, query string, skip uint64, take uint64) ([]Product, error)
}

func NewService

func NewService(r Repository) Service