client

Documentation

Index

• func BuildAddFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc
• func BuildAddPayload(storageAddMessage string) (*storage.Bottle, error)
• func BuildListFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc
• func BuildMultiAddFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc
• func BuildMultiAddPayload(storageMultiAddMessage string) ([]*storage.Bottle, error)
• func BuildMultiUpdateFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc
• func BuildMultiUpdatePayload(storageMultiUpdateMessage string) (*storage.MultiUpdatePayload, error)
• func BuildRateFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc
• func BuildRatePayload(storageRateMessage string) (map[uint32][]string, error)
• func BuildRemoveFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc
• func BuildRemovePayload(storageRemoveMessage string) (*storage.RemovePayload, error)
• func BuildShowFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc
• func BuildShowPayload(storageShowMessage string, storageShowView string) (*storage.ShowPayload, error)
• func DecodeAddResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)
• func DecodeListResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)
• func DecodeMultiAddResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)
• func DecodeShowResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)
• func EncodeAddRequest(ctx context.Context, v any, md *metadata.MD) (any, error)
• func EncodeMultiAddRequest(ctx context.Context, v any, md *metadata.MD) (any, error)
• func EncodeMultiUpdateRequest(ctx context.Context, v any, md *metadata.MD) (any, error)
• func EncodeRateRequest(ctx context.Context, v any, md *metadata.MD) (any, error)
• func EncodeRemoveRequest(ctx context.Context, v any, md *metadata.MD) (any, error)
• func EncodeShowRequest(ctx context.Context, v any, md *metadata.MD) (any, error)
• func NewAddResult(message *storagepb.AddResponse) string
• func NewListResult(message *storagepb.StoredBottleCollection) storageviews.StoredBottleCollectionView
• func NewMultiAddResult(message *storagepb.MultiAddResponse) []string
• func NewProtoAddRequest(payload *storage.Bottle) *storagepb.AddRequest
• func NewProtoListRequest() *storagepb.ListRequest
• func NewProtoMultiAddRequest(payload []*storage.Bottle) *storagepb.MultiAddRequest
• func NewProtoMultiUpdateRequest(payload *storage.MultiUpdatePayload) *storagepb.MultiUpdateRequest
• func NewProtoRateRequest(payload map[uint32][]string) *storagepb.RateRequest
• func NewProtoRemoveRequest(payload *storage.RemovePayload) *storagepb.RemoveRequest
• func NewProtoShowRequest(payload *storage.ShowPayload) *storagepb.ShowRequest
• func NewShowNotFoundError(message *storagepb.ShowNotFoundError) *storage.NotFound
• func NewShowResult(message *storagepb.ShowResponse) *storageviews.StoredBottleView
• func ValidateComponent(elem *storagepb.Component) (err error)
• func ValidateShowResponse(message *storagepb.ShowResponse) (err error)
• func ValidateStoredBottle(elem *storagepb.StoredBottle) (err error)
• func ValidateStoredBottleCollection(message *storagepb.StoredBottleCollection) (err error)
• func ValidateWinery(winery *storagepb.Winery) (err error)
• type Client
  • func NewClient(cc *grpc.ClientConn, opts ...grpc.CallOption) *Client
  • func (c *Client) Add() goa.Endpoint
  • func (c *Client) List() goa.Endpoint
  • func (c *Client) MultiAdd() goa.Endpoint
  • func (c *Client) MultiUpdate() goa.Endpoint
  • func (c *Client) Rate() goa.Endpoint
  • func (c *Client) Remove() goa.Endpoint
  • func (c *Client) Show() goa.Endpoint

Functions

func BuildAddFunc

func BuildAddFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

endpoint.

func BuildAddPayload

func BuildAddPayload(storageAddMessage string) (*storage.Bottle, error)

BuildAddPayload builds the payload for the storage add endpoint from CLI flags.

func BuildListFunc

func BuildListFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

BuildListFunc builds the remote method to invoke for "storage" service "list" endpoint.

func BuildMultiAddFunc

func BuildMultiAddFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

"multi_add" endpoint.

func BuildMultiAddPayload

func BuildMultiAddPayload(storageMultiAddMessage string) ([]*storage.Bottle, error)

BuildMultiAddPayload builds the payload for the storage multi_add endpoint from CLI flags.

func BuildMultiUpdateFunc

func BuildMultiUpdateFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

service "multi_update" endpoint.

func BuildMultiUpdatePayload

func BuildMultiUpdatePayload(storageMultiUpdateMessage string) (*storage.MultiUpdatePayload, error)

BuildMultiUpdatePayload builds the payload for the storage multi_update endpoint from CLI flags.

func BuildRateFunc

func BuildRateFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

"rate" endpoint.

func BuildRatePayload

func BuildRatePayload(storageRateMessage string) (map[uint32][]string, error)

BuildRatePayload builds the payload for the storage rate endpoint from CLI flags.

func BuildRemoveFunc

func BuildRemoveFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

"remove" endpoint.

func BuildRemovePayload

func BuildRemovePayload(storageRemoveMessage string) (*storage.RemovePayload, error)

BuildRemovePayload builds the payload for the storage remove endpoint from CLI flags.

func BuildShowFunc

func BuildShowFunc(grpccli storagepb.StorageClient, cliopts ...grpc.CallOption) goagrpc.RemoteFunc

"show" endpoint.

func BuildShowPayload

func BuildShowPayload(storageShowMessage string, storageShowView string) (*storage.ShowPayload, error)

BuildShowPayload builds the payload for the storage show endpoint from CLI flags.

func DecodeAddResponse

func DecodeAddResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)

DecodeAddResponse decodes responses from the storage add endpoint.

func DecodeListResponse

func DecodeListResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)

DecodeListResponse decodes responses from the storage list endpoint.

func DecodeMultiAddResponse

func DecodeMultiAddResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)

DecodeMultiAddResponse decodes responses from the storage multi_add endpoint.

func DecodeShowResponse

func DecodeShowResponse(ctx context.Context, v any, hdr, trlr metadata.MD) (any, error)

DecodeShowResponse decodes responses from the storage show endpoint.

func EncodeAddRequest

func EncodeAddRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeAddRequest encodes requests sent to storage add endpoint.

func EncodeMultiAddRequest

func EncodeMultiAddRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeMultiAddRequest encodes requests sent to storage multi_add endpoint.

func EncodeMultiUpdateRequest

func EncodeMultiUpdateRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeMultiUpdateRequest encodes requests sent to storage multi_update endpoint.

func EncodeRateRequest

func EncodeRateRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeRateRequest encodes requests sent to storage rate endpoint.

func EncodeRemoveRequest

func EncodeRemoveRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeRemoveRequest encodes requests sent to storage remove endpoint.

func EncodeShowRequest

func EncodeShowRequest(ctx context.Context, v any, md *metadata.MD) (any, error)

EncodeShowRequest encodes requests sent to storage show endpoint.

func NewAddResult

func NewAddResult(message *storagepb.AddResponse) string

NewAddResult builds the result type of the "add" endpoint of the "storage" service from the gRPC response type.

func NewListResult

func NewListResult(message *storagepb.StoredBottleCollection) storageviews.StoredBottleCollectionView

NewListResult builds the result type of the "list" endpoint of the "storage" service from the gRPC response type.

func NewMultiAddResult

func NewMultiAddResult(message *storagepb.MultiAddResponse) []string

NewMultiAddResult builds the result type of the "multi_add" endpoint of the "storage" service from the gRPC response type.

func NewProtoAddRequest

func NewProtoAddRequest(payload *storage.Bottle) *storagepb.AddRequest

NewProtoAddRequest builds the gRPC request type from the payload of the "add" endpoint of the "storage" service.

func NewProtoListRequest

func NewProtoListRequest() *storagepb.ListRequest

NewProtoListRequest builds the gRPC request type from the payload of the "list" endpoint of the "storage" service.

func NewProtoMultiAddRequest

func NewProtoMultiAddRequest(payload []*storage.Bottle) *storagepb.MultiAddRequest

NewProtoMultiAddRequest builds the gRPC request type from the payload of the "multi_add" endpoint of the "storage" service.

func NewProtoMultiUpdateRequest

func NewProtoMultiUpdateRequest(payload *storage.MultiUpdatePayload) *storagepb.MultiUpdateRequest

NewProtoMultiUpdateRequest builds the gRPC request type from the payload of the "multi_update" endpoint of the "storage" service.

func NewProtoRateRequest

func NewProtoRateRequest(payload map[uint32][]string) *storagepb.RateRequest

NewProtoRateRequest builds the gRPC request type from the payload of the "rate" endpoint of the "storage" service.

func NewProtoRemoveRequest

func NewProtoRemoveRequest(payload *storage.RemovePayload) *storagepb.RemoveRequest

NewProtoRemoveRequest builds the gRPC request type from the payload of the "remove" endpoint of the "storage" service.

func NewProtoShowRequest

func NewProtoShowRequest(payload *storage.ShowPayload) *storagepb.ShowRequest

NewProtoShowRequest builds the gRPC request type from the payload of the "show" endpoint of the "storage" service.

func NewShowNotFoundError

func NewShowNotFoundError(message *storagepb.ShowNotFoundError) *storage.NotFound

NewShowNotFoundError builds the error type of the "show" endpoint of the "storage" service from the gRPC error response type.

func NewShowResult

func NewShowResult(message *storagepb.ShowResponse) *storageviews.StoredBottleView

NewShowResult builds the result type of the "show" endpoint of the "storage" service from the gRPC response type.

func ValidateComponent

func ValidateComponent(elem *storagepb.Component) (err error)

ValidateComponent runs the validations defined on Component.

func ValidateShowResponse

func ValidateShowResponse(message *storagepb.ShowResponse) (err error)

ValidateShowResponse runs the validations defined on ShowResponse.

func ValidateStoredBottle

func ValidateStoredBottle(elem *storagepb.StoredBottle) (err error)

ValidateStoredBottle runs the validations defined on StoredBottle.

func ValidateStoredBottleCollection

func ValidateStoredBottleCollection(message *storagepb.StoredBottleCollection) (err error)

ValidateStoredBottleCollection runs the validations defined on StoredBottleCollection.

func ValidateWinery

func ValidateWinery(winery *storagepb.Winery) (err error)

ValidateWinery runs the validations defined on Winery.

Types

type Client

type Client struct {
	// contains filtered or unexported fields

} // NewClient instantiates gRPC client for all the storage service servers.

Client lists the service endpoint gRPC clients.

func NewClient

func NewClient(cc *grpc.ClientConn, opts ...grpc.CallOption) *Client

func (*Client) Add

func (c *Client) Add() goa.Endpoint

func (*Client) List

func (c *Client) List() goa.Endpoint

func (*Client) MultiAdd

func (c *Client) MultiAdd() goa.Endpoint

func (*Client) MultiUpdate

func (c *Client) MultiUpdate() goa.Endpoint

interface.

func (*Client) Rate

func (c *Client) Rate() goa.Endpoint

func (*Client) Remove

func (c *Client) Remove() goa.Endpoint

func (*Client) Show

func (c *Client) Show() goa.Endpoint