123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121 |
- package mount_pb
- import (
- context "context"
- grpc "google.golang.org/grpc"
- codes "google.golang.org/grpc/codes"
- status "google.golang.org/grpc/status"
- )
- const _ = grpc.SupportPackageIsVersion9
- const (
- SeaweedMount_Configure_FullMethodName = "/messaging_pb.SeaweedMount/Configure"
- )
- type SeaweedMountClient interface {
- Configure(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*ConfigureResponse, error)
- }
- type seaweedMountClient struct {
- cc grpc.ClientConnInterface
- }
- func NewSeaweedMountClient(cc grpc.ClientConnInterface) SeaweedMountClient {
- return &seaweedMountClient{cc}
- }
- func (c *seaweedMountClient) Configure(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*ConfigureResponse, error) {
- cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
- out := new(ConfigureResponse)
- err := c.cc.Invoke(ctx, SeaweedMount_Configure_FullMethodName, in, out, cOpts...)
- if err != nil {
- return nil, err
- }
- return out, nil
- }
- type SeaweedMountServer interface {
- Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)
- mustEmbedUnimplementedSeaweedMountServer()
- }
- type UnimplementedSeaweedMountServer struct{}
- func (UnimplementedSeaweedMountServer) Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error) {
- return nil, status.Errorf(codes.Unimplemented, "method Configure not implemented")
- }
- func (UnimplementedSeaweedMountServer) mustEmbedUnimplementedSeaweedMountServer() {}
- func (UnimplementedSeaweedMountServer) testEmbeddedByValue() {}
- type UnsafeSeaweedMountServer interface {
- mustEmbedUnimplementedSeaweedMountServer()
- }
- func RegisterSeaweedMountServer(s grpc.ServiceRegistrar, srv SeaweedMountServer) {
-
-
-
-
- if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
- t.testEmbeddedByValue()
- }
- s.RegisterService(&SeaweedMount_ServiceDesc, srv)
- }
- func _SeaweedMount_Configure_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(ConfigureRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(SeaweedMountServer).Configure(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: SeaweedMount_Configure_FullMethodName,
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(SeaweedMountServer).Configure(ctx, req.(*ConfigureRequest))
- }
- return interceptor(ctx, in, info, handler)
- }
- var SeaweedMount_ServiceDesc = grpc.ServiceDesc{
- ServiceName: "messaging_pb.SeaweedMount",
- HandlerType: (*SeaweedMountServer)(nil),
- Methods: []grpc.MethodDesc{
- {
- MethodName: "Configure",
- Handler: _SeaweedMount_Configure_Handler,
- },
- },
- Streams: []grpc.StreamDesc{},
- Metadata: "mount.proto",
- }
|