WIP
This commit is contained in:
62
services/front/client/item/itemClient.go
Normal file
62
services/front/client/item/itemClient.go
Normal file
@ -0,0 +1,62 @@
|
||||
package itemClient
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/golang/protobuf/ptypes/empty"
|
||||
goa "goa.design/goa/v3/pkg"
|
||||
"google.golang.org/grpc"
|
||||
"google.golang.org/protobuf/types/known/emptypb"
|
||||
|
||||
genClient "crossnokaye-interview-assignment/services/item/gen/grpc/item/client"
|
||||
genItem "crossnokaye-interview-assignment/services/item/gen/item"
|
||||
)
|
||||
|
||||
type (
|
||||
ItemClient interface {
|
||||
GetItemRequest(ctx context.Context, id int32) (*genItem.Item, error)
|
||||
// listItems(ctx context.Context) (*Forecast, error)
|
||||
CreateItemRequest(ctx context.Context, item genItem.Item) (*genItem.Item, error)
|
||||
UpdateItemRequest(ctx context.Context, item genItem.Item) (*genItem.Item, error)
|
||||
DeleteItemRequest(ctx context.Context, id int32) (*empty.Empty, error)
|
||||
}
|
||||
|
||||
// client is the client implementation.
|
||||
itemClient struct {
|
||||
getItem goa.Endpoint
|
||||
createItem goa.Endpoint
|
||||
updateItem goa.Endpoint
|
||||
deleteItem goa.Endpoint
|
||||
}
|
||||
)
|
||||
|
||||
// New instantiates a new forecast service client.
|
||||
func New(clientConnection *grpc.ClientConn) ItemClient {
|
||||
c := genClient.NewClient(clientConnection, grpc.WaitForReady(true))
|
||||
return &itemClient{c.GetItem(), c.CreateItem(), c.UpdateItem(), c.DeleteItem()}
|
||||
}
|
||||
|
||||
// createItemRequest implements ItemClient.
|
||||
func (itemClient *itemClient) CreateItemRequest(ctx context.Context, item genItem.Item) (*genItem.Item, error) {
|
||||
res, err := itemClient.createItem(ctx, item);
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return res.(*genItem.Item), nil
|
||||
}
|
||||
|
||||
// deleteItemRequest implements ItemClient.
|
||||
func (itemClient *itemClient) DeleteItemRequest(ctx context.Context, id int32) (*emptypb.Empty, error) {
|
||||
panic("unimplemented")
|
||||
}
|
||||
|
||||
// getItemRequest implements ItemClient.
|
||||
func (itemClient *itemClient) GetItemRequest(ctx context.Context, id int32) (*genItem.Item, error) {
|
||||
panic("unimplemented")
|
||||
}
|
||||
|
||||
// updateItemRequest implements ItemClient.
|
||||
func (itemClient *itemClient) UpdateItemRequest(ctx context.Context, item genItem.Item) (*genItem.Item, error) {
|
||||
panic("unimplemented")
|
||||
}
|
Reference in New Issue
Block a user