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 interface{}, hdr, trlr metadata.MD) (interface{}, error)
- func DecodeListResponse(ctx context.Context, v interface{}, hdr, trlr metadata.MD) (interface{}, error)
- func DecodeMultiAddResponse(ctx context.Context, v interface{}, hdr, trlr metadata.MD) (interface{}, error)
- func DecodeShowResponse(ctx context.Context, v interface{}, hdr, trlr metadata.MD) (interface{}, error)
- func EncodeAddRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)
- func EncodeMultiAddRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)
- func EncodeMultiUpdateRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)
- func EncodeRateRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)
- func EncodeRemoveRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)
- func EncodeShowRequest(ctx context.Context, v interface{}, md *metadata.MD) (interface{}, error)
- func NewAddRequest(payload *storage.Bottle) *storagepb.AddRequest
- func NewAddResult(message *storagepb.AddResponse) string
- func NewListRequest() *storagepb.ListRequest
- func NewListResult(message *storagepb.StoredBottleCollection) storageviews.StoredBottleCollectionView
- func NewMultiAddRequest(payload []*storage.Bottle) *storagepb.MultiAddRequest
- func NewMultiAddResult(message *storagepb.MultiAddResponse) []string
- func NewMultiUpdateRequest(payload *storage.MultiUpdatePayload) *storagepb.MultiUpdateRequest
- func NewRateRequest(payload map[uint32][]string) *storagepb.RateRequest
- func NewRemoveRequest(payload *storage.RemovePayload) *storagepb.RemoveRequest
- func NewShowNotFoundError(message *storagepb.ShowNotFoundError) *storage.NotFound
- func NewShowRequest(payload *storage.ShowPayload) *storagepb.ShowRequest
- func NewShowResult(message *storagepb.ShowResponse) *storageviews.StoredBottleView
- func ValidateComponent(message *storagepb.Component) (err error)
- func ValidateShowResponse(message *storagepb.ShowResponse) (err error)
- func ValidateStoredBottle(message *storagepb.StoredBottle) (err error)
- func ValidateStoredBottleCollection(message *storagepb.StoredBottleCollection) (err error)
- func ValidateWinery(message *storagepb.Winery) (err error)
- type Client
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
EncodeRateRequest encodes requests sent to storage rate endpoint.
func EncodeRemoveRequest ¶
EncodeRemoveRequest encodes requests sent to storage remove endpoint.
func EncodeShowRequest ¶
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 ¶
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 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 ¶
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 ¶
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) MultiAdd ¶
MultiAdd calls the "MultiAdd" function in storagepb.StorageClient interface.
func (*Client) MultiUpdate ¶
MultiUpdate calls the "MultiUpdate" function in storagepb.StorageClient interface.