factory worker post

This commit is contained in:
2026-09-14 14:27:20 +08:00
parent 4ff974eb8d
commit e04e82abb3
44 changed files with 4388 additions and 17 deletions
+837 -1
View File
@@ -19,7 +19,29 @@ import (
const _ = grpc.SupportPackageIsVersion9
const (
Store_Status_FullMethodName = "/store.Store/Status"
Store_Status_FullMethodName = "/store.Store/Status"
Store_Edit_FullMethodName = "/store.Store/Edit"
Store_Create_FullMethodName = "/store.Store/Create"
Store_ToSale_FullMethodName = "/store.Store/ToSale"
Store_Pwd_FullMethodName = "/store.Store/Pwd"
Store_Info_FullMethodName = "/store.Store/Info"
Store_Content_FullMethodName = "/store.Store/Content"
Store_Names_FullMethodName = "/store.Store/Names"
Store_Items_FullMethodName = "/store.Store/Items"
Store_VerifyItems_FullMethodName = "/store.Store/VerifyItems"
Store_VerifyStatus_FullMethodName = "/store.Store/VerifyStatus"
Store_VerifyEdit_FullMethodName = "/store.Store/VerifyEdit"
Store_ApplyEdit_FullMethodName = "/store.Store/ApplyEdit"
Store_ApplyVerify_FullMethodName = "/store.Store/ApplyVerify"
Store_ApplyVerifyStatus_FullMethodName = "/store.Store/ApplyVerifyStatus"
Store_DepositDone_FullMethodName = "/store.Store/DepositDone"
Store_DepositIgnore_FullMethodName = "/store.Store/DepositIgnore"
Store_DepositVerify_FullMethodName = "/store.Store/DepositVerify"
Store_DepositDown_FullMethodName = "/store.Store/DepositDown"
Store_DepositItems_FullMethodName = "/store.Store/DepositItems"
Store_DepositIgnoreItems_FullMethodName = "/store.Store/DepositIgnoreItems"
Store_DepositRecover_FullMethodName = "/store.Store/DepositRecover"
Store_DepositBackfill_FullMethodName = "/store.Store/DepositBackfill"
)
// StoreClient is the client API for Store service.
@@ -27,6 +49,28 @@ const (
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type StoreClient interface {
Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Response, error)
Edit(ctx context.Context, in *EditRequest, opts ...grpc.CallOption) (*Response, error)
Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*Response, error)
ToSale(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Response, error)
Pwd(ctx context.Context, in *PwdRequest, opts ...grpc.CallOption) (*Response, error)
Info(ctx context.Context, in *ToSaleRequest, opts ...grpc.CallOption) (*Response, error)
Content(ctx context.Context, in *ContentRequest, opts ...grpc.CallOption) (*Response, error)
Names(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error)
Items(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error)
VerifyItems(ctx context.Context, in *VerifyItemsRequest, opts ...grpc.CallOption) (*Response, error)
VerifyStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Response, error)
VerifyEdit(ctx context.Context, in *EditRequest, opts ...grpc.CallOption) (*Response, error)
ApplyEdit(ctx context.Context, in *ApplyEditRequest, opts ...grpc.CallOption) (*Response, error)
ApplyVerify(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error)
ApplyVerifyStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Response, error)
DepositDone(ctx context.Context, in *IdRequest, opts ...grpc.CallOption) (*Response, error)
DepositIgnore(ctx context.Context, in *DepositIgnoreRequest, opts ...grpc.CallOption) (*Response, error)
DepositVerify(ctx context.Context, in *DepositVerifyRequest, opts ...grpc.CallOption) (*Response, error)
DepositDown(ctx context.Context, in *DepositItemsRequest, opts ...grpc.CallOption) (*Response, error)
DepositItems(ctx context.Context, in *DepositItemsRequest, opts ...grpc.CallOption) (*Response, error)
DepositIgnoreItems(ctx context.Context, in *DepositVerifyRequest, opts ...grpc.CallOption) (*Response, error)
DepositRecover(ctx context.Context, in *IdRequest, opts ...grpc.CallOption) (*Response, error)
DepositBackfill(ctx context.Context, in *DepositBackfillRequest, opts ...grpc.CallOption) (*Response, error)
}
type storeClient struct {
@@ -47,11 +91,253 @@ func (c *storeClient) Status(ctx context.Context, in *StatusRequest, opts ...grp
return out, nil
}
func (c *storeClient) Edit(ctx context.Context, in *EditRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_Edit_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_Create_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) ToSale(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_ToSale_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) Pwd(ctx context.Context, in *PwdRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_Pwd_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) Info(ctx context.Context, in *ToSaleRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_Info_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) Content(ctx context.Context, in *ContentRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_Content_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) Names(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_Names_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) Items(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_Items_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) VerifyItems(ctx context.Context, in *VerifyItemsRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_VerifyItems_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) VerifyStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_VerifyStatus_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) VerifyEdit(ctx context.Context, in *EditRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_VerifyEdit_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) ApplyEdit(ctx context.Context, in *ApplyEditRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_ApplyEdit_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) ApplyVerify(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_ApplyVerify_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) ApplyVerifyStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_ApplyVerifyStatus_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) DepositDone(ctx context.Context, in *IdRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_DepositDone_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) DepositIgnore(ctx context.Context, in *DepositIgnoreRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_DepositIgnore_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) DepositVerify(ctx context.Context, in *DepositVerifyRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_DepositVerify_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) DepositDown(ctx context.Context, in *DepositItemsRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_DepositDown_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) DepositItems(ctx context.Context, in *DepositItemsRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_DepositItems_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) DepositIgnoreItems(ctx context.Context, in *DepositVerifyRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_DepositIgnoreItems_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) DepositRecover(ctx context.Context, in *IdRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_DepositRecover_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *storeClient) DepositBackfill(ctx context.Context, in *DepositBackfillRequest, opts ...grpc.CallOption) (*Response, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Response)
err := c.cc.Invoke(ctx, Store_DepositBackfill_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
return out, nil
}
// StoreServer is the server API for Store service.
// All implementations must embed UnimplementedStoreServer
// for forward compatibility.
type StoreServer interface {
Status(context.Context, *StatusRequest) (*Response, error)
Edit(context.Context, *EditRequest) (*Response, error)
Create(context.Context, *CreateRequest) (*Response, error)
ToSale(context.Context, *StatusRequest) (*Response, error)
Pwd(context.Context, *PwdRequest) (*Response, error)
Info(context.Context, *ToSaleRequest) (*Response, error)
Content(context.Context, *ContentRequest) (*Response, error)
Names(context.Context, *EmptyRequest) (*Response, error)
Items(context.Context, *ItemsRequest) (*Response, error)
VerifyItems(context.Context, *VerifyItemsRequest) (*Response, error)
VerifyStatus(context.Context, *StatusRequest) (*Response, error)
VerifyEdit(context.Context, *EditRequest) (*Response, error)
ApplyEdit(context.Context, *ApplyEditRequest) (*Response, error)
ApplyVerify(context.Context, *ItemsRequest) (*Response, error)
ApplyVerifyStatus(context.Context, *StatusRequest) (*Response, error)
DepositDone(context.Context, *IdRequest) (*Response, error)
DepositIgnore(context.Context, *DepositIgnoreRequest) (*Response, error)
DepositVerify(context.Context, *DepositVerifyRequest) (*Response, error)
DepositDown(context.Context, *DepositItemsRequest) (*Response, error)
DepositItems(context.Context, *DepositItemsRequest) (*Response, error)
DepositIgnoreItems(context.Context, *DepositVerifyRequest) (*Response, error)
DepositRecover(context.Context, *IdRequest) (*Response, error)
DepositBackfill(context.Context, *DepositBackfillRequest) (*Response, error)
mustEmbedUnimplementedStoreServer()
}
@@ -65,6 +351,72 @@ type UnimplementedStoreServer struct{}
func (UnimplementedStoreServer) Status(context.Context, *StatusRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method Status not implemented")
}
func (UnimplementedStoreServer) Edit(context.Context, *EditRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method Edit not implemented")
}
func (UnimplementedStoreServer) Create(context.Context, *CreateRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method Create not implemented")
}
func (UnimplementedStoreServer) ToSale(context.Context, *StatusRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method ToSale not implemented")
}
func (UnimplementedStoreServer) Pwd(context.Context, *PwdRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method Pwd not implemented")
}
func (UnimplementedStoreServer) Info(context.Context, *ToSaleRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method Info not implemented")
}
func (UnimplementedStoreServer) Content(context.Context, *ContentRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method Content not implemented")
}
func (UnimplementedStoreServer) Names(context.Context, *EmptyRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method Names not implemented")
}
func (UnimplementedStoreServer) Items(context.Context, *ItemsRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method Items not implemented")
}
func (UnimplementedStoreServer) VerifyItems(context.Context, *VerifyItemsRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method VerifyItems not implemented")
}
func (UnimplementedStoreServer) VerifyStatus(context.Context, *StatusRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method VerifyStatus not implemented")
}
func (UnimplementedStoreServer) VerifyEdit(context.Context, *EditRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method VerifyEdit not implemented")
}
func (UnimplementedStoreServer) ApplyEdit(context.Context, *ApplyEditRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method ApplyEdit not implemented")
}
func (UnimplementedStoreServer) ApplyVerify(context.Context, *ItemsRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method ApplyVerify not implemented")
}
func (UnimplementedStoreServer) ApplyVerifyStatus(context.Context, *StatusRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method ApplyVerifyStatus not implemented")
}
func (UnimplementedStoreServer) DepositDone(context.Context, *IdRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method DepositDone not implemented")
}
func (UnimplementedStoreServer) DepositIgnore(context.Context, *DepositIgnoreRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method DepositIgnore not implemented")
}
func (UnimplementedStoreServer) DepositVerify(context.Context, *DepositVerifyRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method DepositVerify not implemented")
}
func (UnimplementedStoreServer) DepositDown(context.Context, *DepositItemsRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method DepositDown not implemented")
}
func (UnimplementedStoreServer) DepositItems(context.Context, *DepositItemsRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method DepositItems not implemented")
}
func (UnimplementedStoreServer) DepositIgnoreItems(context.Context, *DepositVerifyRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method DepositIgnoreItems not implemented")
}
func (UnimplementedStoreServer) DepositRecover(context.Context, *IdRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method DepositRecover not implemented")
}
func (UnimplementedStoreServer) DepositBackfill(context.Context, *DepositBackfillRequest) (*Response, error) {
return nil, status.Error(codes.Unimplemented, "method DepositBackfill not implemented")
}
func (UnimplementedStoreServer) mustEmbedUnimplementedStoreServer() {}
func (UnimplementedStoreServer) testEmbeddedByValue() {}
@@ -104,6 +456,402 @@ func _Store_Status_Handler(srv interface{}, ctx context.Context, dec func(interf
return interceptor(ctx, in, info, handler)
}
func _Store_Edit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EditRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).Edit(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_Edit_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).Edit(ctx, req.(*EditRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(CreateRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).Create(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_Create_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).Create(ctx, req.(*CreateRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_ToSale_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(StatusRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).ToSale(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_ToSale_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).ToSale(ctx, req.(*StatusRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_Pwd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(PwdRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).Pwd(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_Pwd_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).Pwd(ctx, req.(*PwdRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_Info_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ToSaleRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).Info(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_Info_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).Info(ctx, req.(*ToSaleRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_Content_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ContentRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).Content(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_Content_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).Content(ctx, req.(*ContentRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_Names_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EmptyRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).Names(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_Names_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).Names(ctx, req.(*EmptyRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_Items_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ItemsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).Items(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_Items_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).Items(ctx, req.(*ItemsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_VerifyItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(VerifyItemsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).VerifyItems(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_VerifyItems_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).VerifyItems(ctx, req.(*VerifyItemsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_VerifyStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(StatusRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).VerifyStatus(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_VerifyStatus_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).VerifyStatus(ctx, req.(*StatusRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_VerifyEdit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EditRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).VerifyEdit(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_VerifyEdit_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).VerifyEdit(ctx, req.(*EditRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_ApplyEdit_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ApplyEditRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).ApplyEdit(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_ApplyEdit_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).ApplyEdit(ctx, req.(*ApplyEditRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_ApplyVerify_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ItemsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).ApplyVerify(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_ApplyVerify_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).ApplyVerify(ctx, req.(*ItemsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_ApplyVerifyStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(StatusRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).ApplyVerifyStatus(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_ApplyVerifyStatus_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).ApplyVerifyStatus(ctx, req.(*StatusRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_DepositDone_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(IdRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).DepositDone(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_DepositDone_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).DepositDone(ctx, req.(*IdRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_DepositIgnore_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DepositIgnoreRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).DepositIgnore(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_DepositIgnore_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).DepositIgnore(ctx, req.(*DepositIgnoreRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_DepositVerify_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DepositVerifyRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).DepositVerify(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_DepositVerify_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).DepositVerify(ctx, req.(*DepositVerifyRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_DepositDown_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DepositItemsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).DepositDown(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_DepositDown_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).DepositDown(ctx, req.(*DepositItemsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_DepositItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DepositItemsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).DepositItems(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_DepositItems_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).DepositItems(ctx, req.(*DepositItemsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_DepositIgnoreItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DepositVerifyRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).DepositIgnoreItems(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_DepositIgnoreItems_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).DepositIgnoreItems(ctx, req.(*DepositVerifyRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_DepositRecover_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(IdRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).DepositRecover(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_DepositRecover_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).DepositRecover(ctx, req.(*IdRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Store_DepositBackfill_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DepositBackfillRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(StoreServer).DepositBackfill(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: Store_DepositBackfill_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(StoreServer).DepositBackfill(ctx, req.(*DepositBackfillRequest))
}
return interceptor(ctx, in, info, handler)
}
// Store_ServiceDesc is the grpc.ServiceDesc for Store service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
@@ -115,6 +863,94 @@ var Store_ServiceDesc = grpc.ServiceDesc{
MethodName: "Status",
Handler: _Store_Status_Handler,
},
{
MethodName: "Edit",
Handler: _Store_Edit_Handler,
},
{
MethodName: "Create",
Handler: _Store_Create_Handler,
},
{
MethodName: "ToSale",
Handler: _Store_ToSale_Handler,
},
{
MethodName: "Pwd",
Handler: _Store_Pwd_Handler,
},
{
MethodName: "Info",
Handler: _Store_Info_Handler,
},
{
MethodName: "Content",
Handler: _Store_Content_Handler,
},
{
MethodName: "Names",
Handler: _Store_Names_Handler,
},
{
MethodName: "Items",
Handler: _Store_Items_Handler,
},
{
MethodName: "VerifyItems",
Handler: _Store_VerifyItems_Handler,
},
{
MethodName: "VerifyStatus",
Handler: _Store_VerifyStatus_Handler,
},
{
MethodName: "VerifyEdit",
Handler: _Store_VerifyEdit_Handler,
},
{
MethodName: "ApplyEdit",
Handler: _Store_ApplyEdit_Handler,
},
{
MethodName: "ApplyVerify",
Handler: _Store_ApplyVerify_Handler,
},
{
MethodName: "ApplyVerifyStatus",
Handler: _Store_ApplyVerifyStatus_Handler,
},
{
MethodName: "DepositDone",
Handler: _Store_DepositDone_Handler,
},
{
MethodName: "DepositIgnore",
Handler: _Store_DepositIgnore_Handler,
},
{
MethodName: "DepositVerify",
Handler: _Store_DepositVerify_Handler,
},
{
MethodName: "DepositDown",
Handler: _Store_DepositDown_Handler,
},
{
MethodName: "DepositItems",
Handler: _Store_DepositItems_Handler,
},
{
MethodName: "DepositIgnoreItems",
Handler: _Store_DepositIgnoreItems_Handler,
},
{
MethodName: "DepositRecover",
Handler: _Store_DepositRecover_Handler,
},
{
MethodName: "DepositBackfill",
Handler: _Store_DepositBackfill_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "store/store.proto",