client

package
v2.2.4+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 20, 2020 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildAddFunc

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

BuildAddFunc builds the remote method to invoke for "storage" service "add" 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

BuildMultiAddFunc builds the remote method to invoke for "storage" service "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

BuildMultiUpdateFunc builds the remote method to invoke for "storage" 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

BuildRateFunc builds the remote method to invoke for "storage" service "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

BuildRemoveFunc builds the remote method to invoke for "storage" service "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

BuildShowFunc builds the remote method to invoke for "storage" service "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 interface{}, hdr, trlr metadata.MD) (interface{}, error)

DecodeAddResponse decodes responses from the storage add endpoint.

func DecodeListResponse

func DecodeListResponse(ctx context.Context, v interface{}, hdr, trlr metadata.MD) (interface{}, error)

DecodeListResponse decodes responses from the storage list endpoint.

func DecodeMultiAddResponse

func DecodeMultiAddResponse(ctx context.Context, v interface{}, hdr, trlr metadata.MD) (interface{}, error)

DecodeMultiAddResponse decodes responses from the storage multi_add endpoint.

func DecodeShowResponse

func DecodeShowResponse(ctx context.Context, v interface{}, hdr, trlr metadata.MD) (interface{}, error)

DecodeShowResponse decodes responses from the storage show endpoint.

func EncodeAddRequest

func EncodeAddRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)

EncodeAddRequest encodes requests sent to storage add endpoint.

func EncodeMultiAddRequest

func EncodeMultiAddRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)

EncodeMultiAddRequest encodes requests sent to storage multi_add endpoint.

func EncodeMultiUpdateRequest

func EncodeMultiUpdateRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)

EncodeMultiUpdateRequest encodes requests sent to storage multi_update endpoint.

func EncodeRateRequest

func EncodeRateRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)

EncodeRateRequest encodes requests sent to storage rate endpoint.

func EncodeRemoveRequest

func EncodeRemoveRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)

EncodeRemoveRequest encodes requests sent to storage remove endpoint.

func EncodeShowRequest

func EncodeShowRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)

EncodeShowRequest encodes requests sent to storage show endpoint.

func NewAddRequest

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

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

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 NewListRequest

func NewListRequest() *storagepb.ListRequest

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

func NewListResult

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

func NewMultiAddRequest

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

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

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 NewMultiUpdateRequest

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

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

func NewRateRequest

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

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

func NewRemoveRequest

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

NewRemoveRequest builds the gRPC request type from the payload of the "remove" 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 NewShowRequest

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

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

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(message *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(message *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(message *storagepb.Winery) (err error)

ValidateWinery runs the validations defined on Winery.

Types

type Client

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

Client lists the service endpoint gRPC clients.

func NewClient

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

NewClient instantiates gRPC client for all the storage service servers.

func (*Client) Add

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

Add calls the "Add" function in storagepb.StorageClient interface.

func (*Client) List

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

List calls the "List" function in storagepb.StorageClient interface.

func (*Client) MultiAdd

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

MultiAdd calls the "MultiAdd" function in storagepb.StorageClient interface.

func (*Client) MultiUpdate

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

MultiUpdate calls the "MultiUpdate" function in storagepb.StorageClient interface.

func (*Client) Rate

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

Rate calls the "Rate" function in storagepb.StorageClient interface.

func (*Client) Remove

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

Remove calls the "Remove" function in storagepb.StorageClient interface.

func (*Client) Show

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

Show calls the "Show" function in storagepb.StorageClient interface.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL