// Code generated by protoc-gen-go-triple. DO NOT EDIT. // versions: // - protoc-gen-go-triple v1.0.5 // - protoc v6.32.0 // source: api/supplier/supplier.proto package supplier import ( context "context" protocol "dubbo.apache.org/dubbo-go/v3/protocol" dubbo3 "dubbo.apache.org/dubbo-go/v3/protocol/dubbo3" invocation "dubbo.apache.org/dubbo-go/v3/protocol/invocation" grpc_go "github.com/dubbogo/grpc-go" codes "github.com/dubbogo/grpc-go/codes" metadata "github.com/dubbogo/grpc-go/metadata" status "github.com/dubbogo/grpc-go/status" common "github.com/dubbogo/triple/pkg/common" constant "github.com/dubbogo/triple/pkg/common/constant" triple "github.com/dubbogo/triple/pkg/triple" ) // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. const _ = grpc_go.SupportPackageIsVersion7 // SupplierClient is the client API for Supplier service. // // 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 SupplierClient interface { // 供应商curd GetSupplier(ctx context.Context, in *GetSupplierRequest, opts ...grpc_go.CallOption) (*UpdateSupplierRequest, common.ErrorWithAttachment) CreateSupplier(ctx context.Context, in *CreateSupplierRequest, opts ...grpc_go.CallOption) (*CreateSupplierResponse, common.ErrorWithAttachment) UpdateSupplier(ctx context.Context, in *UpdateSupplierRequest, opts ...grpc_go.CallOption) (*CreateSupplierResponse, common.ErrorWithAttachment) GetSupplierList(ctx context.Context, in *GetSupplierListRequest, opts ...grpc_go.CallOption) (*GetSupplierListResponse, common.ErrorWithAttachment) // 组织字典 CreateOrganizeDictionary(ctx context.Context, in *CreateOrganizeDictionaryRequest, opts ...grpc_go.CallOption) (*CreateOrganizeDictionaryResponse, common.ErrorWithAttachment) GetOrganizeDictionaryList(ctx context.Context, in *GetOrganizeDictionaryListRequest, opts ...grpc_go.CallOption) (*GetOrganizeDictionaryListResponse, common.ErrorWithAttachment) // 国家组织 GetCountryRegionList(ctx context.Context, in *GetCountryRegionListRequest, opts ...grpc_go.CallOption) (*GetCountryRegionListResponse, common.ErrorWithAttachment) // 导入 CreateImportRecord(ctx context.Context, in *CreateImportRecordRequest, opts ...grpc_go.CallOption) (*CreateImportRecordResponse, common.ErrorWithAttachment) GetImportRecordInfo(ctx context.Context, in *GetImportRecordRequest, opts ...grpc_go.CallOption) (*GetImportRecordResponse, common.ErrorWithAttachment) } type supplierClient struct { cc *triple.TripleConn } type SupplierClientImpl struct { GetSupplier func(ctx context.Context, in *GetSupplierRequest) (*UpdateSupplierRequest, error) CreateSupplier func(ctx context.Context, in *CreateSupplierRequest) (*CreateSupplierResponse, error) UpdateSupplier func(ctx context.Context, in *UpdateSupplierRequest) (*CreateSupplierResponse, error) GetSupplierList func(ctx context.Context, in *GetSupplierListRequest) (*GetSupplierListResponse, error) CreateOrganizeDictionary func(ctx context.Context, in *CreateOrganizeDictionaryRequest) (*CreateOrganizeDictionaryResponse, error) GetOrganizeDictionaryList func(ctx context.Context, in *GetOrganizeDictionaryListRequest) (*GetOrganizeDictionaryListResponse, error) GetCountryRegionList func(ctx context.Context, in *GetCountryRegionListRequest) (*GetCountryRegionListResponse, error) CreateImportRecord func(ctx context.Context, in *CreateImportRecordRequest) (*CreateImportRecordResponse, error) GetImportRecordInfo func(ctx context.Context, in *GetImportRecordRequest) (*GetImportRecordResponse, error) } func (c *SupplierClientImpl) GetDubboStub(cc *triple.TripleConn) SupplierClient { return NewSupplierClient(cc) } func (c *SupplierClientImpl) XXX_InterfaceName() string { return "supplier.Supplier" } func NewSupplierClient(cc *triple.TripleConn) SupplierClient { return &supplierClient{cc} } func (c *supplierClient) GetSupplier(ctx context.Context, in *GetSupplierRequest, opts ...grpc_go.CallOption) (*UpdateSupplierRequest, common.ErrorWithAttachment) { out := new(UpdateSupplierRequest) interfaceKey := ctx.Value(constant.InterfaceKey).(string) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetSupplier", in, out) } func (c *supplierClient) CreateSupplier(ctx context.Context, in *CreateSupplierRequest, opts ...grpc_go.CallOption) (*CreateSupplierResponse, common.ErrorWithAttachment) { out := new(CreateSupplierResponse) interfaceKey := ctx.Value(constant.InterfaceKey).(string) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CreateSupplier", in, out) } func (c *supplierClient) UpdateSupplier(ctx context.Context, in *UpdateSupplierRequest, opts ...grpc_go.CallOption) (*CreateSupplierResponse, common.ErrorWithAttachment) { out := new(CreateSupplierResponse) interfaceKey := ctx.Value(constant.InterfaceKey).(string) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UpdateSupplier", in, out) } func (c *supplierClient) GetSupplierList(ctx context.Context, in *GetSupplierListRequest, opts ...grpc_go.CallOption) (*GetSupplierListResponse, common.ErrorWithAttachment) { out := new(GetSupplierListResponse) interfaceKey := ctx.Value(constant.InterfaceKey).(string) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetSupplierList", in, out) } func (c *supplierClient) CreateOrganizeDictionary(ctx context.Context, in *CreateOrganizeDictionaryRequest, opts ...grpc_go.CallOption) (*CreateOrganizeDictionaryResponse, common.ErrorWithAttachment) { out := new(CreateOrganizeDictionaryResponse) interfaceKey := ctx.Value(constant.InterfaceKey).(string) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CreateOrganizeDictionary", in, out) } func (c *supplierClient) GetOrganizeDictionaryList(ctx context.Context, in *GetOrganizeDictionaryListRequest, opts ...grpc_go.CallOption) (*GetOrganizeDictionaryListResponse, common.ErrorWithAttachment) { out := new(GetOrganizeDictionaryListResponse) interfaceKey := ctx.Value(constant.InterfaceKey).(string) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetOrganizeDictionaryList", in, out) } func (c *supplierClient) GetCountryRegionList(ctx context.Context, in *GetCountryRegionListRequest, opts ...grpc_go.CallOption) (*GetCountryRegionListResponse, common.ErrorWithAttachment) { out := new(GetCountryRegionListResponse) interfaceKey := ctx.Value(constant.InterfaceKey).(string) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetCountryRegionList", in, out) } func (c *supplierClient) CreateImportRecord(ctx context.Context, in *CreateImportRecordRequest, opts ...grpc_go.CallOption) (*CreateImportRecordResponse, common.ErrorWithAttachment) { out := new(CreateImportRecordResponse) interfaceKey := ctx.Value(constant.InterfaceKey).(string) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CreateImportRecord", in, out) } func (c *supplierClient) GetImportRecordInfo(ctx context.Context, in *GetImportRecordRequest, opts ...grpc_go.CallOption) (*GetImportRecordResponse, common.ErrorWithAttachment) { out := new(GetImportRecordResponse) interfaceKey := ctx.Value(constant.InterfaceKey).(string) return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetImportRecordInfo", in, out) } // SupplierServer is the server API for Supplier service. // All implementations must embed UnimplementedSupplierServer // for forward compatibility type SupplierServer interface { // 供应商curd GetSupplier(context.Context, *GetSupplierRequest) (*UpdateSupplierRequest, error) CreateSupplier(context.Context, *CreateSupplierRequest) (*CreateSupplierResponse, error) UpdateSupplier(context.Context, *UpdateSupplierRequest) (*CreateSupplierResponse, error) GetSupplierList(context.Context, *GetSupplierListRequest) (*GetSupplierListResponse, error) // 组织字典 CreateOrganizeDictionary(context.Context, *CreateOrganizeDictionaryRequest) (*CreateOrganizeDictionaryResponse, error) GetOrganizeDictionaryList(context.Context, *GetOrganizeDictionaryListRequest) (*GetOrganizeDictionaryListResponse, error) // 国家组织 GetCountryRegionList(context.Context, *GetCountryRegionListRequest) (*GetCountryRegionListResponse, error) // 导入 CreateImportRecord(context.Context, *CreateImportRecordRequest) (*CreateImportRecordResponse, error) GetImportRecordInfo(context.Context, *GetImportRecordRequest) (*GetImportRecordResponse, error) mustEmbedUnimplementedSupplierServer() } // UnimplementedSupplierServer must be embedded to have forward compatible implementations. type UnimplementedSupplierServer struct { proxyImpl protocol.Invoker } func (UnimplementedSupplierServer) GetSupplier(context.Context, *GetSupplierRequest) (*UpdateSupplierRequest, error) { return nil, status.Errorf(codes.Unimplemented, "method GetSupplier not implemented") } func (UnimplementedSupplierServer) CreateSupplier(context.Context, *CreateSupplierRequest) (*CreateSupplierResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateSupplier not implemented") } func (UnimplementedSupplierServer) UpdateSupplier(context.Context, *UpdateSupplierRequest) (*CreateSupplierResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateSupplier not implemented") } func (UnimplementedSupplierServer) GetSupplierList(context.Context, *GetSupplierListRequest) (*GetSupplierListResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetSupplierList not implemented") } func (UnimplementedSupplierServer) CreateOrganizeDictionary(context.Context, *CreateOrganizeDictionaryRequest) (*CreateOrganizeDictionaryResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateOrganizeDictionary not implemented") } func (UnimplementedSupplierServer) GetOrganizeDictionaryList(context.Context, *GetOrganizeDictionaryListRequest) (*GetOrganizeDictionaryListResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetOrganizeDictionaryList not implemented") } func (UnimplementedSupplierServer) GetCountryRegionList(context.Context, *GetCountryRegionListRequest) (*GetCountryRegionListResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetCountryRegionList not implemented") } func (UnimplementedSupplierServer) CreateImportRecord(context.Context, *CreateImportRecordRequest) (*CreateImportRecordResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateImportRecord not implemented") } func (UnimplementedSupplierServer) GetImportRecordInfo(context.Context, *GetImportRecordRequest) (*GetImportRecordResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetImportRecordInfo not implemented") } func (s *UnimplementedSupplierServer) XXX_SetProxyImpl(impl protocol.Invoker) { s.proxyImpl = impl } func (s *UnimplementedSupplierServer) XXX_GetProxyImpl() protocol.Invoker { return s.proxyImpl } func (s *UnimplementedSupplierServer) XXX_ServiceDesc() *grpc_go.ServiceDesc { return &Supplier_ServiceDesc } func (s *UnimplementedSupplierServer) XXX_InterfaceName() string { return "supplier.Supplier" } func (UnimplementedSupplierServer) mustEmbedUnimplementedSupplierServer() {} // UnsafeSupplierServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to SupplierServer will // result in compilation errors. type UnsafeSupplierServer interface { mustEmbedUnimplementedSupplierServer() } func RegisterSupplierServer(s grpc_go.ServiceRegistrar, srv SupplierServer) { s.RegisterService(&Supplier_ServiceDesc, srv) } func _Supplier_GetSupplier_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { in := new(GetSupplierRequest) if err := dec(in); err != nil { return nil, err } base := srv.(dubbo3.Dubbo3GrpcService) args := []interface{}{} args = append(args, in) md, _ := metadata.FromIncomingContext(ctx) invAttachment := make(map[string]interface{}, len(md)) for k, v := range md { invAttachment[k] = v } invo := invocation.NewRPCInvocation("GetSupplier", args, invAttachment) if interceptor == nil { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } info := &grpc_go.UnaryServerInfo{ Server: srv, FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string), } handler := func(ctx context.Context, req interface{}) (interface{}, error) { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } return interceptor(ctx, in, info, handler) } func _Supplier_CreateSupplier_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { in := new(CreateSupplierRequest) if err := dec(in); err != nil { return nil, err } base := srv.(dubbo3.Dubbo3GrpcService) args := []interface{}{} args = append(args, in) md, _ := metadata.FromIncomingContext(ctx) invAttachment := make(map[string]interface{}, len(md)) for k, v := range md { invAttachment[k] = v } invo := invocation.NewRPCInvocation("CreateSupplier", args, invAttachment) if interceptor == nil { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } info := &grpc_go.UnaryServerInfo{ Server: srv, FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string), } handler := func(ctx context.Context, req interface{}) (interface{}, error) { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } return interceptor(ctx, in, info, handler) } func _Supplier_UpdateSupplier_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateSupplierRequest) if err := dec(in); err != nil { return nil, err } base := srv.(dubbo3.Dubbo3GrpcService) args := []interface{}{} args = append(args, in) md, _ := metadata.FromIncomingContext(ctx) invAttachment := make(map[string]interface{}, len(md)) for k, v := range md { invAttachment[k] = v } invo := invocation.NewRPCInvocation("UpdateSupplier", args, invAttachment) if interceptor == nil { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } info := &grpc_go.UnaryServerInfo{ Server: srv, FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string), } handler := func(ctx context.Context, req interface{}) (interface{}, error) { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } return interceptor(ctx, in, info, handler) } func _Supplier_GetSupplierList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { in := new(GetSupplierListRequest) if err := dec(in); err != nil { return nil, err } base := srv.(dubbo3.Dubbo3GrpcService) args := []interface{}{} args = append(args, in) md, _ := metadata.FromIncomingContext(ctx) invAttachment := make(map[string]interface{}, len(md)) for k, v := range md { invAttachment[k] = v } invo := invocation.NewRPCInvocation("GetSupplierList", args, invAttachment) if interceptor == nil { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } info := &grpc_go.UnaryServerInfo{ Server: srv, FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string), } handler := func(ctx context.Context, req interface{}) (interface{}, error) { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } return interceptor(ctx, in, info, handler) } func _Supplier_CreateOrganizeDictionary_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { in := new(CreateOrganizeDictionaryRequest) if err := dec(in); err != nil { return nil, err } base := srv.(dubbo3.Dubbo3GrpcService) args := []interface{}{} args = append(args, in) md, _ := metadata.FromIncomingContext(ctx) invAttachment := make(map[string]interface{}, len(md)) for k, v := range md { invAttachment[k] = v } invo := invocation.NewRPCInvocation("CreateOrganizeDictionary", args, invAttachment) if interceptor == nil { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } info := &grpc_go.UnaryServerInfo{ Server: srv, FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string), } handler := func(ctx context.Context, req interface{}) (interface{}, error) { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } return interceptor(ctx, in, info, handler) } func _Supplier_GetOrganizeDictionaryList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { in := new(GetOrganizeDictionaryListRequest) if err := dec(in); err != nil { return nil, err } base := srv.(dubbo3.Dubbo3GrpcService) args := []interface{}{} args = append(args, in) md, _ := metadata.FromIncomingContext(ctx) invAttachment := make(map[string]interface{}, len(md)) for k, v := range md { invAttachment[k] = v } invo := invocation.NewRPCInvocation("GetOrganizeDictionaryList", args, invAttachment) if interceptor == nil { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } info := &grpc_go.UnaryServerInfo{ Server: srv, FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string), } handler := func(ctx context.Context, req interface{}) (interface{}, error) { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } return interceptor(ctx, in, info, handler) } func _Supplier_GetCountryRegionList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { in := new(GetCountryRegionListRequest) if err := dec(in); err != nil { return nil, err } base := srv.(dubbo3.Dubbo3GrpcService) args := []interface{}{} args = append(args, in) md, _ := metadata.FromIncomingContext(ctx) invAttachment := make(map[string]interface{}, len(md)) for k, v := range md { invAttachment[k] = v } invo := invocation.NewRPCInvocation("GetCountryRegionList", args, invAttachment) if interceptor == nil { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } info := &grpc_go.UnaryServerInfo{ Server: srv, FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string), } handler := func(ctx context.Context, req interface{}) (interface{}, error) { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } return interceptor(ctx, in, info, handler) } func _Supplier_CreateImportRecord_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { in := new(CreateImportRecordRequest) if err := dec(in); err != nil { return nil, err } base := srv.(dubbo3.Dubbo3GrpcService) args := []interface{}{} args = append(args, in) md, _ := metadata.FromIncomingContext(ctx) invAttachment := make(map[string]interface{}, len(md)) for k, v := range md { invAttachment[k] = v } invo := invocation.NewRPCInvocation("CreateImportRecord", args, invAttachment) if interceptor == nil { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } info := &grpc_go.UnaryServerInfo{ Server: srv, FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string), } handler := func(ctx context.Context, req interface{}) (interface{}, error) { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } return interceptor(ctx, in, info, handler) } func _Supplier_GetImportRecordInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) { in := new(GetImportRecordRequest) if err := dec(in); err != nil { return nil, err } base := srv.(dubbo3.Dubbo3GrpcService) args := []interface{}{} args = append(args, in) md, _ := metadata.FromIncomingContext(ctx) invAttachment := make(map[string]interface{}, len(md)) for k, v := range md { invAttachment[k] = v } invo := invocation.NewRPCInvocation("GetImportRecordInfo", args, invAttachment) if interceptor == nil { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } info := &grpc_go.UnaryServerInfo{ Server: srv, FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string), } handler := func(ctx context.Context, req interface{}) (interface{}, error) { result := base.XXX_GetProxyImpl().Invoke(ctx, invo) return result, result.Error() } return interceptor(ctx, in, info, handler) } // Supplier_ServiceDesc is the grpc_go.ServiceDesc for Supplier service. // It's only intended for direct use with grpc_go.RegisterService, // and not to be introspected or modified (even as a copy) var Supplier_ServiceDesc = grpc_go.ServiceDesc{ ServiceName: "supplier.Supplier", HandlerType: (*SupplierServer)(nil), Methods: []grpc_go.MethodDesc{ { MethodName: "GetSupplier", Handler: _Supplier_GetSupplier_Handler, }, { MethodName: "CreateSupplier", Handler: _Supplier_CreateSupplier_Handler, }, { MethodName: "UpdateSupplier", Handler: _Supplier_UpdateSupplier_Handler, }, { MethodName: "GetSupplierList", Handler: _Supplier_GetSupplierList_Handler, }, { MethodName: "CreateOrganizeDictionary", Handler: _Supplier_CreateOrganizeDictionary_Handler, }, { MethodName: "GetOrganizeDictionaryList", Handler: _Supplier_GetOrganizeDictionaryList_Handler, }, { MethodName: "GetCountryRegionList", Handler: _Supplier_GetCountryRegionList_Handler, }, { MethodName: "CreateImportRecord", Handler: _Supplier_CreateImportRecord_Handler, }, { MethodName: "GetImportRecordInfo", Handler: _Supplier_GetImportRecordInfo_Handler, }, }, Streams: []grpc_go.StreamDesc{}, Metadata: "api/supplier/supplier.proto", }